[ https://issues.apache.org/jira/browse/FLINK-7063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16072185#comment-16072185 ]
ASF GitHub Bot commented on FLINK-7063: --------------------------------------- GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/4246 [FLINK-7063] [checkpoint] Call super.cancel(...) before closing strea… Minor fix that has only consequences in exception reporting. With this change, the future is first set to canceled state before a potential IO exception due to the closed stream can be reported first. You can merge this pull request into a Git repository by running: $ git pull https://github.com/StefanRRichter/flink FLINK-7063 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/4246.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #4246 ---- commit 9116129aec71937bf73e8c2ae727c164fdb95297 Author: Stefan Richter <s.rich...@data-artisans.com> Date: 2017-07-03T09:46:16Z [FLINK-7063] [checkpoint] Call super.cancel(...) before closing streams in AsyncStoppableTaskWithCallback ---- > test instability in OperatorStateBackendTest.testSnapshotAsyncCancel > -------------------------------------------------------------------- > > Key: FLINK-7063 > URL: https://issues.apache.org/jira/browse/FLINK-7063 > Project: Flink > Issue Type: Bug > Components: State Backends, Checkpointing, Tests > Affects Versions: 1.3.1, 1.4.0 > Reporter: Nico Kruber > Assignee: Stefan Richter > Priority: Minor > > {{OperatorStateBackendTest.testSnapshotAsyncCancel}} seems to be instable and > sometimes fails: > {code} > testSnapshotAsyncCancel(org.apache.flink.runtime.state.OperatorStateBackendTest) > Time elapsed: 0.036 sec <<< ERROR! > java.util.concurrent.ExecutionException: java.io.IOException: Stream closed. > at java.util.concurrent.FutureTask.report(FutureTask.java:122) > at java.util.concurrent.FutureTask.get(FutureTask.java:206) > at > org.apache.flink.runtime.state.OperatorStateBackendTest.testSnapshotAsyncCancel(OperatorStateBackendTest.java:636) > Caused by: java.io.IOException: Stream closed. > at > org.apache.flink.runtime.util.BlockerCheckpointStreamFactory$1.write(BlockerCheckpointStreamFactory.java:95) > at java.io.DataOutputStream.writeInt(DataOutputStream.java:197) > at > org.apache.flink.core.io.VersionedIOReadableWritable.write(VersionedIOReadableWritable.java:40) > at > org.apache.flink.runtime.state.OperatorBackendSerializationProxy.write(OperatorBackendSerializationProxy.java:65) > at > org.apache.flink.runtime.state.DefaultOperatorStateBackend$1.performOperation(DefaultOperatorStateBackend.java:255) > at > org.apache.flink.runtime.state.DefaultOperatorStateBackend$1.performOperation(DefaultOperatorStateBackend.java:233) > at > org.apache.flink.runtime.io.async.AbstractAsyncIOCallable.call(AbstractAsyncIOCallable.java:72) > at java.util.concurrent.FutureTask.run(FutureTask.java:266) > at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) > at java.util.concurrent.FutureTask.run(FutureTask.java:266) > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) > at java.lang.Thread.run(Thread.java:748) > {code} > logs: > * > https://s3.amazonaws.com/archive.travis-ci.org/jobs/248822546/log.txt?X-Amz-Expires=30&X-Amz-Date=20170703T092940Z&X-Amz-Algorithm=AWS4-HMAC-SHA256&X-Amz-Credential=AKIAJRYRXRSVGNKPKO5A/20170703/us-east-1/s3/aws4_request&X-Amz-SignedHeaders=host&X-Amz-Signature=f468cd238236d7038a1e12086dd4a0e3ba538d93c883790d180e4c63b973a5f2 > * https://transfer.sh/MHawk/17392.5.tar.gz -- This message was sent by Atlassian JIRA (v6.4.14#64029)