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