Perbarui aplikasi Python - Layanan Terkelola untuk Apache Flink

Amazon Managed Service untuk Apache Flink (Amazon MSF) sebelumnya dikenal sebagai Amazon Kinesis Data Analytics untuk Apache Flink.

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Perbarui aplikasi Python

Aplikasi Python dapat menggunakan konektor dalam 2 cara berbeda: konektor pengemasan dan dependensi Java lainnya sebagai bagian dari tabung uber tunggal, atau menggunakan jar konektor secara langsung. Untuk memperbaiki aplikasi yang terpengaruh oleh kebuntuan Async Sink:

  • Jika aplikasi menggunakan toples uber, ikuti instruksi untukPerbarui aplikasi Java .

  • Untuk membangun kembali stoples konektor dari sumber, gunakan langkah-langkah berikut:

Membangun konektor dari sumber:

Prasyarat, mirip dengan persyaratan build Flink:

  • Java 11

  • Maven 3.2.5

  1. Unduh kode sumber untuk Flink 1.15.4:

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

  2. Buka kompres kode sumber:

    tar -xvf flink-1.15.4-src.tgz

  3. Arahkan ke direktori konektor kinesis

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

  4. Kompilasi dan instal jar konektor, tentukan versi AWS SDK yang diperlukan. Untuk mempercepat penggunaan build -DskipTests untuk melewati eksekusi pengujian dan -Dfast melewati pemeriksaan kode sumber tambahan:

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

  5. Arahkan ke direktori konektor kinesis

    cd ../flink-sql-connector-kinesis

  6. Kompilasi dan pasang jar konektor sql:

    mvn clean install -DskipTests -Dfast

  7. Jar yang dihasilkan akan tersedia di:

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

  1. Unduh kode sumber untuk Flink 1.15.4:

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

  2. Buka kompres kode sumber:

    tar -xvf flink-1.15.4-src.tgz

  3. Arahkan ke direktori konektor kinesis

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

  4. Kompilasi dan instal jar konektor, tentukan versi AWS SDK yang diperlukan. Untuk mempercepat penggunaan build -DskipTests untuk melewati eksekusi pengujian dan -Dfast melewati pemeriksaan kode sumber tambahan:

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

  5. Arahkan ke direktori konektor kinesis

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

  6. Kompilasi dan pasang jar konektor sql:

    mvn clean install -DskipTests -Dfast

  7. Jar yang dihasilkan akan tersedia di:

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

  1. Unduh kode sumber untuk Flink 1.15.4:

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

  2. Buka kompres kode sumber:

    tar -xvf flink-1.15.4-src.tgz

  3. Arahkan ke direktori konektor

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

  4. Kompilasi dan instal jar konektor, tentukan versi AWS SDK yang diperlukan. Untuk mempercepat penggunaan build -DskipTests untuk melewati eksekusi pengujian dan -Dfast melewati pemeriksaan kode sumber tambahan:

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

  5. Arahkan ke direktori konektor sql

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

  6. Kompilasi dan pasang jar konektor sql:

    mvn clean install -DskipTests -Dfast

  7. Jar yang dihasilkan akan tersedia di:

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

  1. Unduh kode sumber untuk 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. Buka kompres kode sumber:

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

  3. Arahkan ke direktori konektor

    cd flink-connector-aws-3.0.0

  4. Kompilasi dan instal jar konektor, tentukan versi AWS SDK yang diperlukan. Untuk mempercepat penggunaan build -DskipTests untuk melewati eksekusi pengujian dan -Dfast melewati pemeriksaan kode sumber tambahan:

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

  5. Jar yang dihasilkan akan tersedia di:

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