I think the problem is that you only set the version of the Kafka connector
to 1.0-SNAPSHOT, not for the rest of the Flink dependencies.
On Tue, Jan 5, 2016 at 6:18 PM, Alex Rovner <alex.rov...@magnetic.com>
wrote:
> Thanks Till for the info. I tried switching to 1.0-SNAPSHOT and now facing
> another error:
>
> Caused by: java.lang.NoSuchMethodError:
> org.apache.flink.streaming.api.operators.StreamingRuntimeContext.isCheckpointingEnabled()Z
> at
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer.run(FlinkKafkaConsumer.java:413)
> at
> org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:58)
> at
> org.apache.flink.streaming.runtime.tasks.SourceStreamTask.run(SourceStreamTask.java:55)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:218)
> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:584)
> at java.lang.Thread.run(Thread.java:745)
>
>
> On Tue, Jan 5, 2016 at 3:54 AM Till Rohrmann <trohrm...@apache.org> wrote:
>
>> Hi Alex,
>>
>> this is a bug in the `0.10` release. Is it possible for you to switch to
>> version `1.0-SNAPSHOT`. With this version, the error should no longer occur.
>>
>> Cheers,
>> Till
>>
>> On Tue, Jan 5, 2016 at 1:31 AM, Alex Rovner <alex.rov...@magnetic.com>
>> wrote:
>>
>>> Hello Flinkers!
>>>
>>> The below program produces the following error when running locally. I
>>> am building the program using maven, using 0.10.0 and running in streaming
>>> only local mode "start-local-streaming.sh". I have verified that kafka and
>>> the topic is working properly by using kafka-console-*.sh scripts. What am
>>> I doing wrong? Any help would be appreciated it.
>>>
>>> Caused by: java.lang.NumberFormatException: For input string: ""
>>>
>>> at
>>> java.lang.NumberFormatException.forInputString(NumberFormatException.java:65)
>>>
>>> at java.lang.Long.parseLong(Long.java:601)
>>>
>>> at java.lang.Long.valueOf(Long.java:803)
>>>
>>> at
>>> org.apache.flink.streaming.connectors.kafka.internals.ZookeeperOffsetHandler.getOffsetFromZooKeeper(ZookeeperOffsetHandler.java:125)
>>>
>>> at
>>> org.apache.flink.streaming.connectors.kafka.internals.ZookeeperOffsetHandler.seekFetcherToInitialOffsets(ZookeeperOffsetHandler.java:88)
>>>
>>>
>>> def main(args: Array[String]) {
>>> val env = StreamExecutionEnvironment.getExecutionEnvironment
>>>
>>> val properties = new Properties();
>>> properties.setProperty("bootstrap.servers", "localhost:9092");
>>> properties.setProperty("zookeeper.connect", "localhost:2181");
>>> properties.setProperty("group.id", "test");
>>>
>>> val stream = env
>>> .addSource(new FlinkKafkaConsumer082[String]("topic", new
>>> SimpleStringSchema(), properties))
>>>
>>> val counts = stream.map(f=>f.split(","))
>>>
>>> print(counts)
>>>
>>> env.execute()
>>> }
>>>
>>> --
>>> *Alex Rovner*
>>> *Director, Data Engineering *
>>> *o:* 646.759.0052
>>>
>>> * <http://www.magnetic.com/>*
>>>
>>>
>> --
> *Alex Rovner*
> *Director, Data Engineering *
> *o:* 646.759.0052
>
> * <http://www.magnetic.com/>*
>
>
