flink-streaming

0熱

1答えて

FLINK：同じStreamExecutionEnvironmentを使用して複数のカフカクラスタから読み込む方法

FLINKで複数のKAFKAクラスタからデータを読み込みたい。しかし、その結果、kafkaMessageStreamは最初のKafkaからのみ読み込み中です。カフカクラスターの両方から読み取ることができます。私はと2つのストリームを別々に持っています。これはどちらもKafkaです。これは私が望むものではありません。単一のリーダーに複数のソースを添付することは可能ですか？サンプルコード pu

0熱

1答えて

タイプ不一致FLINKグラフコミュニティ

私はコミュニティの検出のための非常に簡単なコードを実行しようとしていますが、それはエラーを返します： import org.apache.flink.graph.library.CommunityDetection import org.apache.flink.graph._ import org.apache.flink.graph.scala.Graph import java.lan

2熱

1答えて

Apache Flink：遅れたDatastreamを作成する

私はScalaを使ってApache Flinkを使い始めました。誰かが私が持っている現在のデータストリームから遅れたストリーム（kイベントまたはk単位の時間差がある）を作成する方法を教えてもらえますか？基本的には、データストリームに自動回帰モデル（ストリームのリニア回帰とタイムラグのあるバージョン）を実装したいと考えています。したがって、以下の擬似コードに類似した方法が必要です。 val ds

2熱

1答えて

Flinkクエリ可能状態が動作しない

私はIDEからflinkを実行しています。照会可能で、データを格納することで、作業何とか、私はそれを照会するとき、それは例外 Exeception Failure(akka.actor.ActorNotFound: Actor not found for: ActorSelection[Anchor(akka.tcp://[email protected]:6123/), Path(/user/

2熱

1答えて

Flink RabbitMQ相関ID

FlinkでRabbiMQで高可用性を使用する方法、相関IDと有効化チェックポイントを使用する方法を理解しようとしていますが、機能しません。私のプロデューサーコード： connection = factory.newConnection(); Channel channel = connection.createChannel(); String corrId = java.util.UUI

1熱

1答えて

Flinkのグローバル変数

データストリームの要素を格納するためにサイズ2のFIFOキューを使用します。いずれにしても、ストリームに入っている前の要素が必要ですが、現在の要素は必要ありません。これを行うには、ストリームコードの外にキューを作成し、現在の要素をキューに入れています。私のキューに2つの要素がある場合は、その要素をデキューして最初の要素を使用します。私が直面している問題は、ストリームコードの外に宣言されているため

2熱

1答えて

Flinkストリーミング：各タイムウィンドウの要素の上位n個を取得

データストリームのタプル（浮動小数点数、ストリング）をソートし、各タイムウィンドウ（固定）の3つの最大値を選択します。データストリームのウィンドウ処理は、自然な順序で時間とソートを処理することによって行われます。 FLINK 1.0.1を使用して、以下の私に期待されるタスク名を与えるものではありません、私のtryアウトのいずれか1 sortMetricStreamで val topTasks

1熱

1答えて

Flink 1.xのEventTimeSourceFunction（Flink 0.10.x）の置き換えは何ですか？

Flink 0.10.1に基づくFlicker 1.1.1へのSlidingArrivalCount.scalaの例を移行しようとしています。この例で使用されているTaxiRideSourceデータストリームソースは、org.apache.flink.streaming.api.functions.source.EventTimeSourceFunctionインターフェイスを実装していますが、こ

2熱

1答えて

Scala WindowFunctionがコンパイルされない

私はApache Flinkを使用してプロトタイプアプリケーションを作成しています。このプロセスでは、特定のユースケースに対してorg.apache.flink.streaming.api.functions.windowing.WindowFunctionを使用することを選択しました。しかし、apply（）関数の本体を書いている間、私はこのエラーに直面しています（以下のコードは、私が書いているア

3熱

1答えて

チェックポイントからApache Flinkジョブを復元する

Apache Flink + RabbitMQスタックを使用しています。手動でセーブポイントをトリガーしてジョブをリストアする機会については知っていますが、問題は、チェックポイントが成功した後にFlinkがメッセージを認識し、セーブポイントとリストア状態を作成したい場合、最後に成功したセーブポイントと最後に成功したチェックポイント。チェックポイントからジョブを復元する方法はありますか？これは、再生