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 <aljos...@apache.org> 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 <victorpoluc...@gmail.com> > 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 > > -- > hooray! > > -- > Victor Godoy Poluceno > > > -- hooray! -- Victor Godoy Poluceno
