flink-streaming

2熱

1答えて

ApacheのFLINK：私は私のFLINKアプリケーションを実行するとTupleSerializer

によって引き起こさNullPointerExceptionが、それは私にこのNullPointerExceptionを与える： 2017-08-08 13:21:57,690 INFO com.datastax.driver.core.Cluster - New Cassandra host /127.0.0.1:9042 added 2017-08-08 13:22:02,427 INFO o

0熱

1答えて

kafka-flink：フリンクジョブに依存するカフカプロデューサーのエラー

私はカフカフリンクで概念証明をしていましたが、次のことを発見しました：フリフサイドでの作業負荷のためにカフカプロデューサーのエラーが発生する可能性があります。ここでされている詳細：私は「実体」、「値」、「タイムスタンプ」私が使用のような値で700'000行〜で作られたEDR ??サンプルなどのサンプルファイルがあります。カフカトピックを作成するには、次のコマンドを実行します。 ~/kafka

0熱

1答えて

warnings.print（）（最初の最後のイベント）逆の順序でイベントを出力しますが、ApacheのFLINK CEPで最初のイベントをexceptsで

私はパターンの下に使用してFLINKに> 10あるすべての一時イベントをフィルタしようとしています、 Pattern<MonitoringEvent, ?> warningPattern = Pattern.<MonitoringEvent>begin("first") .subtype(TemperatureEvent.class) .where(new Filt

0熱

2答えて

ジェネリック型パラメータがFLINK-CEPにパターンを検出するためのFLINK-CEP

コードに含まれていないがマックでコマンド+ F9を使用して // Generate temperature warnings for each matched warning pattern DataStream<TemperatureEvent> warnings = tempPatternStream.select( (Map<String, MonitoringEvent> pa

0熱

1答えて

送信データストリームは、/ FLINKプログラムへのリモートソケットは、ホストOS上で実行されている

FLINKのドキュメントで述べたように、私は [email protected]:~$ nc -l 12345 を使用して、ローカルソケットをオープンしてから受信することで、テキストサーバからのテキスト入力を読み取ることができました DataStream<String> text = env.socketTextStream("localhost", 12345); text.print(

0熱

2答えて

スパークストリーミングのような時系列データベースとストリーミング分析エンジンの違い

時系列データベースは、ストリーミング分析システム（スパークストリーミング/フリンク/キネシス分析など）でできることはすべてできますか？ 1つは他を包含するか？私はどちらが良いかを探していない。彼らがサポートしているさまざまなユースケースを理解するだけです。

1熱

1答えて

はNoSuchMethodError Elasticsearch5.xにFLINKコネクタ

私FLINKプログラムを実行している間、私はいくつかの問題に直面していますは、ここでエラーです：私はSOに見て、誰かが同じ問題を抱えていた見つける java.lang.NoSuchMethodError: io.netty.buffer.CompositeByteBuf.addComponents(ZLjava/lang/Iterable;)Lio/netty/buffer/CompositeB

1熱

2答えて

FlinkはJob APIにジョブを投入するJava APIを提供していますか？

私はJobsがFlinkまたはflink.batによってJobManagerに送信できることを知っています。 FlinkがJava APIを提供してJobManagerにジョブを送信するかどうかを知りたいですか？

0熱

1答えて

チェックポイントが無効の場合、オフセットをコミットする特定のZookeeperパスを設定するにはどうすればよいですか？

チェックポイントが有効になっていない場合、Kafkaのコンシューマは定期的にZookeeperにオフセットをコミットします.Zookeeperパスを設定することは可能ですか？

-1熱

1答えて

Flinkの別のジョブでジョブの結果を取得する方法は？

ここに状況があります。私は2つのデータソースを持っています。メッセージキューとMySQLテーブルはそれぞれDataStreamとDataSetと見なすことができます。DataStreamに基づいてジョブを開始して、メッセージキューからデータを取り出して計算を実行したいとします。計算の進行中に、DataSet（MySQLテーブル）に基づくジョブが必要です。そのジョブのOutputFormatは、結