Jingsong Lee created FLINK-20213:
------------------------------------
Summary: Partition commit is delayed when records keep coming
Key: FLINK-20213
URL: https://issues.apache.org/jira/browse/FLINK-20213
Project: Flink
Issue Type: Bug
Components: Connectors / FileSystem
Affects Versions: 1.11.2
Reporter: Jingsong Lee
Assignee: Jingsong Lee
Fix For: 1.12.0
When set partition-commit.delay=0, Users expect partitions to be committed
immediately.
However, if the record of this partition continues to flow in, the bucket for
the partition will be activated, and no inactive bucket will appear.
We need to consider listening to bucket created.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
