??????Re:Re: flink-1.10 checkpoint ?????? NullPointerException

Tue, 03 Nov 2020 19:34:03 -0800 

hi????????????????????????????????????????????????



------------------ ???????? ------------------
??????: "chenkaibit"<chenkai...@163.com&gt;; 
????????: 2020??5??9??(??????) ????12:09
??????: "user-zh"<user-zh@flink.apache.org&gt;; 
????: Re:Re:Re: flink-1.10 checkpoint ?????? NullPointerException



Hi??
????????????????????&nbsp;checkpointMetaData&nbsp;??&nbsp;NULL&nbsp;??&nbsp;https://github.com/apache/flink/blob/release-1.10.0/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java#L1421
????????????&nbsp;kafka??????????&nbsp;wordcount??????????&nbsp;kafka??checkpoint&nbsp;??????????
|&nbsp;Checkpointing&nbsp;Mode&nbsp;|&nbsp;Exactly&nbsp;Once&nbsp;|
|&nbsp;Interval&nbsp;|&nbsp;5s&nbsp;|
|&nbsp;Timeout&nbsp;|&nbsp;10m&nbsp;0s&nbsp;|
|&nbsp;Minimum&nbsp;Pause&nbsp;Between&nbsp;Checkpoints&nbsp;|&nbsp;0ms&nbsp;|
|&nbsp;Maximum&nbsp;Concurrent&nbsp;Checkpoints&nbsp;|&nbsp;1&nbsp;|


????????&nbsp;5377&nbsp;??&nbsp;checkpoint&nbsp;????&nbsp;NPE


????????????????????????????????????????&nbsp;https://github.com/yuchuanchen/flink/commit/e5122d9787be1fee9bce141887e0d70c9b0a4f19????????????&nbsp;NPE&nbsp;????


??&nbsp;2020-04-21&nbsp;10:21:56??&quot;chenkaibit&quot;&nbsp;<chenkai...@163.com&gt;&nbsp;??????
&gt;
&gt;
&gt;
&gt;??????????????????????????????&nbsp;1.10&nbsp;??????????????????????????????????????????????????????????????????????
&gt;
&gt;
&gt;
&gt;
&gt;??&nbsp;2020-04-21&nbsp;01:12:48??&quot;Yun&nbsp;Tang&quot;&nbsp;<myas...@live.com&gt;&nbsp;??????
&gt;&gt;Hi
&gt;&gt;
&gt;&gt;????NPE????????????executeCheckpointing????[1]??????????????????????????????????????????????????null??
&gt;&gt;??????????????????&nbsp;org.apache.flink.streaming.runtime.tasks&nbsp;??DEBUG&nbsp;level??????????debug????????????????????????????null
&gt;&gt;
&gt;&gt;????????????????????????task????????????????????????????????NPE??????????????????????????
&gt;&gt;
&gt;&gt;[1]&nbsp;https://github.com/apache/flink/blob/aa4eb8f0c9ce74e6b92c3d9be5dc8e8cb536239d/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java#L1349
&gt;&gt;
&gt;&gt;????
&gt;&gt;????
&gt;&gt;
&gt;&gt;________________________________
&gt;&gt;From:&nbsp;chenkaibit&nbsp;<chenkai...@163.com&gt;
&gt;&gt;Sent:&nbsp;Monday,&nbsp;April&nbsp;20,&nbsp;2020&nbsp;18:39
&gt;&gt;To:&nbsp;user-zh@flink.apache.org&nbsp;<user-zh@flink.apache.org&gt;
&gt;&gt;Subject:&nbsp;flink-1.10&nbsp;checkpoint&nbsp;??????&nbsp;NullPointerException
&gt;&gt;
&gt;&gt;????????????????????,&nbsp;CheckpointOperation.executeCheckpointing&nbsp;????????&nbsp;NullPointerException
&gt;&gt;java.lang.Exception:&nbsp;Couldnot&nbsp;perform&nbsp;checkpoint&nbsp;5505for&nbsp;operator&nbsp;Source:&nbsp;KafkaTableSource(xxx)&nbsp;-&gt;&nbsp;SourceConversion(table=[xxx,&nbsp;source:&nbsp;[KafkaTableSource(xxx)]],&nbsp;fields=[xxx])&nbsp;-&gt;&nbsp;Calc(select=[xxx)&nbsp;AS&nbsp;xxx])&nbsp;-&gt;&nbsp;SinkConversionToTuple2&nbsp;-&gt;&nbsp;Sink:&nbsp;Elasticsearch6UpsertTableSink(xxx)&nbsp;(1/1).
&gt;&gt;
&gt;&gt;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;org.apache.flink.streaming.runtime.tasks.StreamTask.triggerCheckpoint(StreamTask.java:802)
&gt;&gt;
&gt;&gt;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$triggerCheckpointAsync$3(StreamTask.java:777)
&gt;&gt;
&gt;&gt;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;org.apache.flink.streaming.runtime.tasks.StreamTask$$Lambda$228/1024478318.call(UnknownSource)
&gt;&gt;
&gt;&gt;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;java.util.concurrent.FutureTask.run(FutureTask.java:266)
&gt;&gt;
&gt;&gt;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.run(StreamTaskActionExecutor.java:87)
&gt;&gt;
&gt;&gt;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:78)
&gt;&gt;
&gt;&gt;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:261)
&gt;&gt;
&gt;&gt;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:186)
&gt;&gt;
&gt;&gt;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:487)
&gt;&gt;
&gt;&gt;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:470)
&gt;&gt;
&gt;&gt;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:707)
&gt;&gt;
&gt;&gt;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;org.apache.flink.runtime.taskmanager.Task.run(Task.java:532)
&gt;&gt;
&gt;&gt;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;java.lang.Thread.run(Thread.java:745)
&gt;&gt;
&gt;&gt;Causedby:&nbsp;java.lang.NullPointerException
&gt;&gt;
&gt;&gt;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;org.apache.flink.streaming.runtime.tasks.StreamTask$CheckpointingOperation.executeCheckpointing(StreamTask.java:1411)
&gt;&gt;
&gt;&gt;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;org.apache.flink.streaming.runtime.tasks.StreamTask.checkpointState(StreamTask.java:991)
&gt;&gt;
&gt;&gt;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$performCheckpoint$5(StreamTask.java:887)
&gt;&gt;
&gt;&gt;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;org.apache.flink.streaming.runtime.tasks.StreamTask$$Lambda$229/1010499540.run(UnknownSource)
&gt;&gt;
&gt;&gt;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:94)
&gt;&gt;
&gt;&gt;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;org.apache.flink.streaming.runtime.tasks.StreamTask.performCheckpoint(StreamTask.java:860)
&gt;&gt;
&gt;&gt;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;org.apache.flink.streaming.runtime.tasks.StreamTask.triggerCheckpoint(StreamTask.java:793)
&gt;&gt;
&gt;&gt;&nbsp;&nbsp;&nbsp;&nbsp;...&nbsp;12&nbsp;more

回复