View a markdown version of this page

Python 애플리케이션 업데이트 - Managed Service for Apache Flink

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

Python 애플리케이션 업데이트

Python 애플리케이션은 커넥터를 두 가지 방식으로 사용할 수 있습니다. 커넥터 및 기타 Java 종속성을 단일 uber-jar의 일부로 패키징하거나 커넥터 jar를 직접 사용하는 것입니다. Async Sink 교착 상태의 영향을 받는 애플리케이션을 수정하려면,

  • 애플리케이션이 uber jar를 사용하는 경우 Java 애플리케이션 업데이트의 지침을 따르세요.

  • 소스에서 커넥터 jar를 다시 빌드하려면 다음 단계를 사용하십시오.

소스에서 커넥터 만들기:

Flink 빌드 요건과 유사한 사전 요건:

  • Java 11

  • Maven 3.2.5

  1. Flink 1.15.4의 소스 코드 다운로드:

    wget https://archive.apache.org/dist/flink/flink-1.15.4/flink-1.15.4-src.tgz

  2. 소스 코드 압축 해제:

    tar -xvf flink-1.15.4-src.tgz

  3. kinesis 커넥터 디렉터리로 이동합니다.

    cd flink-1.15.4/flink-connectors/flink-connector-kinesis/

  4. 필요한 AWS SDK 버전을 지정하여 커넥터 jar을 컴파일하고 설치합니다. 빌드 속도를 높이려면 테스트 실행을 건너뛰는 -DskipTests 방법과 추가 소스 코드 검사를 건너뛰는 -Dfast 방법을 사용하십시오.

    mvn clean install -DskipTests -Dfast -Daws.sdkv2.version=2.20.144

  5. kinesis 커넥터 디렉터리로 이동합니다.

    cd ../flink-sql-connector-kinesis

  6. sql 커넥터 jar 컴파일 및 설치:

    mvn clean install -DskipTests -Dfast

  7. 결과 jar는 다음에서 확인할 수 있습니다.

    target/flink-sql-connector-kinesis-1.15.4.jar

  1. Flink 1.15.4의 소스 코드 다운로드:

    wget https://archive.apache.org/dist/flink/flink-1.15.4/flink-1.15.4-src.tgz

  2. 소스 코드 압축 해제:

    tar -xvf flink-1.15.4-src.tgz

  3. kinesis 커넥터 디렉터리로 이동합니다.

    cd flink-1.15.4/flink-connectors/flink-connector-aws-kinesis-streams/

  4. 필요한 AWS SDK 버전을 지정하여 커넥터 jar을 컴파일하고 설치합니다. 빌드 속도를 높이려면 테스트 실행을 건너뛰는 -DskipTests 방법과 추가 소스 코드 검사를 건너뛰는 -Dfast 방법을 사용하십시오.

    mvn clean install -DskipTests -Dfast -Daws.sdk.version=2.20.144

  5. kinesis 커넥터 디렉터리로 이동합니다.

    cd ../flink-sql-connector-aws-kinesis-streams

  6. sql 커넥터 jar 컴파일 및 설치:

    mvn clean install -DskipTests -Dfast

  7. 결과 jar는 다음에서 확인할 수 있습니다.

    target/flink-sql-connector-aws-kinesis-streams-1.15.4.jar

  1. Flink 1.15.4의 소스 코드 다운로드:

    wget https://archive.apache.org/dist/flink/flink-1.15.4/flink-1.15.4-src.tgz

  2. 소스 코드 압축 해제:

    tar -xvf flink-1.15.4-src.tgz

  3. 커넥터 디렉토리로 이동합니다.

    cd flink-1.15.4/flink-connectors/flink-connector-aws-kinesis-firehose/

  4. 필요한 AWS SDK 버전을 지정하여 커넥터 jar을 컴파일하고 설치합니다. 빌드 속도를 높이려면 테스트 실행을 건너뛰는 -DskipTests 방법과 추가 소스 코드 검사를 건너뛰는 -Dfast 방법을 사용하십시오.

    mvn clean install -DskipTests -Dfast -Daws.sdk.version=2.20.144

  5. sql 커넥터 디렉터리로 이동합니다.

    cd ../flink-sql-connector-aws-kinesis-firehose

  6. sql 커넥터 jar 컴파일 및 설치:

    mvn clean install -DskipTests -Dfast

  7. 결과 jar는 다음에서 확인할 수 있습니다.

    target/flink-sql-connector-aws-kinesis-firehose-1.15.4.jar

  1. Flink 1.15.4의 소스 코드 다운로드:

    wget https://archive.apache.org/dist/flink/flink-connector-aws-3.0.0/flink-connector-aws-3.0.0-src.tgz

  2. 소스 코드 압축 해제:

    tar -xvf flink-connector-aws-3.0.0-src.tgz

  3. 커넥터 디렉토리로 이동합니다.

    cd flink-connector-aws-3.0.0

  4. 필요한 AWS SDK 버전을 지정하여 커넥터 jar을 컴파일하고 설치합니다. 빌드 속도를 높이려면 테스트 실행을 건너뛰는 -DskipTests 방법과 추가 소스 코드 검사를 건너뛰는 -Dfast 방법을 사용하십시오.

    mvn clean install -DskipTests -Dfast -Dflink.version=1.15.4 -Daws.sdk.version=2.20.144

  5. 결과 jar는 다음에서 확인할 수 있습니다.

    flink-sql-connector-dynamodb/target/flink-sql-connector-dynamodb-3.0.0.jar