[ https://issues.apache.org/jira/browse/FLINK-6079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Chesnay Schepler closed FLINK-6079. ----------------------------------- Resolution: Fixed Fix Version/s: 1.3.0 1.3: 8890a8db41c45504aa658a1942f40bb9af7dcf30 > Ineffective null check in FlinkKafkaConsumerBase#open() > ------------------------------------------------------- > > Key: FLINK-6079 > URL: https://issues.apache.org/jira/browse/FLINK-6079 > Project: Flink > Issue Type: Bug > Components: Kafka Connector > Reporter: Ted Yu > Assignee: Chesnay Schepler > Priority: Minor > Fix For: 1.3.0 > > > 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)