翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

# Python アプリケーションを更新する
<a name="troubleshooting-async-deadlock-update-python-apps"></a>

Python アプリケーションでは、コネクタと他の Java 依存関係を単一の uber-jar の一部としてパッケージ化する方法と、コネクタ jar を直接使用する方法の 2 つの方法でコネクタを使用できます。Async Sink デッドロックの影響を受けるアプリケーションを修正するには:
+ アプリケーションが uber jar を使用している場合は、 [Java アプリケーションを更新する](troubleshooting-async-deadlock-update-java-apps.md) の指示に従ってください。
+ コネクタ JAR をソースから再構築するには、以下の手順に従います。

「**ソースからコネクタを構築:**」

「[Flink のビルド要件と同様の前提条件:](https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/flinkdev/building/#build-flink)」
+ Java 11
+ Maven 3.2.5

## Flink-sql-コネクタ-キネシス
<a name="troubleshooting-async-deadlock-update-python-apps-flink-sql-connector-kinesis"></a>

1. Flink 1.15.4 のソースコードのダウンロード:

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

1. ソースコードの解凍:

   ```
   tar -xvf flink-1.15.4-src.tgz
   ```

1. Kinesis コネクタディレクトリに移動します。

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

1. コネクタ jar をコンパイルしてインストールし、必要な AWS SDK バージョンを指定します。`-DskipTests` ビルド時間を短縮するには、 `-Dfast` テスト実行をスキップして追加のソースコードチェックをスキップします。

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

1. Kinesis コネクタディレクトリに移動します。

   ```
   cd ../flink-sql-connector-kinesis
   ```

1. SQL コネクタ jar をコンパイルしてインストールします。

   ```
   mvn clean install -DskipTests -Dfast
   ```

1. 作成された jar は次の場所で入手できます。

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

## フリンク-sql-コネクタ-aws-kinesis-ストリーム
<a name="troubleshooting-async-deadlock-update-python-apps-flink-sql-connector-aws-kinesis-streams"></a>

1. Flink 1.15.4 のソースコードのダウンロード:

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

1. ソースコードの解凍:

   ```
   tar -xvf flink-1.15.4-src.tgz
   ```

1. Kinesis コネクタディレクトリに移動します。

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

1. コネクタ jar をコンパイルしてインストールし、必要な AWS SDK バージョンを指定します。`-DskipTests` ビルド時間を短縮するには、 `-Dfast` テスト実行をスキップして追加のソースコードチェックをスキップします。

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

1. Kinesis コネクタディレクトリに移動します。

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

1. SQL コネクタ jar をコンパイルしてインストールします。

   ```
   mvn clean install -DskipTests -Dfast
   ```

1. 作成された jar は次の場所で入手できます。

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

## フリンク-sql-コネクタ-aws-kinesis-firehose
<a name="troubleshooting-async-deadlock-update-python-apps-flink-sql-connector-kinesis-firehose"></a>

1. Flink 1.15.4 のソースコードのダウンロード:

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

1. ソースコードの解凍:

   ```
   tar -xvf flink-1.15.4-src.tgz
   ```

1. コネクタディレクトリに移動

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

1. コネクタ jar をコンパイルしてインストールし、必要な AWS SDK バージョンを指定します。`-DskipTests` ビルド時間を短縮するには、 `-Dfast` テスト実行をスキップして追加のソースコードチェックをスキップします。

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

1. SQL コネクタディレクトリに移動します。

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

1. SQL コネクタ jar をコンパイルしてインストールします。

   ```
   mvn clean install -DskipTests -Dfast
   ```

1. 作成された jar は次の場所で入手できます。

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

## flink-sql-connector-dynamodb
<a name="troubleshooting-async-deadlock-update-python-apps-flink-sql-connector-dynamodb"></a>

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
   ```

1. ソースコードの解凍:

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

1. コネクタディレクトリに移動

   ```
   cd flink-connector-aws-3.0.0
   ```

1. コネクタ jar をコンパイルしてインストールし、必要な AWS SDK バージョンを指定します。`-DskipTests` ビルド時間を短縮するには、 `-Dfast` テスト実行をスキップして追加のソースコードチェックをスキップします。

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

1. 作成された jar は次の場所で入手できます。

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