[jira] [Created] (FLINK-15608) State Processor api Write new state will get NullPointerException

[Shang Yuanchun (Jira)]

HunterHunter created FLINK-15608:
------------------------------------

             Summary:  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


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)