問題タブ [spring-cloud-dataflow]

spring-cloud-dataflow でソースとしてHadoopを提供する方法はありますか?

spring-cloud-dataflow のドキュメントを読んだところ、hadoopをシンクとしてのみサポートしていることがわかりました。しかし、 hdfs からデータを読み取り、データの集計と変換を行い、最後にデータを hdfs に保存する map-reduce ジョブを実行する必要があります。そのため、上記の状況を処理する方法を親切に提供してください。

CloudFoundry で実行されている Spring Cloud Dataflow の最も基本的な例を取得しようとしています。ここの手順に従いました: http://docs.spring.io/spring-cloud-dataflow-admin-cloudfoundry/docs/current-SNAPSHOT/reference/htmlsingle/#getting-startedで管理アプリを利用できるようにします組織/スペース。次に、 http://cloud.spring.io/spring-cloud-dataflow/から最も基本的な例、つまり「ticktock」ストリームを作成しようとしました。

ticktock-time と ticktock-log の両方のアプリがスペースに作成され、必要なサービス「redis」がこれらのアプリにバインドされ、起動しようとしていることがわかります。残念ながら、「redis」サービスへのアクセスに問題があるため、完全には起動しません。ログには次のものがあります。

コンテキストの初期化中に例外が発生しました - 更新試行のキャンセル: org.springframework.context.ApplicationContextException: Bean 'outputBindingLifecycle' の開始に失敗しました。ネストされた例外は org.springframework.context.ApplicationContextException: Bean 'inputBindingLifecycle' の開始に失敗しました。ネストされた例外は org.springframework.data.redis.RedisConnectionFailureException: Cannot get Jedis connection; です。ネストされた例外は redis.clients.jedis.exceptions.JedisConnectionException です: プールからリソースを取得できませんでした

それは最終的にによって引き起こされます

原因: redis.clients.jedis.exceptions.JedisConnectionException: java.net.ConnectException: 接続が拒否されました

間にいくつかの構成手順がありませんか?

アレクサンダー

現在、Spring Cloud Data Flow には、Local、YARN、Cloud Foundry、Mesos、および Kubernetes のサーバーがあることがわかります。Swarm サポートの予定はありますか?

コンストラクター注入を使用して Bean を作成し、Spring Cloud アノテーションでアノテーションを付けようとしています@EnableBinding。

Spring Boot1.3.3と Spring Cloudを使用していBrixton.M5ます。

アプリの起動中に次の例外が発生します。

次の場合、この例外は消えます。

1. @EnableBinding削除されます
2. @Autowired引数なしのコンストラクターが導入されました (明らかに、引数を含むコンストラクターの注釈にもかかわらず、それが使用されます)
3. 代わりにフィールド注入が使用されます

以下のコード スニペット:

CGLIB プロキシと何らかの関係があるのでしょうが、Spring 4 からコンストラクター インジェクションをサポートする必要があります。

誰が何が悪いのか考えていますか？それは私のせいですか、それとも Spring Cloud Data Flow のバグですか?

https://github.com/spring-cloud/spring-cloud-dataflow/tree/master/spring-cloud-dataflow-app-launcherを使用します。

OS: Ubuntu 15.10

それから

しかし、エラーを満たす：

私のやり方が間違っているのでしょうか？

ドキュメントで確認できることから、Spring Cloud Dataflow が機能するには常に Redis インスタンスが必要です。

RabbitMQ などの別のメッセージ ブローカーを使用することは可能ですか?

起動時に別のメッセージ ブローカーを指定するにはどうすればよいでしょうか?

ここの指示に従いましたhttp://docs.spring.io/spring-cloud-dataflow/docs/1.0.0.M1/reference/html/getting-started-deploying-spring-cloud-dataflow.html (ダウンしているようです)現在）、管理アプリをプッシュしようとするとインストールに失敗します。

私は spring-cloud-dataflow を調査しており、twitterstream サンプルを正常にウォークスルーでき、field-value-counters にはいくつかの有用な値が含まれていました。

しかし、次のような他の単純な例を作成できません。

stream create test --definition 'http --server.port=9999 | counter --name=httpcounter --store=redis' --deploy

また

stream create http-log --definition 'http --server.port=1234 | log' --deploy

stream create http-tap-counter --definition ':http-log.http > counter --name=http-tap-counter' --deploy

どちらの場合も、ストリームが作成および展開されてstream list表示されますが、シェルで「カウンター リスト」を実行してもカウンターは表示されません。

ログで、http ソースが何らかの入力を受け取っていることも確認します。

簡単なカウンターを作成するためにここで欠落している理由はありますか?