flink-streaming

0熱

1答えて

Azure Data Lakeにデータを格納するためにflinkジョブを実行しているとき、私は以下の例外を取得しています。

I am using concurrend append method from the class Core in Azure to store data to Azure Data lake.Below is the code and the exception which I got.I am getting this exception rarely not always.Could an

1熱

1答えて

Flink Java APIを使用してDataStream内の別個に数える方法

FlinkプログラミングでHow to count unique words in a stream?と同じ問題が発生しました。しかし、その答えはScala APIを使用して問題を解決しました。 Flink Java APIサポートfilterWithStateは変換されますか？ Java APIで問題を解決できますか？

0熱

1答えて

setParallelismによって非キーウィンドウの並列性を上げることはできますか？

以下の記事から、非キーストリームの場合の並列性は1であることが分かっているので、setParallelismによって並列性を高めることができますか？ "キーが入力されていないストリームの場合、元のストリームは複数の論理ストリームに分割されず、すべてのウィンドウロジックは1つのタスク、つまり並列性1で実行されます。すぐにすべてのウィンドウ演算子内のストリームのオペレーターに1とは異なる値を設定するs

0熱

1答えて

GlobalWindowsはFlinkの同じGlobalWindowsで同じキーを持つ要素を割り当てますか？以下の文書に基づいて

は、私は、ソースコードをチェックしGlobalWindowsのassignWindows方法は、単にグローバルを返した後 https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/windows.html 「グローバル窓割当は、同じ単一のグローバルウィンドウに同じキーを持つすべての要素を割り当て」ウィンドウとパラメータ要素のため

1熱

1答えて

FlinkでTriggerとCountとProcess Timeの両方を組み合わせることはできますか？

カウントが100に達した後、または5秒ごとに処理が完了した後に、Windowsを終了したいですか？つまり、要素が100に達したときにWindows計算をトリガーしますが、要素が100に達しても時間が5秒経過した場合、以下の2つのトリガーの組み合わせと同様にWindows計算がトリガーされます。 .countWindow（100） .window（TumblingProcessingTimeWind

1熱

2答えて

フリックストリーミングウィンドウトリガー

私はフリンクストリームを持っており、私はいくつかの時間ウィンドウで30秒と言ういくつかの事を較正しています。ここで私の結果は私の前のウィンドウを集約してくれます。ではなく、私が新しいというように最後のウィンドウ結果+を取得し、私は新鮮な結果が欲しい結果10. 次ティリ秒を取得する最初の30秒間言います。私の質問はどのように私は各ウィンドウの新鮮な結果を得るかです。

0熱

1答えて

FLINKのSQLウィンドウのAPI

私はFLINKのSQLウィンドウAPIを使用してみました： https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/table_api.html#group-windows StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvir

1熱

1答えて

flinkがサポートしているかどうかを確認してください。

私はちょうどApacheのflinkを学び始めて、フォールリングの問題を抱え始めています：どうすればflinkジョブを中断してから再開できますか？コマンドラインを使用してジョブを一時停止するにはどうすればよいですか？