Springクラウドデータフローを使用してストリームデータをシンクファイルに書き込むことができません

Question

シェル（UIではなく）を使用しているSpringクラウドデータフローを使用してデータフローパイプラインを作成しようとしています。ソースがtwitterstreamで、ファイルとしてシンクします。ここで私は、ファイル・シンクを構成するためにやったことです：

dataflow:>stream create demo --definition "twitterstream --credentials | file --dir=/opt/datastream --mode=APPEND --filename=tweets.txt"

私はカフカのトピックからデータを消費しますが、シンクの位置の上に書き込むことができないことができ、ファイルであっても作成されません。ストリームをデプロイする際のエラーログはありません。最終的に私はそれをローカルファイルシステムからHDFSに変更します。不足しているものはありますか？

PS：私は内部を/ tmp/XD /出力をデフォルトのファイルを作成することになっている（定義なし）デフォルトのファイル・シンクを、試してみました、のいずれか発生しませんでした。

Answer 1

最新の1.0.0.RELEASE（GA）リリースでは、次のストリーム定義が機能します。

dataflow:>stream create demo --definition "twitterstream | file --directory=/someFolder --mode=APPEND --name=demo.txt"

指摘する物事のカップル：

1）twitterstreamソースはOOTBプロパティとして--credentialsをサポートしていません。 hereを参照してください。

2）OOTBプロパティとして--filenameをサポートしていないfileシンク。代わりに--nameを使用する必要があります。 hereを参照してください。