1.StreamingFileWriter 测试下来目前发现,sql方式提交任务,不能从checkpoint、savepoint恢复。
   举例:5min产生一个分区,数据按照process_time来落,hm= 2100 的分区, 在 21:04分左右的时候做一次checkpoint 
或savepoint,重启任务的时候,hm =2100分区的数据还存在很多的in-progress文件。 
另外,目前在hdfs目录下没看到pending文件,想了解一下这文件状态是如何转换的,跟之前的bucketsink好像实现不太一样。


2. sql-client不支持 checkpoint savepoint恢复的问题,何时可以支持


3.sql-client 提交任务,不支持StatementSet批量提交,何时可以支持

回复