[jira] [Created] (FLINK-7063) test instability in OperatorStateBackendTest.testSnapshotAsyncCancel

["Nico Kruber (JIRA)" <ji...@apache.org>]

Nico Kruber created FLINK-7063:
----------------------------------

             Summary: 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)