FLINKは、ログフォルダ内のファイルを生成するが、私は、並列私のFLINKコードで= 1</p> <p>でFLINKローカルモードを使用しています何

Question

を印刷していない、私が使用して着信ソースを印刷しようとしている：

DataStream<String> ds = env.addSource(source); 
ds.print(); 

私のローカルのFlink_dir/logフォルダに、xxx.outファイルが作成されていても、ファイルに何も印刷されていないことがわかりました。私が見落とした可能性のある設定はありますか？シンクにデータを正常に追加できたら、ソースデータにテキストが含まれていると確信しています。ありがとう！

Answer 1

ds.printは、ファイルではなくstdoutに書き出します。 $ {flink_dir}/logには、タスクやジョブマネージャのログだけが含まれます。