Ted Yu created FLINK-6079: ----------------------------- Summary: Ineffective null check in FlinkKafkaConsumerBase#open() Key: FLINK-6079 URL: https://issues.apache.org/jira/browse/FLINK-6079 Project: Flink Issue Type: Bug Reporter: Ted Yu Priority: Minor
Here is related code: {code} List<KafkaTopicPartition> kafkaTopicPartitions = getKafkaPartitions(topics); subscribedPartitionsToStartOffsets = new HashMap<>(kafkaTopicPartitions.size()); if (kafkaTopicPartitions != null) { {code} Prior to the null check, kafkaTopicPartitions is already dereferenced. -- This message was sent by Atlassian JIRA (v6.3.15#6346)