http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/TableException-tp28215.html
Hi,
I am attempting the following:
String sql = "INSERT INTO table3 "
+ "SELECT col1, col2,
window_start_time ,
window_end_time , MAX(col3), MAX(col4), MAX(col5) FROM "
+ "(SELECT col1,col2, "
+ "TUMBLE_START(ts, INTERVAL '1' MINUTE) as window_start_time, "
+ "TUMBLE_END(ts, INTERVAL '1' MINUTE) as window_end_time, "
....
+ "FROM table1"
+ "WHERE...."
+ "GROUP BY TUMBLE(ts, INTERVAL '1' MINUTE), col1, col2"
+ "UNION "
+ "SELECT col1, col2, "
+ "TUMBLE_START(ts, INTERVAL '1' MINUTE) as window_start_time, "
+ "TUMBLE_END(ts, INTERVAL '1' MINUTE) as window_end_time, "
....
+ "FROM table2"
+ "WHERE ..... "
+ "GROUP BY TUMBLE(ts, INTERVAL '1' MINUTE),
col1, col2 ) "
+ "
window_start_time, window_end_time, col1, col2";
tableEnv.sqlUpdate(
sql );
I am using JDBCAppendTableSink.
Exception:
org.apache.flink.table.api.TableException: AppendStreamTableSink requires that Table has only insert changes.
What in the query should I fix?