Streaming

Flink パイプラインの出力パーティション数にデフォルト値はありますか？また、設定可能ですか？

出力はデフォルトで 8 個のパーティションに制限されていますが、パーティション数を自動的に計算する場合、この出力はパイプライン設定で最大 16 個に設定できます。

タイムスタンプ: 2024年3月2日

バッチデータセットを Kafka にエクスポートするためにストリームに変換する際のベストプラクティスは何ですか？

ベストプラクティスは、Pipeline Builder でバッチデータセットを入力として使用し、出力をストリームとして設定するストリーミングパイプラインを作成することです。このストリームは、通常の Kafka ストリーミングエクスポートドキュメント に従って Kafka にエクスポートできます。

タイムスタンプ: 2024年3月26日

Java デプロイメント UDF からストリームを再生するにはどうすればよいですか？

パイプライン設定の yaml ファイルでロジックバージョンを更新することで、ストリームを再生できます。

タイムスタンプ: 2024年7月25日