Hi,
I use flink-scala version 1.9.1 and scala 2.12.10, and I defined a data
type which is a bit more complex: it has a list in it and even a
dictionary. When I try to use a custom map I got this error:
INFO org.apache.flink.api.java.typeutils.TypeExtractor - class A does not
contain a setter fo
Hi Alex,
the problem is that `case class` classes are analyzed by Scala specific
code whereas `class` classes are analyzed with Java specific code. So I
would recommend to use a case class to make sure you stay in the "Scala
world" otherwise the fallback is the Java-based TypeExtractor.
For
I used `case class` for example case class A(a: Map[String, String]) so it
should work
Alex
On Thu, Dec 19, 2019 at 2:18 PM Timo Walther wrote:
> Hi Alex,
>
> the problem is that `case class` classes are analyzed by Scala specific
> code whereas `class` classes are analyzed with Java specific c
I'm sorry for my last message, it might be incomplete.
So I used case classed for my objects, but it doesn't work.
Riching this error: "Exception in thread "main"
org.apache.flink.shaded.guava18.com.google.common.util.concurrent.ExecutionError:
java.lang.NoClassDefFoundError: scala/math/Ordering$
That's sounds like a classloading or most likely dependency issue.
Are all dependencies including Flink use the same Scala version? Could
you maybe share reproducible some code with us?
Regards,
Timo
On 19.12.19 13:53, Alexandru Vasiu wrote:
I'm sorry for my last message, it might be incomp
This is a part of my Gradle config:
ext {
scalaVersion = '2.12'
flinkVersion = '1.9.1'
scalaBuildVersion = "${scalaVersion}.10"
scalaMockVersion = '4.4.0'
circeGenericVersion = '0.12.3'
circeExtrasVersion = '0.12.2'
pardiseVersion = '2.1.1'
slf4jVersion = '1.7.7'
I see a mismatch between scalaBuildVersion and scalaVersion could this
be the issue?
Regards,
Timo
On 19.12.19 14:33, Alexandru Vasiu wrote:
This is a part of my Gradle config:
ext {
scalaVersion = '2.12'
flinkVersion = '1.9.1'
scalaBuildVersion = "${scalaVersion}.10"
sca
Nope, because scalaBuildVersion is the scala version including minor
version so in this case: 2.12.10 and we used it just where we need.
We used scalaVersion to specify for each library what scala is used, so
used flink will be flink-streaming-scala_2.12
Alex
On Thu, Dec 19, 2019 at 3:40 PM Timo
Sorry, you are right. Maybe you can also share the full stack trace
because I don't know where this guava library should be used.
Regards,
Timo
On 19.12.19 14:50, Alexandru Vasiu wrote:
Nope, because scalaBuildVersion is the scala version including minor
version so in this case: 2.12.10 and w
Hi,
We fixed it by converting the case class to a class.
Thank you,
Alex
On Thu, Dec 19, 2019 at 5:43 PM Timo Walther wrote:
> Sorry, you are right. Maybe you can also share the full stack trace
> because I don't know where this guava library should be used.
>
> Regards,
> Timo
>
>
> On 19.12.
10 matches
Mail list logo
