Hi Robert,
After we restarted our Kafka / Zookeeper cluster the consumer worked. Some
of our topics had some problems. The flink's consumer for Kafka 0.9 works
as expected.
Thanks!
On 19 February 2016 at 12:03, Lopez, Javier <javier.lo...@zalando.de> wrote:
> Hi, these are the p
er");
properties.put("value.deserializer",
"org.apache.kafka.common.serialization.StringDeserializer");
With all three different configurations we get the same result.
On 19 February 2016 at 11:55, Robert Metzger <rmetz...@apache.org> wrote:
> Thank you.
Hi guys,
We are using Flink 1.0-SNAPSHOT with Kafka 0.9 Consumer and we have not
been able to retrieve data from our Kafka Cluster. The DEBUG data reports
the following:
10:53:24,365 DEBUG org.apache.kafka.clients.NetworkClient
- Sending metadata request ClientRequest(expectResponse=true,
endencies.
> If this is not the problem, I would try to update all Flink dependencies.
>
> Cheers, Fabian
>
> [1]
> https://cwiki.apache.org/confluence/display/FLINK/Maven+artifact+names+suffixed+with+Scala+version
>
> 2016-02-15 10:54 GMT+01:00 Lopez, Javier <j
Hi guys,
I'm running a small test with the SNAPSHOT version in order to be able to
use Kafka 0.9 and I'm getting the following error:
*cannot access org.apache.flink.api.java.operators.Keys*
*[ERROR] class file for org.apache.flink.api.java.operators.Keys not found*
The code I'm using is as
ucene-codecs/4.10.4/).
>
> Cheers,
> Aljoscha
> > On 12 Jan 2016, at 11:55, Lopez, Javier <javier.lo...@zalando.de> wrote:
> >
> > Hi,
> >
> > We are using the sink for ElasticSearch and when we try to run our job
> we
Hi,
We are using the sink for ElasticSearch and when we try to run our job we
get the following exception:
java.lang.ExceptionInInitializerError Caused by:
java.lang.IllegalArgumentException: An SPI class of type
org.apache.lucene.codecs.Codec with name 'Lucene410' does not exist. You
need to
>
> val stream: DataStream[(String, Int)] = *...*
> val counts: DataStream[(String, Int)] = stream
> .keyBy(_._1)
> .mapWithState((in: (String, Int), sum: Option[Int]) => {*val* newSum =
> in._2 + sum.getOrElse(0)
> ( (in._1, newSum), Some(newSum) )
> }
>
>
&g
