Dear:
Why no stable common examples using flink 1.9.3 about streaming sql with
rowtime...
Thanks for helping.
flink1.9.3
root
|-- error_code: STRING
|-- window_start: TIMESTAMP(3) *ROWTIME*
|-- window_end: TIMESTAMP(3) *ROWTIME*
|-- total_num: BIGINT NOT NULL
POJO's type is java.sql.Time
Dear:
Why no stable common examples using flink 1.9.3 about streaming sql with
rowtime...
Thanks for helping.
flink1.9.3
root
|-- error_code: STRING
|-- window_start: TIMESTAMP(3) *ROWTIME*
|-- window_end: TIMESTAMP(3) *ROWTIME*
|-- total_num: BIGINT NOT NULL
POJO's type is TIMESTAMP in
Dear flinker:
Look at the contradiction between event time and natural time from
EventTimeTrigger.java (the window at the time of the break and the end of the
window at the end of the end must not be "real time"):
From the default EventTimeTrigger source code, I found that only onElement
met
Hi,
I want to contribute to Apache Flink.
Would you please give me the contributor permission?
My JIRA ID is shaozhipeng.
Thank you very much.
