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)
