java.lang.IllegalArgumentException with 1.3.0 and Elastic Search connector

classic Classic list List threaded Threaded
4 messages 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
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

Re: java.lang.IllegalArgumentException with 1.3.0 and Elastic Search connector

Aljoscha Krettek
Hi Victor,

What are you using as a Source? The stack trace you posted indicates that the problem is happening while specifying the source. This might be caused by some interactions with the Elasticsearch dependency.

Best,
Aljoscha

On 17. Jun 2017, at 18:36, Victor Godoy Poluceno <[hidden email]> wrote:

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

Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

Re: java.lang.IllegalArgumentException with 1.3.0 and Elastic Search connector

Victor Godoy Poluceno
Hi Aljoscha,

I am using Kafka connector (flink-connector-kafka-0.8) as source.

Thank you!

On Tue, Jun 27, 2017 at 11:52 AM, Aljoscha Krettek <[hidden email]> wrote:
Hi Victor,

What are you using as a Source? The stack trace you posted indicates that the problem is happening while specifying the source. This might be caused by some interactions with the Elasticsearch dependency.

Best,
Aljoscha

On 17. Jun 2017, at 18:36, Victor Godoy Poluceno <[hidden email]> wrote:

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




--
hooray!

--
Victor Godoy Poluceno
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

Re: java.lang.IllegalArgumentException with 1.3.0 and Elastic Search connector

Aljoscha Krettek
Luckily, someone else figured out what the problem is: https://issues.apache.org/jira/browse/FLINK-7133

Best,
Aljoscha

On 30. Jun 2017, at 00:49, Victor Godoy Poluceno <[hidden email]> wrote:

Hi Aljoscha,

I am using Kafka connector (flink-connector-kafka-0.8) as source.

Thank you!

On Tue, Jun 27, 2017 at 11:52 AM, Aljoscha Krettek <[hidden email]> wrote:
Hi Victor,

What are you using as a Source? The stack trace you posted indicates that the problem is happening while specifying the source. This might be caused by some interactions with the Elasticsearch dependency.

Best,
Aljoscha

On 17. Jun 2017, at 18:36, Victor Godoy Poluceno <[hidden email]> wrote:

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




--
hooray!

--
Victor Godoy Poluceno

Loading...