[
https://issues.apache.org/jira/browse/FLINK-22993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-22993.
--------------------------------
Resolution: Fixed
Fixed via:
master: 046d9b683e04c77671fe96e0a5fb20b31ed4436e
release-1.13: d8157b960e6d8d9d4903daf49b8d76d91f27dac9
> CompactFileWriter won't emit EndCheckpoint with Long.MAX_VALUE checkpointId
> ---------------------------------------------------------------------------
>
> Key: FLINK-22993
> URL: https://issues.apache.org/jira/browse/FLINK-22993
> Project: Flink
> Issue Type: Bug
> Components: Connectors / FileSystem, Connectors / Hive
> Affects Versions: 1.13.0
> Reporter: luoyuxia
> Assignee: luoyuxia
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.14.0
>
>
> CompactFileWriter won't emit EndCheckpoint with Long.MAX_VALUE checkpointId
> even though the inputs end.
> It will cause data lose. For example, after completing checkpoint 5,
> CompactFileWriter write some file, then the inputs end, but it won't emit
> EndCheckpoint with Long.MAX_VALUE checkpointId, so the downstream operator
> won't do the compaction for the files which means these files are invisible.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
