問題タブ [flink-sql]

質問する

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

441 問題
Newest
Active
Bountied
318
Unanswered
0 投票する
1 に答える
2366 参照

java - Flink : Rowtime 属性は通常の結合の入力行にあってはなりません

flink SQL API を使用して、複数のテーブルを結合し、時間枠で計算を行いたいと考えています。CSV ファイルからの 3 つのテーブルと、Kafka からの 1 つのテーブルがあります。timestampMsKafka テーブルには、タイム ウィンドウ操作に使用するフィールドがあります。

そのために、次のコードを実行しました。

しかし、実行すると、次のエラーが発生します。

しかし、回避策のヒントの部分がわかりません。テーブルを結合した後、時間属性を作成し、ウィンドウ計算を実行するにはどうすればよいですか。

- - 編集 - -

上記のコードで、次の行を置き換えました。

に ：

しかし、TemporalTableFunction でエラーが発生します。

「セット型」と「式型」の 2 つのフィールドが一致しない場合。 TIMESTAMP(3) rowtime0とTIMESTAMP(0) NOT NULL rowtime0

問題は、という名前のフィールドがないことrowtime0です。内部フィールドのようです。ここで何が起こっているのかよくわかりません


12345678910