Re: 回复：flink1.10 checkpoint 运行一段时间空指针异常

Thu, 02 Jul 2020 23:08:50 -0700 

你可以看看是否 FLINK-17479[1] 和你的问题一样，是的话，可以尝试修改一下 jdk 版本试试
[1]  https://issues.apache.org/jira/browse/FLINK-17479
Best,
Congxian


程龙 <13162790...@163.com> 于2020年7月1日周三 下午9:09写道：

>
>
>
>
>
>
>
>
>
>
>
>
> 都是分配不到资源(slot)的错误，应该还是checkpoint 为空导致的,不知道为啥为空
>
>
>
>
>
> 在 2020-07-01 20:51:34，"JasonLee" <17610775...@163.com> 写道：
> >你到具体的tm上找到相关的operator看看是不是有异常信息
> >
> >
> >| |
> >JasonLee
> >|
> >|
> >邮箱：17610775...@163.com
> >|
> >
> >Signature is customized by Netease Mail Master
> >
> >在2020年07月01日 20:43，程龙 写道：
> >flink1.10上 程序运行几个小时后就会报不能执行checkpoint 空指针异常 具体如下：
> >
> >
> >java.lang.Exception: Could not perform checkpoint 3201 for operator
> Filter -> Map (2/8).
> >       at
> org.apache.flink.streaming.runtime.tasks.StreamTask.triggerCheckpointOnBarrier(StreamTask.java:816)
> >       at org.apache.flink.streaming.runtime.io
> .CheckpointBarrierHandler.notifyCheckpoint(CheckpointBarrierHandler.java:86)
> >       at org.apache.flink.streaming.runtime.io
> .CheckpointBarrierAligner.processBarrier(CheckpointBarrierAligner.java:177)
> >       at org.apache.flink.streaming.runtime.io
> .CheckpointedInputGate.pollNext(CheckpointedInputGate.java:155)
> >       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:310)
> >       at
> org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:187)
> >       at
> org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:485)
> >       at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:469)
> >       at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:708)
> >       at org.apache.flink.runtime.taskmanager.Task.run(Task.java:533)
> >       at java.lang.Thread.run(Thread.java:745)
> >Caused by: java.lang.NullPointerException
> >       at
> org.apache.flink.streaming.runtime.tasks.StreamTask$CheckpointingOperation.executeCheckpointing(StreamTask.java:1382)
> >       at
> org.apache.flink.streaming.runtime.tasks.StreamTask.checkpointState(StreamTask.java:974)
> >       at
> org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$performCheckpoint$5(StreamTask.java:870)
> >       at
> org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:94)
> >       at
> org.apache.flink.streaming.runtime.tasks.StreamTask.performCheckpoint(StreamTask.java:843)
> >       at
> org.apache.flink.streaming.runtime.tasks.StreamTask.triggerCheckpointOnBarrier(StreamTask.java:803)
>

回复