You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Gary Yao (Jira)" <ji...@apache.org> on 2019/12/17 09:30:00 UTC
[jira] [Assigned] (FLINK-15285) Resuming Externalized Checkpoint
(file, async, no parallelism change) E2E test fails on Travis
[ https://issues.apache.org/jira/browse/FLINK-15285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Gary Yao reassigned FLINK-15285:
--------------------------------
Assignee: Arvid Heise
> 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
> Assignee: Arvid Heise
> Priority: Blocker
> Labels: test-stability
> 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)