flink-streaming

0熱

0答えて

私はFlinkを初めて使用していますが、カフカコネクタを使用してウィンドウを使用したときに問題が発生しました。コードは次のようである： val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment ..... // a KeyedStream with name as th

1熱

1答えて

Apache Flink DataStreamのフィード方法

私はApache Flinkを初めて使用しています。私は、DataStreamを作成し、別のシステムからの値でフィードしたいと思います。 "SourceFunctions"を追加する方法を知りました。その関数では、ソースから値を待ってから、これらの値をFlinkに発行してctx.collectを呼び出してから、再度ポーリングします。しかし、値が到着（async）したときに関数を呼び出すデータソー

0熱

1答えて

Apache Flink：InvalidProgramException：テーブルプログラムをコンパイルできません

私は単一のStringフィールドを抽出するAvroオブジェクトのDataStreamを持つ簡単なプログラムを持っています。私はDataStreamをTableに変換し、簡単な投影法でクエリを実行します。 val kinesisConsumer = new FlinkKinesisConsumer(streamName, new UnifiedEventDeserializationSchema,

0熱

1答えて

apache flinkダッシュボードでタスクの名前をカスタマイズする方法は？

私はapache flinkダッシュボードでタスクの名前をカスタマイズしたいと思います。たとえば、ダッシュボードにタスクマップがある場合、その名前はMAPです。特定の名前を追加するにはどのように変更できますか？ありがとうございます。次の例に示すように

0熱

1答えて

FlinkとEvent-Time-Basedストリームで平均値を計算する

Flickinkで、ウィンドウベースの平均（または私が定義した他の関数）を履歴イベントに基づいたストリームで計算したいので、ストリームはEvent-Times （時間ベースを処理していない）：とき ctx.collectWithTimestamp(Datapoint(instrument, bid, ask), time.getMillis) しかし、私は計算（適用機能）を行うときには動作しま

0熱

1答えて

一度に1つのFLINK CEPパターンが存在する

一度に1つのキーに対して単一のパターンを持つことは可能ですか？例えば、私は、1分のウィンドウ内のどこの条件にマッチする5つのイベントが得られたかどうかをチェックしたいと思います.10分のイベントを分で取得すると、2つのアラートを取得する必要がありますが、6つのアラートが表示されます。すべてのイベントが新しいパターンを引き起こすからです。一度に1つのパターンインスタンスをキーとして使用できますか？

0熱

1答えて

プロジェクトにFlinkをインポートできません

サンプルのFlinkプロジェクトをインストールするために使用しました。 https://github.com/tillrohrmann/flink-project.g8 私はFlinkの摂取アプリケーションの作成を開始し、依存関係について心配する必要はありませんが、逆効果です。このテンプレートを使用しようとしています。私がsbtと同期しようとすると、私はFlinkを見つけることができません（この部

0熱

2答えて

flinkでdelta triggerを使用するには？

私はApacheのFLINK（FLINK 1.3）でdeltatriggerを使用したいが、私はこのコードのいくつかの問題があります。 .trigger(DeltaTrigger.of(100, new DeltaFunction[uniqStruct] { override def getDelta(oldFp: uniqStruct, newFp: uniqStruct): Doub

0熱

1答えて

イベント時間ベースのスライディングウィンドウの最新のウィンドウのみを評価する

スライディングウィンドウを使用してEvenTimeでイベントを処理したい。スライド間隔は24時間で、インクリメントは30分です。問題は、以下のコードでは、イベントごとに48回の計算が行われていることです。我々のケースでは、イベントが順番に来ているので、最新のウィンドウだけを評価する必要があります。おかげで、デヤン public static void processEventsa(

2熱

1答えて

フリンクシンクはバイオのみをサポートしますか？

シンクのinvokeメソッドは、非同期ioを作る方法のようですか？例えば返信Future？例えば、Redisのコネクターが同期Redisのコマンドを実行するためにjedis libにを使用しています： https://github.com/apache/bahir-flink/blob/master/flink-connector-redis/src/main/java/org/apache/f