問題タブ [flink-streaming]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
apache-flink - Scala Shell で StreamExecutionEnvironment をインスタンス化する
scala シェルを起動します。タイプ org.apache.flink.api.scala.ExecutionEnvironment から ExecutionEnvironment を自動的に作成します
しかし、ストリーミング環境を利用したい。
ExecutionEnvironement は 1 回しかインスタンス化できないため、例外が発生します。
apache-flink - Flink: 1 つのプログラム内のデータセットとデータストリーム API。出来ますか？
最初にデータセット API を使用して静的データを操作し、次に DataStream API を使用してストリーミング ジョブを実行したいと考えています。IDE でコードを書くと、完全に機能します。しかし、ローカルの flink jobmanager (すべての並列処理 1) で実行しようとすると、ストリーミング コードが実行されません!
たとえば、次のコードは機能しません。
このことを機能させるにはどうすればよいですか？
ログ:上記プログラムの実行ログ
実行計画: plan 非周期的なようです。
apache-flink - flink でのストリーミングの実装
私の仕事は、ローカル ドライブから csv ファイルを読み取ることです。一定の間隔で定期的に更新される在庫データが含まれています。次に、読み取ったデータに対していくつかの操作を実行し、定期的に新しい csv ファイルに書き戻します。
私のコードはWikipediaAnalysisコードから適応されています。問題は、実行が 1 回しか行われないことです。最初の実行後、プログラムは終了し、実行中の状態にはなりません。WikipediaAnalysis のように 5 秒間隔 (私が設定) で実行するわけではありません。以下は私のコードです：
提案していただけませんか!!
apache-flink - Flink でのカスタム Windows 充電
Flink のTimeWindow機能を使用していくつかの計算を実行しています。5分の を作成していWindowます。Windowただし、初回のみ1時間作成したいです。次に必要な Windows は 5 分です。
最初の 1 時間はデータが収集され、それに対して私の操作が実行されます。これが完了すると、5 分ごとに同じ操作が実行されます。
これは a で実装できることがわかりましたが、どちらをどのように使用すればよいかわかりtriggerません。trigger
更新:私triggersが得ることができるものから、彼らwindowは最初のトリガーがいつトリガーwindowされるかではなく、ごとにトリガーする時間/カウントを定義するだけです。