Re: KAFKA-3112

2016-05-07 Thread Ismael Juma
Hi Raj and Tao, I just merged the KAFKA-3112 PR, so this issue will be fixed in 0.10.0.0. Thanks, Ismael On Fri, May 6, 2016 at 7:47 PM, tao xiao wrote: > KAFKA-2657 is unresolved so you can safely assume it hasn't been fixed yet. > > On Fri, 6 May 2016 at 07:38 Raj Tanneru wrote: > > > Yeah

gobblin error

2016-05-07 Thread Mudit Kumar
Hi, I am getting below error while running my first job. Any leads why this is happening? [hdfs@analytics gobblin-dist]$bin/gobblin-mapreduce.sh --conf job/hadoop.conf WARNING: Use "yarn jar" to launch YARN applications. SLF4J: Class path contains multiple SLF4J bindings. SLF4J: Found binding in

Re: ktable implemented as compacted topic?

2016-05-07 Thread Guozhang Wang
Hello, 1. KTable is an API class that only exists in the Kafka Streams DSL, in which users cannot directly query it by key, but can use operators like joins and aggregates that will query the KTable internal for the operation. 2. When involved in stateful operations like joins, KTable is usually

Re: KAFKA-3112

2016-05-07 Thread Raj Tanneru
Thanks Ismael and Tao. Appreciate it. Sent from my iPhone > On May 7, 2016, at 1:14 AM, Ismael Juma wrote: > > Hi Raj and Tao, > > I just merged the KAFKA-3112 PR, so this issue will be fixed in 0.10.0.0. > > Thanks, > Ismael > >> On Fri, May 6, 2016 at 7:47 PM, tao xiao wrote: >> >> KAFKA-2657