After some poking around I noticed that flink-connector-elasticsearch_2.10-1.0.0.jar contains shaded asm classes. If I remove that dependency from my project then I do not get the IllegalArgumentException.
On Thu, Mar 10, 2016 at 11:51 AM Zach Cox <zcox...@gmail.com> wrote: > Here are the jars on the classpath when I try to run our Flink job in a > local environment (via `sbt run`): > > > https://gist.githubusercontent.com/zcox/0992aba1c517b51dc879/raw/7136ec034c2beef04bd65de9f125ce3796db511f/gistfile1.txt > > There are many transitive dependencies pulled in from internal library > projects that probably need to be cleaned out. Maybe we are including > something that conflicts? Or maybe something important is being excluded? > > Are the asm classes included in Flink jars in some shaded form? > > Thanks, > Zach > > > On Thu, Mar 10, 2016 at 5:06 AM Stephan Ewen <se...@apache.org> wrote: > >> Dependency shading changed a bit between RC4 and RC5 - maybe a different >> minor ASM version is now included in the "test" scope. >> >> Can you share the dependencies of the problematic project? >> >> On Thu, Mar 10, 2016 at 12:26 AM, Zach Cox <zcox...@gmail.com> wrote: >> >>> I also noticed when I try to run this application in a local >>> environment, I get the same IllegalArgumentException. >>> >>> When I assemble this application into a fat jar and run it on a Flink >>> cluster using the CLI tools, it seems to run fine. >>> >>> Maybe my local classpath is missing something that is provided on the >>> Flink task managers? >>> >>> -Zach >>> >>> >>> On Wed, Mar 9, 2016 at 5:16 PM Zach Cox <zcox...@gmail.com> wrote: >>> >>>> Hi - after upgrading to 1.0.0, I'm getting this exception now in a unit >>>> test: >>>> >>>> IllegalArgumentException: (null:-1) >>>> org.apache.flink.shaded.org.objectweb.asm.ClassVisitor.<init>(Unknown >>>> Source) >>>> org.apache.flink.shaded.org.objectweb.asm.ClassVisitor.<init>(Unknown >>>> Source) >>>> >>>> org.apache.flink.api.scala.InnerClosureFinder.<init>(ClosureCleaner.scala:279) >>>> >>>> org.apache.flink.api.scala.ClosureCleaner$.getInnerClasses(ClosureCleaner.scala:95) >>>> >>>> org.apache.flink.api.scala.ClosureCleaner$.clean(ClosureCleaner.scala:115) >>>> >>>> org.apache.flink.streaming.api.scala.StreamExecutionEnvironment.scalaClean(StreamExecutionEnvironment.scala:568) >>>> >>>> org.apache.flink.streaming.api.scala.StreamExecutionEnvironment.addSource(StreamExecutionEnvironment.scala:498) >>>> >>>> The line that causes that exception is just adding >>>> a FlinkKafkaConsumer08 source. >>>> >>>> ClassVisitor [1] seems to throw that IllegalArgumentException when it >>>> is not given a valid api version number, but InnerClosureFinder [2] looks >>>> fine to me. >>>> >>>> Any idea what might be causing this? This unit test worked fine with >>>> 1.0.0-rc0 jars. >>>> >>>> Thanks, >>>> Zach >>>> >>>> [1] >>>> http://websvn.ow2.org/filedetails.php?repname=asm&path=%2Ftrunk%2Fasm%2Fsrc%2Forg%2Fobjectweb%2Fasm%2FClassVisitor.java >>>> [2] >>>> https://github.com/apache/flink/blob/master/flink-scala/src/main/scala/org/apache/flink/api/scala/ClosureCleaner.scala#L279 >>>> >>>> >>>> >>
