Ted Yu created FLINK-6052:
-----------------------------
Summary: Potential null access in
ZooKeeperCompletedCheckpointStore#getLatestCheckpoint()
Key: FLINK-6052
URL: https://issues.apache.org/jira/browse/FLINK-6052
Project: Flink
Issue Type: Bug
Reporter: Ted Yu
Priority: Minor
{code}
Tuple2<RetrievableStateHandle<CompletedCheckpoint>, String>
checkpointStateHandle = checkpointStateHandles.peekLast();
try {
return retrieveCompletedCheckpoint(checkpointStateHandle);
} catch (Exception e) {
LOG.warn("Could not retrieve latest checkpoint. Removing it from " +
"the completed checkpoint store.", e);
try {
// remove the checkpoint with broken state handle
removeBrokenStateHandle(checkpointStateHandles.pollLast());
} catch (Exception removeException) {
{code}
The code should handle the case where peekLast() / pollLast() returns null.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
