[FLINK-15608] State Processor api Write new state will get NullPointerException

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Not A Bug
• Component/s: API / State Processor
• Assignee: Unassigned
• Reporter: HunterXHunter
• Created: 16/Jan/20 04:08
• Updated: 05/Mar/20 20:39
• Resolved: 16/Jan/20 07:13

Description

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)