[
https://issues.apache.org/jira/browse/FLINK-24096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17410406#comment-17410406
]
Yun Gao commented on FLINK-24096:
---------------------------------
Fix on master via
c0c33d3f8dd39c312111de68d3c4230d89edbb10..888b3653bd8c7b0c9088d143227eacb82f480a4d
Fix on release-1.14 via
f6460e9341a155459541dbaee331ffd751dd6f7e..9c8d21fbfdc71f7daab99a4a4c5b19f9b353757a
> Table planner tests fails due to NPE in
> FailingCollectionSource.notifyCheckpointComplete
> ----------------------------------------------------------------------------------------
>
> Key: FLINK-24096
> URL: https://issues.apache.org/jira/browse/FLINK-24096
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Checkpointing
> Affects Versions: 1.14.0, 1.15.0
> Reporter: Xintong Song
> Assignee: Yun Gao
> Priority: Blocker
> Labels: pull-request-available, test-stability
> Fix For: 1.14.0, 1.15.0
>
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=23250&view=logs&j=a9db68b9-a7e0-54b6-0f98-010e0aff39e2&t=cdd32e0b-6047-565b-c58f-14054472f1be&l=9417
> JoinITCase.testNullFullOuterJoin
> {code}
> Sep 01 01:57:41 Caused by: java.lang.NullPointerException
> Sep 01 01:57:41 at
> org.apache.flink.table.planner.runtime.utils.FailingCollectionSource.notifyCheckpointComplete(FailingCollectionSource.java:242)
> Sep 01 01:57:41 at
> org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.notifyCheckpointComplete(AbstractUdfStreamOperator.java:126)
> Sep 01 01:57:41 at
> org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.notifyCheckpointComplete(StreamOperatorWrapper.java:99)
> Sep 01 01:57:41 at
> org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.notifyCheckpointComplete(RegularOperatorChain.java:152)
> Sep 01 01:57:41 at
> org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl.notifyCheckpointComplete(SubtaskCheckpointCoordinatorImpl.java:348)
> Sep 01 01:57:41 at
> org.apache.flink.streaming.runtime.tasks.StreamTask.notifyCheckpointComplete(StreamTask.java:1397)
> Sep 01 01:57:41 at
> org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$notifyCheckpointAbortAsync$16(StreamTask.java:1355)
> Sep 01 01:57:41 at
> org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$notifyCheckpointOperation$17(StreamTask.java:1377)
> Sep 01 01:57:41 at
> org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:93)
> Sep 01 01:57:41 at
> org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90)
> Sep 01 01:57:41 at
> org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.drain(MailboxProcessor.java:177)
> Sep 01 01:57:41 at
> org.apache.flink.streaming.runtime.tasks.StreamTask.afterInvoke(StreamTask.java:834)
> Sep 01 01:57:41 at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:747)
> Sep 01 01:57:41 at
> org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958)
> Sep 01 01:57:41 at
> org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937)
> Sep 01 01:57:41 at
> org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766)
> Sep 01 01:57:41 at
> org.apache.flink.runtime.taskmanager.Task.run(Task.java:575)
> Sep 01 01:57:41 at java.lang.Thread.run(Thread.java:748)
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
