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