[jira] [Created] (FLINK-7127) Remove unnecessary null check or add null check

["Ufuk Celebi (JIRA)" <ji...@apache.org>]

Ufuk Celebi created FLINK-7127:
----------------------------------

             Summary: Remove unnecessary null check or add null check
                 Key: FLINK-7127
                 URL: https://issues.apache.org/jira/browse/FLINK-7127
             Project: Flink
          Issue Type: Improvement
          Components: State Backends, Checkpointing
            Reporter: Ufuk Celebi


In {{HeapKeyedStateBackend#snapshot}} we have:
{code}
for (Map.Entry<String, StateTable<K, ?, ?>> kvState : stateTables.entrySet()) {
	// 1) Here we don't check for null
	metaInfoSnapshots.add(kvState.getValue().getMetaInfo().snapshot());
	kVStateToId.put(kvState.getKey(), kVStateToId.size());
	// 2) Here we check for null
	StateTable<K, ?, ?> stateTable = kvState.getValue();
	if (null != stateTable) {
		cowStateStableSnapshots.put(stateTable, stateTable.createSnapshot());
	}
}
{code}

Either this can lead to a NPE and we should check it in 1) or we remove the null check in 2). 



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)