Re: Kafka issue

2016-03-03 Thread Márton Balassi
I have inspected mvn dependency:tree in the meantime, the maven build fortunately looks healthy fortunately, it seems my IntelliJ is very keen on the freshly acquired dependencies it has gathered recently for scala 2.11. On Thu, Mar 3, 2016 at 1:04 PM, Márton Balassi wrote: > Hey guys, > > I hav

Re: Kafka issue

2016-03-03 Thread Márton Balassi
Hey guys, I have run into the same issue when developing against the master. Now after Max's commit supposedly fixing the issue reimporting the project gives me all the dependencies for 2.10, except for scala-compiler and scala-reflect, which come in version 2.11. It seems very weird. Do you have

Re: Kafka issue

2016-03-03 Thread Gyula Fóra
This problem is kind of the other way around, as our 2.10 build has 2.11 dependencies pulled in by kafka. But let's see what happens. :) Gyula Till Rohrmann ezt írta (időpont: 2016. márc. 3., Cs, 9:46): > Hi Gyula, > > we discovered yesterday that our build process for Scala 2.11 is broken > fo

Re: Kafka issue

2016-03-03 Thread Till Rohrmann
Hi Gyula, we discovered yesterday that our build process for Scala 2.11 is broken for the Kafka connector. The reason is that a property value is not properly resolved and thus pulls in the 2.10 Kafka dependencies. Max already opened a PR to fix this problem. I hope this will also solve your probl

Re: Kafka issue

2016-03-03 Thread Gyula Fóra
Hey, Do we have any idea why this is happening in the snapshot repo? We have run into the same issue again... Cheers, Gyula Gyula Fóra ezt írta (időpont: 2016. febr. 26., P, 11:17): > Thanks Robert, so apparently the snapshot version was screwed up somehow > and included the 2.11 dependencies.

Re: Kafka issue

2016-02-26 Thread Gyula Fóra
Thanks Robert, so apparently the snapshot version was screwed up somehow and included the 2.11 dependencies. Now it works. Cheers, Gyula Gyula Fóra ezt írta (időpont: 2016. febr. 26., P, 11:09): > That actually seemed to be the issue, not that I compiled my own version > it doesnt have these w

Re: Kafka issue

2016-02-26 Thread Gyula Fóra
That actually seemed to be the issue, not that I compiled my own version it doesnt have these wrond jars in the dependency tree... Gyula Fóra ezt írta (időpont: 2016. febr. 26., P, 11:01): > I was using the snapshot repo in this case, let me try building my own > version... > > Maybe this is int

Re: Kafka issue

2016-02-26 Thread Gyula Fóra
I was using the snapshot repo in this case, let me try building my own version... Maybe this is interesting: mvn dependency:tree | grep 2.11 [INFO] | \- org.apache.kafka:kafka_2.11:jar:0.8.2.2:compile [INFO] | +- org.scala-lang.modules:scala-xml_2.11:jar:1.0.2:compile [INFO] | +- org.scal

Re: Kafka issue

2016-02-26 Thread Robert Metzger
Are you building 1.0-SNAPSHOT yourself or are you relying on the snapshot repository? We had issues in the past that jars in the snapshot repo were incorrect On Fri, Feb 26, 2016 at 10:45 AM, Gyula Fóra wrote: > I am not sure what is happening. I tried running against a Flink cluster > that is

Re: Kafka issue

2016-02-26 Thread Gyula Fóra
I am not sure what is happening. I tried running against a Flink cluster that is definitely running the correct Scala version (2.10) and I still got the error. So it might be something with the pom.xml but we just don't see how it is different from the correct one. Gyula Till Rohrmann ezt írta (

Re: Kafka issue

2016-02-26 Thread Till Rohrmann
Hi Gyula, could it be that you compiled against a different Scala version than the one you're using for running the job? This usually happens when you compile against 2.10 and let it run with version 2.11. Cheers, Till On Fri, Feb 26, 2016 at 10:09 AM, Gyula Fóra wrote: > Hey, > > For one of o