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?

By the way, this seems very close to this: [1], [2]

[1] - http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/asm-IllegalArgumentException-with-1-0-0-td5411.html
[2] - https://issues.apache.org/jira/browse/FLINK-3328

--

[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?

By the way, this seems very close to this: [1], [2]

[1] - http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/asm-IllegalArgumentException-with-1-0-0-td5411.html
[2] - https://issues.apache.org/jira/browse/FLINK-3328

--

[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?

By the way, this seems very close to this: [1], [2]

[1] - http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/asm-IllegalArgumentException-with-1-0-0-td5411.html
[2] - https://issues.apache.org/jira/browse/FLINK-3328

--

--

[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?

By the way, this seems very close to this: [1], [2]

[1] - http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/asm-IllegalArgumentException-with-1-0-0-td5411.html
[2] - https://issues.apache.org/jira/browse/FLINK-3328

--

--