ストリームパイプラインの依存関係

ストリーム パイプライン （ Flink ）内でデータ クライアント ライブラリ を使用するアプリケーションを実行するに flink-support は、このモジュールをプロジェクトへの依存関係として使用します。 プロジェクトに他のデータ クライアント ライブラリ モジュールを追加しないでください。 他のモジュールを追加すると、依存関係が ( と ) 競合し Akka、アプリケーションは Flink 環境で動作しません。

注 : Akka ライブラリー

Flink は Akka ライブラリに依存しているため、データ クライアント ライブラリとの依存関係の競合が発生します。 これらの競合を解決する ために、データ クライアント ライブラリは内部名前空間 datacenter_akka の Akka 関連のすべての依存関係を再配置しました。 競合を避けるため、 Flink ユーザーは、 FlinkDataClient によって公開されているクラスにのみアクセスするようにしてください。

flink-support このモジュールは、すべての Data ライブラリモジュールおよび一部の共有ライブラリを含むファット JAR としてのみリリースされます。 これは flakka 、データ クライアント ライブラリが使用している Akka バージョンと互換性のない (Akka ライブラリの Flink カスタムビルド ) との競合を避けるために必要です。

メモ : Flink-support

このモジュール flink-support は、 Flink 1.13.5 とのみ互換性があります

flink-support モジュールをプロジェクトに追加するには、次の依存関係を追加します。

注意 : Flink サポートの依存関係

ご注意ください

  • Maven を使用する場合、のバージョン flink-support_2.12 はハードコード化されていませんが、 SDK の pom から提供されています。
  • SBT を使用する場合 flink-support_2.12 は、のバージョンをハードコードする必要があります。

Maven
SBT
<dependencies>
        <dependency>
            <groupId>com.here.platform.data.client</groupId>
            <artifactId>flink-support_2.12</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-clients_2.12</artifactId>
            <version>1.13.5</version>
            <scope>provided</scope>
        </dependency>
        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-table-planner-blink_2.12</artifactId>
            <version>1.13.5</version>
            <scope>provided</scope>
        </dependency>
    </dependencies>
libraryDependencies ++=
        Seq(
          "com.here.platform.data.client" %% "flink-support" % "1.18.163",
          "org.apache.flink" %% "flink-clients" % "1.13.5" % "provided",
          "org.apache.flink" %% "flink-table-planner-blink" % "1.13.5" % "provided"
        )

「」に一致する結果は 件です

    「」に一致する結果はありません