spring-xd

0熱

1答えて

Spring-XDの内部データベースに保存されている内容を減らすことを検討しています。これは、合計500,000エントリを超えるとサーバーの容量がオーバーロードされるためです。 4日ごと、時間ごと、分、または秒したがって、私は以下のように、切り捨てるする必要が予定されている多数のジョブの実行のログからIOすぎ： truncate springxd.batch_step_execution_con

1熱

1答えて

Spring XD - 'ftphdfs'という名前のモジュールが見つかりませんでした。 'source'を入力してください

私はspring-xd-1.3.1.RELEASEランタイムコンテナを実行しています。ftpからhdfs、私は以下のシェルコマンドで例外を得る。 xd:>module info --name source:ftphdfs Command failed org.springframework.xd.rest.client.impl.SpringXDException: Could

3熱

1答えて

Springクラウドデータフロー - マイクロサービス展開

チーム、現在、私はspring-xdに取り組んでおり、データ分析と糸ジョブの実行時コンテナとして使用しています。私の質問は、私は私が春-XDのために使用したのと同じ環境設定を活用することができます） 1ですか？ 2）ドキュメントから、マイクロサービスとして配備できること、ストリーム処理に埋め込みドライバを使用していること、組み込みドライバを使用している場合は、同じインフラストラクチャをspri

5熱

1答えて

Spring Cloudデータフローのドキュメント

Spring Cloud Data Flowのドキュメントがプライムタイムの準備が整った時点の更新。開発者の完全なドキュメントを作成することなく、今後重要な展開を計画するのは本当に難しい作業です。 Spring CloudのデータフローはSpring XDを大量に使い果たしているので、Spring XDのドキュメントを使用して完全なものにすることができます。ありがとうございました

0熱

1答えて

spring xd module jarからテキストファイルを読むには

私はspring xdモジュールをjarファイルとしてパッケージ化しています。私はリソースにテキストファイルを置き、モジュールが起動されたときにそのファイルからデータを読み込みたい。私がこれまで試してみました何は Thread.currentThread().getClass().getClassLoader().getResource("file") Thread.currentTh

0熱

1答えて

春xd。ソース待機シンクの完了

実装が可能ですか（dslクエリーを書き込みますか）？ sourcesink処理が完了していない間に待機する必要があります。 sink - 完了 - >sourceが開始します。例：いくつかの情報をDBへの書き込み First stream（jdbc sink） Second streamは、すべての情報はDB（first stream）に保存されている場合にのみ、何かをしなければなりません。私

2熱

1答えて

カフカソース（Springクラウドデータフロー）

私はSpring XDからSpring Cloud Data Flowに移行しています。私がモジュールリストを探しているとき、私はいくつかのソースがSpring Cloud Flowにリストされていないことに気付きました。その1つはKAFKAソースです。私の質問は、春の雲のデータフローの標準ソースリストからKAFKAソースが削除された理由です。あなたが保つことができる - 私はモジュールのリスト

0熱

2答えて

Spring XDとOracle RDBMS

私はSpring XDの初心者です。特定のディレクトリにあるファイルを解析し、出力をoracleテーブルにプッシュするという要件があります。私はSpring XDでこれを達成できますか？もし私がSpringブート/統合/バッチアプリケーションを直接作成し、Sprig XD上に展開することはできますか？おかげで、 Pratik

0熱

1答えて

ReentrantLockがSpringXDで動作しない理由

私はSpringXDでの作業にReentrantLockを追加しようとしていますが、時にはスレッド間に中断があるようです。例えば、私はこれらのコードを持っている： public class LoadGenerator extends MessageProducerSupport { private final AtomicBoolean running = new AtomicBoolean

2熱

1答えて

春XDコンテナ（1.3.1）との互換性に1.6.1+のHadoop 2.7.2

私は現在私が使用し、春-XDランタイムコンテナに取り組んでいます：スパークを1.6.1+のHadoop 2.7 0.2 +春XD 1.3.1 私の質問：は、これらのバージョンは、スプリング-XDコンテナ（1.3.1）に互換性がありますか？これらはクラスタ環境でスプリングブートとしてデプロイできますか？ spring-xdがsparkで使用するために推奨される特定の部品表記がありますか？ gi