Dheeraj Panangat
05/12/2023, 10:47 AMHash collision on user-specified ID "uid_split_monitor_tableRoot". Most likely cause is a non-unique ID. Please check that all IDs specified via `uid(String)` are unique.
at org.apache.flink.streaming.api.graph.StreamGraphHasherV2.generateNodeHash(StreamGraphHasherV2.java:185)
at org.apache.flink.streaming.api.graph.StreamGraphHasherV2.traverseStreamGraphAndGenerateHashes(StreamGraphHasherV2.java:110)
Our Eg:
table1 = tableEnv.sqlQuery("");
table2 = tableEnv.sqlQuery("");
tableRoot = tableEnv.sqlQuery("");
table3= table1.join(tableRoot);
table4= table2.join(tableRoot)
Has anyone faces this ? Anything we are doing wrong here ?
Appreciate any help.
Thanks