Quick clarification on Stephan's comment: In Flink 0.10, no suffix means
scala 2.10, for Scala 2.11 you have to add the _2.11 suffix to ALL
dependencies (including flink-java_2.11, flink-core_2.11 and so on).
In Flink 1.0, all artifacts depending on scala have a version suffix. For
example flink-cl
Yes, 0.10.x does not always have Scala version suffixes.
1.0 is doing this consistently, should cause less confusion...
On Wed, Feb 10, 2016 at 2:38 PM, shotte wrote:
> Ok It is working now
>
> I had to change a few dependency with the _2.11 suffix
>
> Thanks
>
> Sylvain
>
>
>
>
Ok It is working now
I had to change a few dependency with the _2.11 suffix
Thanks
Sylvain
org.apache.flink
flink-java
${flink.version}
o
Hi,
Thanks for your reply, but I am still a bit confuse.
I have downloaded flink-0.10.1-bin-hadoop27-scala_2.11.tgz
and kafka_2.11-0.9.0.0.tgz
I did not install myself Scala
Now tell me if I understand correctly.
Depending on the version of Flink I have (in my case the scala 2.11) I must
spec
The documentation I sent is for Flink 1.0.
In Flink 0.10.x, there is no suffix of dependencies for Scala 2.10 (e.g.
flink-streaming-java). But there is a suffix of dependencies for Scala 2.11
(e.g. flink-streaming-java_2.11).
Regards,
Chiwan Park
> On Feb 10, 2016, at 1:46 PM, Chiwan Park wro
Hi shotte,
The exception is caused by Scala version mismatch. If you want to use Scala
2.11, you have to set Flink dependencies compiled for Scala 2.11. We have a
documentation about this in wiki [1].
I hope this helps.
[1]:
https://cwiki.apache.org/confluence/display/FLINK/Maven+artifact+nam
Do I need to go to Flink 1.0 or the downgrade to Kafka 0.8 ?
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Simple-Flink-Kafka-Test-tp4828p4829.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
