spring-cloud-dataflow

0熱

1答えて

私が構成タスクの動作をエラー処理をシミュレートしていに記録されていない、failedTask構成タスクの定義は次のようになります。 <f1: sampleTask --fail=true --custom-argument=someMessage || f2: sampleTask> sampleTaskクラスのランナー： public class SampleTask implements A

0熱

1答えて

Spring Cloud Data FlowでAvroを実装する

データベースからレコードを読み込み、Avroスキーマに変換してシンクアプリケーションが消費するように渡すプロセッサにこれらを渡すSpring Cloud Dataflowストリームを実装しようとしています。私はデータをSQLデータベースから私のソースアプリケーションに流して、問題なく問題なくカフカバインダー経由でデータを渡しました。プロセッサからシンクアプリケーションのシリアライズ/デシリアライ

0熱

1答えて

Spring Cloud DataFlow：リストとしてペイロードを取得する<Map>

Spring Cloud DataFlow 1.3.0.M2をSpring Cloud Stream Starters Celsius.M1で使用する。私は2つのプロセッサを持っています。最初に他の人が消費すると思われるList<Map>を生成します。ここに簡略化したコードがあります。私はSCDFシェルを使用してパイプラインでこれら二つのプロセッサを展開しています // Processor 1

1熱

1答えて

SpringクラウドタスクはSCDF上で動作できませんKubernetes

私はSCDF Kubernetes Serverを使用してSpringクラウドタスクをデプロイします。私はSCDF Kubernetes Server上のSpringクラウドタスクを起動すると、私は2つの奇妙な問題を見つけ、詳細は以下を参照してください。春クラウドタスクを展開し、引数付きのポッドがKubernetes、see Pod pictureに生成されます。問題は、Podの引数がSprin

1熱

1答えて

スプリングクラウドデータフローサーバーのスケール方法

通常、マシンの1つにスプリングクラウドデータフローのJarを実行しますが、期間中にマシン上に多数のフローを作成し、サーバーが過負荷になりシングル私たちは、別のマシンでスプリングクラウドデータフローサーバーのjarファイルを実行し、そのようなエラーを回避し、完全なシステムをより弾力性と堅牢性にするためにフローを移行します。また、完全なシステムをPCF /クラウドファウンドリに導入すると自動的に拡張が

0熱

1答えて

Springクラウドストリーム：SinkがRabbitMQ接続を失う

ログシンクストリームのアプリケーション依存関係のある私のカスタムSpringクラウドストリームシンクが、RabbitMQ停止中にRabbitMQ接続を失い、5回接続しようとしてから消費者を停止することがわかりました。私は手動でRabbitMQがアップしたら、それが正常に接続するために、アプリケーションを手動で再起動する必要があります。私がrabbitMQバインディングhereのデフォルトのプロパテ

0熱

2答えて

Spring Cloudのデータフローをリモートデバッグする方法

いくつかのバッチジョブを実行し、Spring Cloud Dataflowを使用することを検討するためにSpring XDを使用しています。このために、私はタスクの実行をリモートデバッグしたいと思っていました。私はそれを動作させることができませんでした。私はSCDFサーバが起動する前に、以下の環境変数をエクスポートしようとした： spring.cloud.deployer.local.javaO

2熱

1答えて

Spring Cloud StreamアプリケーションWebインターフェイス

spring-cloud-streamアプリケーションへのWebインターフェイスを作成することは可能ですか？多くのソース（ファイル、http、ftp）は、アプリケーションにデータを共通の形式で変換し、開発を軽減するためにデータを送信します。ユーザーがデータ変換を簡単に設定できるWebインターフェイスを作成しようと考えていました。

0熱

1答えて

AmbariのSCDFプラグインの開始中にエラーが発生しました

Ambariを使用してSCDFをインストールしましたが、Spring Cloud Dataflowサーバーを正常に開始できないようです。ここで 03:07:30.592 [main] ERROR org.springframework.boot.SpringApplication - Application startup failed java.lang.IllegalStateExcepti