[
https://issues.apache.org/jira/browse/FLINK-21213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276306#comment-17276306
]
Arvid Heise commented on FLINK-21213:
-------------------------------------
The sanity check at the end of the e2e fails as the log contains
{noformat}
2021-01-29 23:46:05,857 WARN
org.apache.flink.streaming.runtime.tasks.AsyncCheckpointRunnable [] - As task
is already not running, no longer decline checkpoint 1.
java.lang.Exception: Could not materialize checkpoint 1 for operator Source:
Sequence Source -> Flat Map -> Sink: Unnamed (1/1).
at
org.apache.flink.streaming.runtime.tasks.AsyncCheckpointRunnable.handleExecutionException(AsyncCheckpointRunnable.java:214)
[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
at
org.apache.flink.streaming.runtime.tasks.AsyncCheckpointRunnable.run(AsyncCheckpointRunnable.java:149)
[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
[?:1.8.0_282]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
[?:1.8.0_282]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_282]
Caused by: java.util.concurrent.CancellationException
at java.util.concurrent.FutureTask.report(FutureTask.java:121)
~[?:1.8.0_282]
at java.util.concurrent.FutureTask.get(FutureTask.java:192)
~[?:1.8.0_282]
at
org.apache.flink.runtime.concurrent.FutureUtils.runIfNotDoneAndGet(FutureUtils.java:501)
~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
at
org.apache.flink.streaming.api.operators.OperatorSnapshotFinalizer.<init>(OperatorSnapshotFinalizer.java:57)
~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
at
org.apache.flink.streaming.runtime.tasks.AsyncCheckpointRunnable.run(AsyncCheckpointRunnable.java:112)
~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
... 3 more {noformat}
> Elasticsearch (v5.3.3) sink end-to-end test' failed
> ----------------------------------------------------
>
> Key: FLINK-21213
> URL: https://issues.apache.org/jira/browse/FLINK-21213
> Project: Flink
> Issue Type: Bug
> Components: Connectors / ElasticSearch
> Affects Versions: 1.13.0
> Reporter: Guowei Ma
> Assignee: Arvid Heise
> Priority: Major
> Labels: test-stability
>
> [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=12686&view=logs&j=68a897ab-3047-5660-245a-cce8f83859f6&t=d47e27f5-9721-5d5f-1cf3-62adbf3d115d]
>
> Checking for non-empty .out files...
> No non-empty .out files.
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
