flink-streaming

1熱

1答えて

私はApache Flink v1.2を使用しています。私は数日間のデータを含む巨大なログファイルを避けるために、ローリングファイルアペンダーに切り替える必要がありました。しかし、それは動作していないようです。次のように私はlog4j構成（log4j.propertiesを）適応： log4j.appender.file=org.apache.log4j.rolling.RollingFileAp

1熱

2答えて

ソケットを使用してFlinkでDataStreamを送信する。シリアル化の問題

私は、マシンをホストするVMからのデータのストリームを送信すると、以下のように私は方法writeToSocket()を使用しています：ここで joinedStreamEventDataStream.writeToSocket("192.168.1.10", 6998) ; joinedStreamEventDataStreamはタイプDataStream<Integer,Integer>です。

0熱

1答えて

KafkaコンソールプロデューサからFlink Programにデータを読み込む

testという名前のトピックを作成し、コンソールProducerを使用してコンソールに文字列を書きました。 ./bin/kafka-console-producer.sh --topic test --broker-list localhost:9092 は幸いなことに、私はconsole-consumerを使用して、コンソールで作成されたデータを読み取ることができています。 <project

0熱

1答えて

カスタムデータシンク（Flink CEP）のフィールドを初期化する

Apache Flink Streaming APIに問題があります。私はCEP-Environment全体をカスタムDataSourceでセットアップできました。そして、 "print（）"のようなソースで標準シンクを使用すると、すべてうまく動作します。これが私のシンクは、今のように見えるものです：私は、ISTを達成しようと何 @RequiredArgsConstructor public

2熱

1答えて

FLINKストリーミング：

私のストリームは、キーがusr12345であり、値がストリーム出力に{"_key":"usr12345","_temperature":46.6} .print()あるタイプTuple2<String,String> .toString()出力(usr12345,{"_key":"usr12345","_temperature":46.6}) の記録を生産しているシリアル化された文字列のメッセージ

0熱

1答えて

FlinkおよびKinesisストリームによるストリームウィンドウ処理が機能していません。

Flinkを使用してキネシスストリームを読みます。タイムウィンドウとキーに基づいて特定のイベントを集約します。コードはreduceの後に何もしません。出力csvにputのデータがマップされていません。私は数分待っています（時間窓がわずか2分であっても）。 public static void main(String[] args) throws Exception { StreamEx

0熱

1答えて

Iは、特定の条件警告が生成されるCEPエンジンによって受信されているカフカにストリームを送信している2台の仮想マシンがある場合のシナリオ</p> <p><a href="https://i.stack.imgur.com/PYbQ7.png" rel="nofollow noreferrer"><img src="https://i.stack.imgur.com/PYbQ7.png" alt="enter image description here"></a></p> <p>次た並列

にFLINK CEPに複数のパターンを処理します個々のストリーム上で満足される。現在、CEPは、両方のストリームに同じ条件をチェックする（心拍数> 65と呼吸率> 68）の両方の患者のための並列にアラームを上げ // detecting pattern Pattern<joinEvent, ? > pattern = Pattern.<joinEvent>begin("start")

0熱

2答えて

FLINKコード内カサンドラでテーブルを作成する

私は誰かがどのように教えてくださいすることができ、それがFLINKコードから存在していない場合は鍵空間と表を作成したいcqlshシェルからカサンドラに CREATE KEYSPACE data WITH replication= {'class':'SimpleStrategy', 'replication_factor':1; CREATE TABLE test.patient(id int

0熱

1答えて

KotlinでFlinkを使用できますか？

私はリアルタイムでデータをストリームする必要があるプロジェクトを持っています。私はカフカのトピックにインストリームデータを書きました。今私はこのデータを読んでそれを処理する必要があります。このために、私はFlinkを使うつもりです。私のジレンマは、Java、Scala、Kotlinのいずれかを知らないことです。私はFlinkを使うために彼らの1人を覚えなければならないでしょう。そして、Kotli

0熱

1答えて

どのようFLINK

にウィンドウストリーム内の各単語のカウンタを取得する私は、単語ごとにウィンドウ機能で単語の数を取得したい：私はこのコードを使用する場合： object WindowWordCount { def main(args: Array[String]) { val env = StreamExecutionEnvironment.getExecutionEnvironment