[
https://issues.apache.org/jira/browse/FLINK-9238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-9238.
-----------------------------------
Resolution: Duplicate
Fix Version/s: (was: 1.4.2)
Unfortunately, the current bucketing sink does not work with
eventually-consistent file systems. See FLINK-6306
> There are some questions about BuckeingSink when sinking data to S3.
> ---------------------------------------------------------------------
>
> Key: FLINK-9238
> URL: https://issues.apache.org/jira/browse/FLINK-9238
> Project: Flink
> Issue Type: Bug
> Components: filesystem-connector
> Affects Versions: 1.4.2
> Reporter: liuzhixin
> Priority: Major
>
> When flink is sinking data to S3, there are some IOExceptions from fs. For
> some reasons I throw the exceptions, then the job will restart.
> Sometimes,fs.rename fails and there are pending part files which are from the
> last job and finished part files, but the count of records is not the
> same,slight difference. The "Exactly once" should not be the results.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)