spring-xd

0熱

1答えて

特定のユースケースに対してSpring Data Flowストリームを設定する際のアドバイスを探しています。私のユースケース：私は2 RDBMSを持っていると私はそれぞれに対して実行クエリの結果を比較する必要があります。クエリはほぼ同時に実行する必要があります。比較の結果に基づいて、私が作成したカスタム電子メールシンクアプリを通じて電子メールを送信できるはずです。私は（塗料用申し訳ありません

0熱

1答えて

spring-xdで解析モジュールを使用したストリーム作成が失敗しました

私はspring-xdフレームワークに取り組んでいます。私はSpring-XDガイドの[分析]タブに従っており、ライブストリーミングデータの予測モデルを展開したいと考えています。私はRでnaive-Bayesを使用して虹彩分類モデルを構築し、そのデスクトップにUbuntu-14.0.4 Ltsのpmmlファイルを保存しました。これは私のストリーム定義です stream create test -

1熱

1答えて

springxdストリームでHDFS-Datasetを使用してavroデータを保存してケルベロスチケットを更新できない

私はspringxdストリーム====> source-JMSキュー - >変換 - カスタムJavaプロセッサ（XML-AVRO） - > Sink-HDFS -Dataset。ストリームは正常に動作しますが、24時間後に連続接続されているため、Kerberos認証チケットを更新できず、HDFSへの書き込みが停止します。このストリームがデプロイされているコンテナを再起動していますが、問題が発生

0熱

1答えて

spring-integration-kafka 1.3.1.RELEASE：org.apache.kafka.common.serializationを使用するための回避策はありますか？

私はこの問題で遊ぶためにSpring XDを使用しています：カフカのトピック（0.9バージョン）から受け取ったメッセージを逆シリアル化するための回避策はありますか？私はカフカのソースをasuming（私のストリームを実行すると、私は春・統合・カフカ1.3.1を維持するために、依存関係を変更しようと、この <dependency> <groupId>org.springframewo

0熱

1答えて

バッチジョブからSpring-xdシェルコマンドを送信するにはどうすればいいですか

私はJobAを実行してJobBを再起動しようとしています。私はjobOperater.restart（）を使用しようとしていて、失敗しました。私は "job execution restart - id 0"によってxd-shellからjobBを再起動することができました。私はJobAからそのコマンドを呼び出すことで同様のことをすることはできますか？あなたの提案をありがとう。

0熱

1答えて

メッセージバスとしてRabbitMQを使用したSpring XDでメッセージが消耗しました

1つのサーバーと1つのRabbitMQをメッセージバスとして使用する2つのコンテナを持つSpring XD 1.2.0がインストールされています。もの： 2017-02-05T22:51:03+0100 1.2.0.RELEASE WARN xdbus.s5745722984ae22d0317b6377-8ef5f339-f901-4c95-ae11-111be263ce82.1-1 retry.

0熱

1答えて

スプリングステップスケジューリング

スプリングバッチジョブでステップをスケジューリングしようとしています。私は使ってみました。しかし、私がSpringXdにそのジョブをデプロイしようとしているとき、失敗しています。以下は、私はこのエラーを取得しています <batch:job id="addB" restartable="false"> <batch:step id="AddB" > <tasklet ref="addB

0熱

1答えて

Spring XDジョブのデプロイメントエラー

XDシェル/ XD-コンテナーが予期せず終了し、ジョブがデプロイされた状態のままであると、このエラーが複数回発生しています。 xd containerとxd-shellを再起動すると、同じ名前のジョブを再作成することができなくなります。しかし、ジョブリストにも表示されません。この問題を回避するには、新しい名前でジョブを作成しています。この問題の解決策はありますか？私はこれがWindows上のXD

0熱

1答えて

springxd JMSシンクアクノリッジ特権

springxd JMSソースの確認応答プロパティをどのように使用/カスタマイズできるかに関するドキュメントが見つかりません。ドキュメントは言う - オプションザ・JMSソースとJMSあり、以下のオプション：了承セッション確認応答モード（文字列、デフォルト：自動）事前におかげで...

0熱

1答えて

春XD - プレースホルダ 'xd.module.sequence' を解決できませんでした

私は次の記事に同様の問題を扱っています：JIRAチケットのを見て、また Spring -XD Stream deployment failure issue in spring xd cluster when deploying my module オープンしました：https://jira.spring.io/browse/XD-3727 は、私は、カスタムトランスモジュールとの基本的な流れを作