Hi!
The `PropertiesUtil.getBoolean` currently only exists in `1.3-SNAPSHOT`. The method was added along with one of the Kafka consumer changes recently.
Generally, you should always use matching versions of the Flink installation and the library, otherwise these kind of errors can always be expected.
Cheers,
Gordon
On 24 April 2017 at 11:56:44 PM, Abdul Salam Shaikh ([hidden email]) wrote:
Hi,
I am using
1.2-SNAPSHOT of Apache Flink and 1.3-SNAPSHOT
of flink-connector-kafka-0.9_2.11.
It was
executing without any errors before but it is giving the following
exception at the moment:
java.lang.NoSuchMethodError:
org.apache.flink.util.PropertiesUtil.getBoolean(Ljava/util/Properties;Ljava/lang/String;Z)Z
at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09.getIsAutoCommitEnabled(FlinkKafkaConsumer09.java:235)
at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase.open(FlinkKafkaConsumerBase.java:330)
at
org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:36)
at
org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:157)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:383)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:259)
at
org.apache.flink.runtime.taskmanager.Task.run(Task.java:654)
at
java.lang.Thread.run(Thread.java:745)
Has anything
change recently on this front ?
Thanks in
anticipation!
Locked
