在使用Join操作后,StreamTableEnvironment的executeSql()方法返回的结果类型为TableResult类型,该类型不支持AppendStreamTableSink。要解决这个问题,需要将TableResult类型转换为DataStream类型,然后使用DataStream的addSink()方法将结果写入AppendStreamTableSink。
示例代码如下:
TableResult tableResult = tableEnv.executeSql("SELECT ... FROM table1 JOIN table2 ON ...");
DataStream