[
https://issues.apache.org/jira/browse/FLINK-15608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
HunterHunter resolved FLINK-15608.
----------------------------------
Resolution: Not A Bug
flink-state-processor-api 1.9.0 are not compatible flink-runtime 1.9.1
> 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)
