[jira] [Created] (FLINK-15285) Resuming Externalized Checkpoint (file, async, no parallelism change) E2E test fails on Travis

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-15285) Resuming Externalized Checkpoint (file, async, no parallelism change) E2E test fails on Travis

Shang Yuanchun (Jira)
Gary Yao created FLINK-15285:
--------------------------------

             Summary: Resuming Externalized Checkpoint (file, async, no parallelism change) E2E test fails on Travis
                 Key: FLINK-15285
                 URL: https://issues.apache.org/jira/browse/FLINK-15285
             Project: Flink
          Issue Type: Bug
          Components: Runtime / Network, Tests
    Affects Versions: 1.10.0
            Reporter: Gary Yao
             Fix For: 1.10.0


{noformat}
==============================================================================
Running 'Resuming Externalized Checkpoint (file, async, no parallelism change) end-to-end test'
==============================================================================
TEST_DATA_DIR: /home/travis/build/apache/flink/flink-end-to-end-tests/test-scripts/temp-test-directory-08680387784
Flink dist directory: /home/travis/build/apache/flink/build-target
Starting cluster.
Starting standalonesession daemon on host travis-job-9b06ae82-c259-4d51-895c-c3439137e999.
Starting taskexecutor daemon on host travis-job-9b06ae82-c259-4d51-895c-c3439137e999.
Waiting for dispatcher REST endpoint to come up...
Waiting for dispatcher REST endpoint to come up...
Waiting for dispatcher REST endpoint to come up...
Waiting for dispatcher REST endpoint to come up...
Waiting for dispatcher REST endpoint to come up...
Dispatcher REST endpoint is up.
Running externalized checkpoints test, with ORIGINAL_DOP=2 NEW_DOP=2 and STATE_BACKEND_TYPE=file STATE_BACKEND_FILE_ASYNC=true STATE_BACKEND_ROCKSDB_INCREMENTAL=true SIMULATE_FAILURE=false ...
Job (6eb020e02667feb4fd69b2b29be2a9ec) is running.
Waiting for job (6eb020e02667feb4fd69b2b29be2a9ec) to have at least 1 completed checkpoints ...
Waiting for job to process up to 200 records, current progress: 93 records ...
Waiting for job to process up to 200 records, current progress: 146 records ...
Cancelling job 6eb020e02667feb4fd69b2b29be2a9ec.
Cancelled job 6eb020e02667feb4fd69b2b29be2a9ec.
Restoring job with externalized checkpoint at /home/travis/build/apache/flink/flink-end-to-end-tests/test-scripts/temp-test-directory-08680387784/externalized-chckpt-e2e-backend-dir/6eb020e02667feb4fd69b2b29be2a9ec/chk-9 ...
Job (7604e7773d1f7b54b8b1c8655704aa86) is running.
Waiting for job to process up to 200 records, current progress: 195 records ...
Checking for errors...
Found error in log files:
{noformat}
{noformat}
2019-12-16 11:51:30,518 WARN  org.apache.flink.streaming.runtime.tasks.StreamTask           - Error while canceling task.
java.lang.IllegalStateException: Released
        at org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:483)
        at org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.pollNext(SingleInputGate.java:474)
        at org.apache.flink.runtime.taskmanager.InputGateWithMetrics.pollNext(InputGateWithMetrics.java:75)
        at org.apache.flink.streaming.runtime.io.CheckpointedInputGate.pollNext(CheckpointedInputGate.java:125)
        at org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput.emitNext(StreamTaskNetworkInput.java:133)
        at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:69)
        at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:311)
        at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:187)
        at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:488)
        at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:470)
        at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:702)
        at org.apache.flink.runtime.taskmanager.Task.run(Task.java:527)
        at java.lang.Thread.run(Thread.java:748)
{noformat}

https://api.travis-ci.org/v3/job/625630520/log.txt



--
This message was sent by Atlassian Jira
(v8.3.4#803005)