在执行 SQL 的时候遇见如下情况：
streamTableEnvironment.registerDataStream（）注册的字段有一个是 over_time.rowtime
使用 sql：select tumble(over_time,interval '1' second),over_time from kafka_source
group by over_time,tumble(over_time,interval '1' second)
会报错。ClassCastException
如果 将 group by 后面的子句交换位置， group by
在执行 SQL 的时候遇见如下情况：
streamTableEnvironment.registerDataStream（）注册的字段有一个是 over_time.rowtime
使用 sql：select tumble(over_time,interval '1' second),over_time from kafka_source
group by over_time,tumble(over_time,interval '1' second)
会报错。ClassCastException
如果 将 group by 后面的子句交换位置， group by
您好，flink集群关闭的情况下，运行任务会有报错信息 Could not retrieve the execution result，但是在 flink
集群正常运行的情况下，偶然会报
Could not retrieve the execution result，通过查询了解到，flink 通过 RestClusterClient类
将任务提交至 jobmanager，如果 detached 为 false，会采用 CompletableFuture
的 thenCompose 方法，在获取结果时，会有异常的捕获，如下：
final CompletableFuture
