Skip to content Skip to sidebar Skip to footer
Showing posts with the label Flink Sql

"rowtime Attributes Must Not Be In The Input Rows Of A Regular Join" Despite Using Interval Join, But Only With Event Timestamp

Example code: from pyflink.table import EnvironmentSettings, StreamTableEnvironment env_settings … Read more "rowtime Attributes Must Not Be In The Input Rows Of A Regular Join" Despite Using Interval Join, But Only With Event Timestamp