Luckily, someone else figured out what the problem is: https://issues.apache.org/jira/browse/FLINK-7133 <https://issues.apache.org/jira/browse/FLINK-7133>
Best, Aljoscha > On 30. Jun 2017, at 00:49, Victor Godoy Poluceno <victorpoluc...@gmail.com> > 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 <aljos...@apache.org > <mailto: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 >> <mailto: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 >> <http://org.apache.flink.shaded.org/>.objectweb.asm.ClassVisitor.<init>(Unknown >> Source) >> at org.apache.flink.shaded.org >> <http://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 >> >> <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 >> <https://issues.apache.org/jira/browse/FLINK-3328> >> >> -- >> hooray! >> >> -- >> Victor Godoy Poluceno > > > > > -- > hooray! > > -- > Victor Godoy Poluceno
