지원되지 않는 Kinesis 커넥터가 있는 애플리케이션 - Managed Service for Apache Flink
거부 오류 해결 단계

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

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

지원되지 않는 Kinesis 커넥터가 있는 애플리케이션

Managed Service for Apache Flink for Apache Flink 버전 1.15 이상은 애플리케이션 또는 아카이브()에 번들로 제공되는 지원되지 않는 Kinesis Connector 버전(이전 버전 1.15.2)을 사용하는 경우 애플리케이션의 시작 또는 업데이트를 자동으로 거부합니다ZIP. JARs

거부 오류

다음을 통해 애플리케이션 생성/업데이트 호출을 제출할 때 다음 오류가 표시됩니다.

An error occurred (InvalidArgumentException) when calling the CreateApplication operation: An unsupported Kinesis connector version has been detected in the application. Please update flink-connector-kinesis to any version equal to or newer than 1.15.2.
For more information refer to connector fix: https://issues.apache.org/jira/browse/FLINK-23528

해결 단계

  • flink-connector-kinesis에 대한 애플리케이션 종속성을 업데이트하십시오. Maven을 프로젝트의 빌드 도구로 사용하고 있다면 Maven 종속성 업데이트 을 따르세요. Gradle을 사용하고 있다면 Gradle 종속성 업데이트 을 따르세요.

  • 애플리케이션을 재패키징합니다.

  • Amazon S3 버킷에 업로드합니다.

  • Amazon S3 버킷으로 업로드한 수정된 애플리케이션으로 애플리케이션 생성/업데이트 요청을 다시 제출합니다.

  • 동일한 오류 메시지가 계속 표시되면 애플리케이션 종속성을 다시 확인하십시오. 문제가 지속되면 지원 티켓을 생성하세요.

Maven 종속성 업데이트

  1. 프로젝트의 pom.xml를 엽니다.

  2. 프로젝트의 종속성을 찾아보세요. 모양은 다음과 같습니다.

    <project>

    ...

    <dependencies>

        ...

        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-connector-kinesis</artifactId>
        </dependency>

        ...

    </dependencies>

    ...

</project>

  3. 1.15.2 이상의 버전으로 flink-connector-kinesis을 업데이트하세요. 예를 들면 다음과 같습니다.

    <project>

    ...

    <dependencies>

        ...

        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-connector-kinesis</artifactId>
            <version>1.15.2</version>
        </dependency>

        ...

    </dependencies>

    ...

</project>

Gradle 종속성 업데이트

  1. 프로젝트 build.gradle(또는 Kotlin 애플리케이션의 build.gradle.kts)를 엽니다.

  2. 프로젝트의 종속성을 찾아보세요. 모양은 다음과 같습니다.

    ...

dependencies {

    ...

    implementation("org.apache.flink:flink-connector-kinesis")

    ...

}

...

  3. 1.15.2 이상의 버전으로 flink-connector-kinesis을 업데이트하세요. 예를 들면 다음과 같습니다.

    ...

dependencies {

    ...

    implementation("org.apache.flink:flink-connector-kinesis:1.15.2")

    ...

}

...