Apache Flink용 현재 버전 업그레이드를 사용하여 애플리케이션 업그레이드 - Managed Service for Apache Flink
업그레이드 전: Apache Flink 애플리케이션 업데이트

Amazon Managed Service for Apache Flink는 이전에 Amazon Kinesis Data Analytics for Apache Flink로 알려졌습니다.

기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.

Apache Flink용 현재 버전 업그레이드를 사용하여 애플리케이션 업그레이드

시작하기 전에 현재 버전 업그레이드 동영상을 시청하는 것이 좋습니다.

Apache Flink에 대한 현재 버전 업그레이드를 수행하려면 , AWS CloudFormation AWS SDK또는 AWS CLI를 사용할 수 있습니다 AWS Management Console. READY 또는 RUNNING 상태의 Managed Service for Apache Flink와 함께 사용하는 모든 기존 애플리케이션에서 이 기능을 사용할 수 있습니다. 를 UpdateApplication API 사용하여 Flink 런타임을 변경하는 기능을 추가합니다.

업그레이드 전: Apache Flink 애플리케이션 업데이트

Flink 애플리케이션을 작성할 때 종속성과 함께 애플리케이션에 번들링JAR하고 를 Amazon S3 버킷JAR에 업로드합니다. 여기에서 Amazon Managed Service for Apache Flink는 선택한 새 Flink 런타임에서 작업을 실행합니다. 업그레이드하려는 Flink 런타임과의 호환성을 얻으려면 애플리케이션을 업데이트해야 할 수 있습니다. Flink 버전 간에 버전 업그레이드가 실패하는 불일치가 있을 수 있습니다. 가장 일반적으로 소스(수신) 또는 대상(싱크, 발신) 및 Scala 종속성에 대한 커넥터와 함께 사용됩니다. Managed Service for Apache Flink의 Flink 1.15 이상 버전은 Scala에 구애받지 않으며 에 사용하려는 Scala 버전이 포함되어야 JAR 합니다.

애플리케이션을 업데이트하려면

  1. 상태로 애플리케이션을 업그레이드하는 방법에 대한 Flink 커뮤니티의 조언을 읽어보세요. 애플리케이션 및 링크 버전 업그레이드를 참조하세요.

  2. 알고 있는 문제 및 제한 사항 목록을 읽습니다. 애플리케이션 업그레이드 시 예방 조치 및 알려진 문제을 참조하세요.

  3. 종속성을 업데이트하고 애플리케이션을 로컬에서 테스트합니다. 이러한 종속성은 일반적으로 다음과 같습니다.

    1. Flink 런타임 및 API.

    2. 새 Flink 런타임에 권장되는 커넥터입니다. 업데이트하려는 특정 런타임에 대한 릴리스 버전에서 이러한 항목을 찾을 수 있습니다.

    3. Scala – Apache Flink는 Flink 1.15로 시작하고 Flink 1.15를 포함하여 Scala에 구애받지 않습니다. 애플리케이션에 사용하려는 Scala 종속성을 포함해야 합니다JAR.

  4. zipfileJAR에 새 애플리케이션을 빌드하고 Amazon S3에 업로드합니다. 이전 JAR/zipfile과 다른 이름을 사용하는 것이 좋습니다. 롤백해야 하는 경우 이 정보를 사용합니다.

  5. 상태 저장 애플리케이션을 실행하는 경우 현재 애플리케이션의 스냅샷을 생성하는 것이 좋습니다. 이렇게 하면 업그레이드 도중 또는 이후에 문제가 발생할 경우 상태적으로 롤백할 수 있습니다.