Kostas Kloudas created FLINK-10522:
--------------------------------------
Summary: Check if RecoverableWriter supportsResume and accordingly.
Key: FLINK-10522
URL: https://issues.apache.org/jira/browse/FLINK-10522
Project: Flink
Issue Type: Sub-task
Components: filesystem-connector
Affects Versions: 1.6.0
Reporter: Kostas Kloudas
Assignee: Kostas Kloudas
Fix For: 1.7.0
So far we assumed that all `RecoverableWriters` support "resuming", i.e. after
recovering from a failure or from a savepoint they could keep writing to the
previously "in-progress" file. This assumption holds for all current writers,
but in order to be able to accommodate also filesystems that may not support
this operation, we should check upon initialization if the writer supports
resuming and if yes, we go as before, if not, we recover for commit and commit
the previously in-progress file.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
