java.lang.IllegalArgumentException with 1.3.0 and Elastic Search connector

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

java.lang.IllegalArgumentException with 1.3.0 and Elastic Search connector

Victor Godoy Poluceno
Hi,

after migrating to Flink 1.3.0, I started to get this exception when running in local mode:

[error] (run-main-0) java.lang.IllegalArgumentException
java.lang.IllegalArgumentException
    at org.apache.flink.shaded.org.objectweb.asm.ClassVisitor.<init>(Unknown Source)
    at org.apache.flink.shaded.org.objectweb.asm.ClassVisitor.<init>(Unknown Source)
    at org.apache.flink.api.scala.InnerClosureFinder.<init>(ClosureCleaner.scala:279)
    at org.apache.flink.api.scala.ClosureCleaner$.getInnerClasses(ClosureCleaner.scala:95)
    at org.apache.flink.api.scala.ClosureCleaner$.clean(ClosureCleaner.scala:115)
    at org.apache.flink.streaming.api.scala.StreamExecutionEnvironment.scalaClean(StreamExecutionEnvironment.scala:670)
    at org.apache.flink.streaming.api.scala.StreamExecutionEnvironment.addSource(StreamExecutionEnvironment.scala:600)
    at org.azion.com.Job$.main(Job.scala:39)
    at org.azion.com.Job.main(Job.scala)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:497)

This exception only happens when using the Flink Elastic Search connector, everything works fine ES connector is removed from the dependencies.

I am using, Scala 2.11.11, Elastic Search Connector 2 and Java OpenJDK version "1.8.0_111".

Any ideas about the problem here?


--
hooray!

--
Victor Godoy Poluceno
Loading...