Ted Yu created FLINK-3103:
-----------------------------
Summary: Accessing closed in FsStateBackend#FsCheckpointStateOutputStream#flush() should be synchronized
Key: FLINK-3103
URL:
https://issues.apache.org/jira/browse/FLINK-3103 Project: Flink
Issue Type: Bug
Reporter: Ted Yu
Here is related code:
{code}
public void flush() throws IOException {
if (!closed) {
{code}
Lock "FsCheckpointStateOutputStream.this" should be held.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)