[FLINK-3280] Wrong usage of Boolean.getBoolean()

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.0.0
• Assignee: Robert Metzger
• Reporter: Ted Yu
• Created: 22/Jan/16 21:28
• Updated: 25/Jan/16 18:23
• Resolved: 25/Jan/16 17:40

Description

I observed the problem in both FlinkKafkaProducerBase.java and FlinkKafkaConsumer09.java

From FlinkKafkaProducerBase.java :

if(!Boolean.getBoolean(producerConfig.getProperty(KEY_DISABLE_METRICS, "false"))) {

Boolean.getBoolean() would call System.getProperty(). See http://grepcode.com/file/repository.grepcode.com/java/root/jdk/openjdk/6-b14/java/lang/Boolean.java#238