Re: Flink 1.4 SQL API Streaming TableException

Bill Lee, Man, you saved me from headbanging :) Thank you! 2018-03-10 0:25 GMT+02:00 杨力 : > To use a field in a table as timestamp, it must be declared as a rowtime > attribute for the table. > > 1) Call env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime). > 2)

Re: Flink 1.4 SQL API Streaming TableException

To use a field in a table as timestamp, it must be declared as a rowtime attribute for the table. 1) Call env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime). 2) Call withRowtimeAttribute on KafkaJsonTableSourceBuilder. Reference: 1.

Flink 1.4 SQL API Streaming TableException

Hi everyone! I decided to try the Time-windowed join functionality of Flink 1.4+. My SQL query is an exact copy of the example in the documentation, and the program reads and writes from Kafka. I used the example from here: