一语点醒梦中人,谢谢回复@冯嘉伟

因为我是先在sql-client中进行的提交测试,因此忽略了这个问题,谢谢

best,
amenhub



 
发件人: 冯嘉伟
发送时间: 2020-12-24 18:39
收件人: user-zh
主题: Re: Flink-1.11.1流写filesystem分区提交问题
有开启checkpoint吗?
 
Part files can be in one of three states:
 
In-progress : The part file that is currently being written to is
in-progress
Pending : Closed (due to the specified rolling policy) in-progress files
that are waiting to be committed
Finished : On successful checkpoints (STREAMING) or at the end of input
(BATCH) pending files transition to “Finished”
 
https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/connectors/file_sink.html
<https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/connectors/file_sink.html>
  
 
 
 
--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复