zhuxiaoshang created FLINK-20671:
------------------------------------
Summary: Partition doesn't commit until the end of partition
Key: FLINK-20671
URL:
https://issues.apache.org/jira/browse/FLINK-20671 Project: Flink
Issue Type: Bug
Components: Connectors / FileSystem
Affects Versions: 1.11.1, 1.12.0
Reporter: zhuxiaoshang
According to DOC [
https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connectors/filesystem.html#partition-commit]
the partition can be commited multiple times.
Actually, the partition is commited until the end of partition.For example hourly partition, the 10th partition will be commited at 11 clock, even the `sink.partition-commit.delay` is 0s.
In theory,if delay is 0s the partition should be commited on every checkpoint.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)