You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "HunterHunter (Jira)" <ji...@apache.org> on 2020/01/16 07:15:00 UTC
[jira] [Closed] (FLINK-15608) State Processor api Write new state
will get NullPointerException
[ https://issues.apache.org/jira/browse/FLINK-15608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
HunterHunter closed FLINK-15608.
--------------------------------
> State Processor api Write new state will get NullPointerException
> -------------------------------------------------------------------
>
> Key: FLINK-15608
> URL: https://issues.apache.org/jira/browse/FLINK-15608
> Project: Flink
> Issue Type: Bug
> Reporter: HunterHunter
> Priority: Major
>
> When I execute a simple sample program. Sometimes report this mistake (occasionally):
> Assertion failed: (last_ref), function ~ColumnFamilySet, file db/column_family.cc, line 1238.
> And When I Write new State to a new SavepointPath I will get ( v1.9.0 is fine):
> Caused by: java.lang.NullPointerExceptionCaused by: java.lang.NullPointerException at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:279) at org.apache.flink.streaming.runtime.tasks.StreamTask.run(StreamTask.java:301) at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:406) at org.apache.flink.state.api.output.BoundedOneInputStreamTaskRunner.mapPartition(BoundedOneInputStreamTaskRunner.java:76) at org.apache.flink.runtime.operators.MapPartitionDriver.run(MapPartitionDriver.java:103) at org.apache.flink.runtime.operators.BatchTask.run(BatchTask.java:504) at org.apache.flink.runtime.operators.BatchTask.invoke(BatchTask.java:369) at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:705) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:530) at java.lang.Thread.run(Thread.java:748)
>
>
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)