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

[Ufuk Celebi (JIRA)]

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)