애플리케이션 업그레이드에 대한 예방 조치 및 알려진 문제

테이블을 API 사용하는 경우 Apache Flink는 Flink 버전 간의 상태 호환성을 보장하지 않습니다. 자세한 내용은 Apache Flink 설명서의 스테이트풀 업그레이드 및 에볼루션을 참조하십시오.

플링크 1.6 상태는 플링크 1.18과 호환되지 않습니다. 1.6에서 1.18로 또는 이후 상태로 업그레이드하려는 경우 요청이 API 거부됩니다. 1.8, 1.11, 1.13, 1.15로 업그레이드하고 스냅샷을 만든 다음 1.18 이상으로 업그레이드할 수 있습니다. 자세한 내용은 Apache Flink 설명서의 애플리케이션 및 Flink 버전 업그레이드를 참조하십시오.

Flink 1.11 이전 버전을 사용하고 E nhanced-fan-out (EFO) 지원을 위해 amazon-kinesis-connector-flink 커넥터를 사용하는 경우 Flink 1.13 이상으로 스테이트풀 업그레이드를 하려면 추가 단계를 거쳐야 합니다. 이는 커넥터의 패키지 이름이 변경되었기 때문입니다. 자세한 내용은 amazon-kinesis-connector-flink를 참조하세요.

Flink 1.11 및 이전 버전용 amazon-kinesis-connector-flink 커넥터는 패키지를 software.amazon.kinesis 사용하지만 Flink 1.13 이상의 Kinesis 커넥터는 패키지를 사용합니다. org.apache.flink.streaming.connectors.kinesis 이 도구를 사용하여 마이그레이션을 지원하십시오: -state-migraator. amazon-kinesis-connector-flink

Flink 1.13 이전 버전을 사용하고 Flink 1.15 이상으로 업그레이드하는 경우, 스테이트풀 업그레이드를 위해서는 최신 버전이 아닌 Flink 1.15 FlinkKinesisProducer 이상에서 계속 사용해야 합니다. FlinkKinesisProducer KinesisStreamsSink 하지만 싱크대에 이미 커스텀 uid 세트가 있다면 상태를 유지하지 않기 때문에 전환할 수 있을 것입니다. KinesisStreamsSink FlinkKinesisProducer 사용자 지정이 설정되어 있기 때문에 uid Flink는 동일한 연산자로 취급합니다.

플링크 1.15부터 아파치 플링크는 런타임에 스칼라를 포함하지 않습니다. Flink 1.15 이상으로 업그레이드할 때는 사용하려는 스칼라 버전과 기타 스칼라 종속 항목을 코드 JAR /zip에 포함해야 합니다. 자세한 내용은 아파치 플링크용 아마존 매니지드 서비스 (Apache Flink) 1.15.2 릴리스를 참조하십시오.

애플리케이션에서 스칼라를 사용하고 플링크 1.11 이전 버전 (스칼라 2.11) 에서 플링크 1.13 (스칼라 2.12) 으로 업그레이드하는 경우, 코드에 스칼라 2.12가 사용되는지 확인하십시오. 그렇지 않으면 Flink 1.13 애플리케이션이 Flink 1.13 런타임에서 Scala 2.11 클래스를 찾지 못할 수 있습니다.

Flink 응용 프로그램을 다운그레이드할 수 있지만 이전에 응용 프로그램을 이전 Flink 버전에서 실행했던 경우로 제한됩니다. 스테이트풀 업그레이드의 경우 Apache Flink용 Managed Service for Apache Flink에서는 다운그레이드에 해당 버전 또는 이전 버전으로 찍은 스냅샷을 사용해야 합니다.

런타임을 Flink 1.13 이상에서 Flink 1.11 또는 이전 버전으로 업데이트하고 앱에서 HashMap 상태 백엔드를 사용하는 경우 애플리케이션이 계속 실패합니다.