eamTask.finishTask(SourceStreamTask.java:150)
> taskmanager_1 | at
> org.apache.flink.streaming.runtime.tasks.StreamTask.performCheckpoint(StreamTask.java:808)
> taskmanager_1 | at
> org.apache.flink.streaming.runtime.tasks.StreamTask.triggerCheckpoint(StreamTask.java:683)
> taskmanager_1 | at
> org.apache.flink.streaming.runtime.tasks.SourceStreamTask.triggerCheckpoint(SourceStreamTask.java:160)
> taskmanager_1 | at
> org.apache.flink.runtime.taskmanager.Task$1.run(Task.java:1130)
> taskmanager_1 | at
> java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1626)
> taskmanager_1 | at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> taskmanager_1 | at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> taskmanager_1 | ... 1 more
> {noformat}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
