spring-cloud-dataflow

0熱

1答えて

私はスプリングクラウドのデータフローの概念を学び、グローバルなリソースを格納する一般的な方法が何かを考えています。例えば、私がのストリームを持っていて、スプリングクラウドタスクを介して定期的に基礎となるpmmlモデルをリトレインしたいとします。私はモデルを保存して、プロセッサによって（読み取り専用）リソースとして使用でき、毎晩タスクによって更新されるようにしますか？春のクラウドデータフロー

0熱

1答えて

SCDFで2つの異なる出力チャネルにメッセージを送信する方法は？

デフォルトのoutputチャネルを介してストリーム内のプロセッサにメッセージを送信するソースがあります。今私は別のチャネルを介して失敗メッセージを送信したいと思います。私はSourceから拡張するバインド可能なインターフェイスを作成し、@Outputを使用して余分なチャンネルを追加する必要があると考えました。 SCDFが実際にこのチャンネルのカフカのトピックを作成するようにするにはどうすればよい

0熱

1答えて

contentTypeはHDFSシンクから書き込まれたデータにプレフィックスされています

私はHDFSシンクを使用してHDFSに書き込みます。しかし、私がHDFSに書き出すペイロードには？contentType "text/plain"というプレフィックスがありますが、これはペイロードにはありません。これがプレフィックスになっている理由と削除方法を教えてください。 stream create --definition "：ストリーミング--spring.cloud.stream.bi

0熱

1答えて

春クラウドのデータフローアプリ/ストリームのデフォルトのプロパティ

私はapplication.propertiesで指定： spring.cloud.config.uri=http://configserver:8888 をしかし、私は私がサーバーからフェッチ設定ログで確認できるダッシュボードからのストリームを展開するとき：http://localhost:8888 これは、まだデフォルト設定を使用しようとしていることを意味します。また、Kafkaバイン

1熱

2答えて

Spring Cloud Data Flow 1.1.2のUIまたはAPIからジョブの実行を取得するときにNullPointerExceptionが発生する

UIの[ジョブ]タブでジョブ実行リストを取得しようとしたときに問題が発生しました。データフローサーバーは実行中ですか？ '）、またはREST API（500 NullPointerException）を介して送信されます。ログからエラーがコードに起因すると思われる java.lang.NullPointerException: null at org.springframework.cloud

1熱

1答えて

春ストリームルータ-シンクは、私は、次のストリームを展開しようとしたCDF

に起動しません何でも 1.1.1.RELEASEバージョンのrouter-sinkをウサギのバインダーに使用しています。私は間違っていますか？ - EDIT - org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'org.springframework.cloud.stre

1熱

2答えて

CORSエラー私は私のWebアプリケーションから春-クラウドデータフロー・サーバのローカルにGETコールを作ってるんだとき、私はこのエラーを取得し、ばねのクラウド・データフロー・サーバーのローカルへの呼び出し

を作る： XMLHttpRequestはhttp://localhost:9393/をロードできません。プリフライト要求への応答がアクセス制御チェックを通過しない：要求されたリソースに「アクセス制御許可」がない。 Origin 'http://localhost:7002'はアクセスできません。応答にHTTPステータスコード403がありました。これをどのように調整できますか？助けてください、あ

0熱

1答えて

PCFのSpring Cloudデータフローコンテナ内で複数のSpringクラウドタスクジョブを実行

PCFのSpringクラウドデータフローコンテナ内で複数のSpringクラウドタスクジョブを実行しようとしています。これらのジョブは、httpソースからrawファイルを読み込み、次にを解析してmysql dbに書き込みます。これらのジョブは、スプリングバッチではなくプレーンJavaで記述されています。私は、PCF上のscdfコンテナにmysql dbをバインドしました。私は春のクラウドタスクは

0熱

1答えて

カスタムプロセッサアプリケーションでMongoPropertiesをホワイトリストに登録する方法は？

私はMongoDBからデータを読み込むためのカスタムプロセッサーアプリを書いています。このアプリでは、MongoTemplateをMongoDBの操作に使用しています。そのため、SpringBootはプロパティのロードにクラスMongoPropertiesを提供しています。しかし、WebUIダッシュボードでこれらのプロパティを見ることができるようにMongoPropertiesをホワイトリストに

0熱

1答えて

Spring CloudDataflowでX時間後にストリームをアンデプロイする方法は？

Spring CloudDataflowサーバーにストリームをデプロイし、24時間または48時間後に自動的にアンデプロイする必要があります。どこから始めたらいいのかわからないので、誰も私にこれにアプローチする方法を教えてもらえますか？助けが必要です。