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
