这是bug，已经修复了，待发布
On Fri, Aug 14, 2020 at 6:05 PM flink小猪 <18579099...@163.com> wrote:
> 根据我在IDE上面的测试，如果是写入parquet表的话，不添加您发的这段代码，程序依然在运行，并且每间隔checkpoint-interval的时间
> 会打印parquet相关的日志，但是如果是写入orc表的话，则没有任何日志输出，程序依然在运行。另外我通过sql client提交相同的任务，
> parquet表依然没有任何问题，而orc表任务无限重启。并报错。
>
> java.io.FileNotFound
如果是IDE里执行的话，tableEnv.executeSql是马上返回的，然后就退出了，可以用类似这种写法等作业结束：
val tableResult = tEnv.executeSql(insert)
// wait to finish
tableResult.getJobClient.get
.getJobExecutionResult(Thread.currentThread.getContextClassLoader)
.get
> 为什么hive streaming 生成orc文件需要导入flink-orc_2.11jar包，而parquet不需要？
这里其实是缺少
