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

Flink 2.2로 업그레이드: 전체 가이드

이 가이드에서는 Amazon Managed Service for Apache Flink 애플리케이션을 Flink 1.x에서 Flink 2.2로 업그레이드하기 위한 step-by-step 지침을 제공합니다. 이는 신중한 계획 및 테스트가 필요한 주요 버전 업그레이드입니다.

사전 조건

업그레이드를 시작하기 전에:

마이그레이션 경로 이해

업그레이드 환경은 애플리케이션의 Flink 2.2와의 호환성에 따라 달라집니다. 이러한 경로를 이해하면 적절하게 준비하고 현실적인 기대치를 설정하는 데 도움이 됩니다.

경로 1: 호환 가능한 바이너리 및 애플리케이션 상태

예상되는 사항:

가장 적합: 호환되는 직렬화를 사용하는 상태 비저장 애플리케이션 또는 애플리케이션(Avro, 호환되는 Protobuf 스키마, 컬렉션POJOs)

경로 2: 이진 비호환성

예상되는 사항:

가장 적합: Flink 작업 시작 중에 감지된 제거된 APIs 사용하는 애플리케이션

경로 3: 호환되지 않는 애플리케이션 상태

예상되는 사항:

가장 적합: 상태 직렬화 비호환성이 있는 애플리케이션(컬렉션POJOs, 특정 Kryo 직렬화 상태)

1단계: 준비

애플리케이션 코드 업데이트

Flink 2.2와 호환되도록 애플리케이션 코드를 업데이트합니다.

업데이트된 애플리케이션 코드 업로드

2단계: 자동 롤백 활성화

자동 롤백을 사용하면 업그레이드에 실패할 경우 Amazon Managed Service for Apache Flink가 자동으로 이전 버전으로 되돌릴 수 있습니다.

자동 롤백 상태 확인

AWS Management Console:

AWS CLI:

aws kinesisanalyticsv2 describe-application \
    --application-name MyApplication \
    --query 'ApplicationDetail.ApplicationConfigurationDescription.ApplicationSystemRollbackConfigurationDescription.RollbackEnabled'

자동 롤백 활성화(활성화되지 않은 경우)

aws kinesisanalyticsv2 update-application \
    --application-name MyApplication \
    --current-application-version-id <version-id> \
    --application-configuration-update '{
        "ApplicationSystemRollbackConfigurationUpdate": {
            "RollbackEnabledUpdate": true
        }
    }'

3단계: 스냅샷 생성(선택 사항)

애플리케이션에 자동 스냅샷이 활성화된 경우이 단계를 건너뛰고, 그렇지 않으면 업그레이드하기 전에 애플리케이션의 스냅샷을 생성하여 애플리케이션의 상태를 저장할 수 있습니다.

실행 중인 애플리케이션에서 스냅샷 생성

AWS Management Console:

AWS CLI:

aws kinesisanalyticsv2 create-application-snapshot \
    --application-name MyApplication \
    --snapshot-name pre-flink-2.2-upgrade

스냅샷 생성 확인

aws kinesisanalyticsv2 describe-application-snapshot \
    --application-name MyApplication \
    --snapshot-name pre-flink-2.2-upgrade

계속하기 READY 전에 SnapshotStatus가 될 때까지 기다립니다.

4단계: 애플리케이션 업그레이드

UpdateApplication 작업을 사용하여 Flink 애플리케이션을 업그레이드할 수 있습니다.

UpdateApplication API는 다음과 같은 여러 가지 방식으로 직접적으로 호출할 수 있습니다.

애플리케이션이 RUNNING 상태이거나 READY 상태로 중지된 경우 업그레이드를 수행할 수 있습니다. Amazon Managed Service for Apache Flink는 원래 런타임 버전과 대상 런타임 버전 간의 호환성을 검증합니다. 이 호환성 검사는 상태UpdateApplication일 때를 수행하거나 RUNNING 상태일 때 업그레이드할 StartApplication 때 실행됩니다READY.

실행 중 상태에서 업그레이드

aws kinesisanalyticsv2 update-application \
    --application-name MyApplication \
    --current-application-version-id <version-id> \
    --runtime-environment-update FLINK-2_2 \
    --application-configuration-update '{
        "ApplicationCodeConfigurationUpdate": {
            "CodeContentUpdate": {
                "S3ContentLocationUpdate": {
                    "FileKeyUpdate": "my-app-flink-2.2.jar"
                }
            }
        }
    }'

READY 상태에서 업그레이드

aws kinesisanalyticsv2 update-application \
    --application-name MyApplication \
    --current-application-version-id <version-id> \
    --runtime-environment-update FLINK-2_2 \
    --application-configuration-update '{
        "ApplicationCodeConfigurationUpdate": {
            "CodeContentUpdate": {
                "S3ContentLocationUpdate": {
                    "FileKeyUpdate": "my-app-flink-2.2.jar"
                }
            }
        }
    }'

5단계: 업그레이드 모니터링

호환성 검사

애플리케이션 상태 모니터링

애플리케이션 상태:

또한 CloudWatch에서 이러한 지표를 모니터링합니다.

지표 다시 시작:

체크포인트 지표:

6단계: 애플리케이션 동작 검증

애플리케이션이 Flink 2.2에서 실행된 후:

기능 검증

성능 검증

24시간 이상 실행

다음을 보장하기 위해 프로덕션 환경에서 최소 24시간 동안 애플리케이션을 실행하도록 허용합니다.

7단계: 롤백 절차

업그레이드에 실패하거나 애플리케이션이 실행 중이지만 비정상인 경우 이전 버전으로 롤백합니다.

자동 롤백

자동 롤백이 활성화되어 있고 시작 중에 업그레이드가 실패하면 Amazon Managed Service for Apache Flink가 자동으로 이전 버전으로 돌아갑니다.

수동 롤백

애플리케이션이 실행 중이지만 비정상인 경우 RollbackApplication API를 사용합니다.

AWS Management Console:

AWS CLI:

aws kinesisanalyticsv2 rollback-application \
    --application-name MyApplication \
    --current-application-version-id <version-id>

롤백 중에 발생하는 일:

다음 단계

업그레이드 중 질문이나 문제는 섹션을 참조Managed Service for Apache Flink 문제 해결하거나 AWS Support에 문의하세요.