[FLINK-5602] Migration with RocksDB job led to NPE for next checkpoint

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.2.0, 1.3.0
• Assignee: Stefan Richter
• Reporter: Ufuk Celebi
• Created: 21/Jan/17 17:15
• Updated: 25/Jan/17 16:57
• Resolved: 25/Jan/17 16:57

Description

When migrating a job with RocksDB I got the following Exception when the next checkpoint was triggered. This only happened once and I could not reproduce it ever since.

[e-mail] Maybe we can look over the code and check what could have failed here? I unfortunately don't have more available of the stack trace. I don't think that this will be very helpful will it?

	at org.apache.flink.util.Preconditions.checkNotNull(Preconditions.java:58)
	at org.apache.flink.runtime.state.KeyedBackendSerializationProxy$StateMetaInfo.<init>(KeyedBackendSerializationProxy.java:126)
	at org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend$RocksDBSnapshotOperation.writeKVStateMetaData(RocksDBKeyedStateBackend.java:471)
	at org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend$RocksDBSnapshotOperation.writeDBSnapshot(RocksDBKeyedStateBackend.java:382)
	at org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend$1.performOperation(RocksDBKeyedStateBackend.java:280)
	at org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend$1.performOperation(RocksDBKeyedStateBackend.java:262)
	at org.apache.flink.runtime.io.async.AbstractAsyncIOCallable.call(AbstractAsyncIOCallable.java:72)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at org.apache.flink.util.FutureUtil.runIfNotDoneAndGet(FutureUtil.java:37)
	... 6 more

Issue Links

• links to: GitHub Pull Request #3200