Great to hear!
On Tue, Mar 15, 2016 at 1:14 PM, Balaji Rajagopalan <
balaji.rajagopa...@olacabs.com> wrote:
> Robert,
> I got it working for 1.0.0.
>
> balaji
>
> On Mon, Mar 14, 2016 at 4:41 PM, Balaji Rajagopalan <
> balaji.rajagopa...@olacabs.com> wrote:
>
>> Yep the same issue as before(cla
Robert,
I got it working for 1.0.0.
balaji
On Mon, Mar 14, 2016 at 4:41 PM, Balaji Rajagopalan <
balaji.rajagopa...@olacabs.com> wrote:
> Yep the same issue as before(class not found) with flink 0.10.2 with
> scala version 2.11. I was not able to use scala 2.10 since connector for
> flink_con
Yep the same issue as before(class not found) with flink 0.10.2 with scala
version 2.11. I was not able to use scala 2.10 since connector for
flink_connector_kafka for 0.10.2 is not available.
balaji
On Mon, Mar 14, 2016 at 4:20 PM, Balaji Rajagopalan <
balaji.rajagopa...@olacabs.com> wrote:
>
Yes figured that out, thanks for point that, my bad. I have put back 0.10.2
as flink version, will try to reproduce the problem again, this time I have
explicitly called out the scala version as 2.11.
On Mon, Mar 14, 2016 at 4:14 PM, Robert Metzger wrote:
> Hi,
>
> flink-connector-kafka_ doesn'
Hi,
flink-connector-kafka_ doesn't exist for 1.0.0. You have to use either
flink-connector-kafka-0.8_ or flink-connector-kafka-0.9_
On Mon, Mar 14, 2016 at 11:17 AM, Balaji Rajagopalan <
balaji.rajagopa...@olacabs.com> wrote:
> What I noticied was that, if I remove the dependency on
> flink-con
What I noticied was that, if I remove the dependency on
flink-connector-kafka so it is clearly to do something with that
dependency.
On Mon, Mar 14, 2016 at 3:46 PM, Balaji Rajagopalan <
balaji.rajagopa...@olacabs.com> wrote:
> Robert,
>I have moved on to latest version of flink of 1.0.0 ho
Robert,
I have moved on to latest version of flink of 1.0.0 hoping that will
solve my problem with kafka connector . Here is my pom.xml but now I cannot
get the code compiled.
[ERROR] Failed to execute goal
net.alchim31.maven:scala-maven-plugin:3.2.1:compile (scala-compile-first)
on project fl
Can you send me the full build file to further investigate the issue?
On Fri, Mar 11, 2016 at 4:56 PM, Balaji Rajagopalan <
balaji.rajagopa...@olacabs.com> wrote:
> Robert,
> That did not fix it ( using flink and connector same version) . Tried
> with scala version 2.11, so will try to see scal
Robert,
That did not fix it ( using flink and connector same version) . Tried
with scala version 2.11, so will try to see scala 2.10 makes any
difference.
balaji
On Fri, Mar 11, 2016 at 8:06 PM, Robert Metzger wrote:
> Hi,
>
> you have to use the same version for all dependencies from the
> "
Hi,
you have to use the same version for all dependencies from the
"org.apache.flink" group.
You said these are the versions you are using:
flink.version = 0.10.2
kafka.verison = 0.8.2
flink.kafka.connection.verion=0.9.1
For the connector, you also need to use 0.10.2.
On Fri, Mar 11, 2016 at
I am tyring to use the flink kafka connector, for this I have specified the
kafka connector dependency and created a fat jar since default flink
installation does not contain kafka connector jars. I have made sure that
flink-streaming-demo-0.1.jar has the
kafka.javaapi.consumer.SimpleConsumer.class
11 matches
Mail list logo
