We're having the same issue (we also have a dependency on
flink-connector-elasticsearch). It's only happening to us in IntelliJ
though. Is this the case for you as well?

On Thu, Mar 10, 2016 at 3:20 PM, Zach Cox <zcox...@gmail.com> wrote:

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


-- 
Andrew Whitaker | andrew.whita...@braintreepayments.com
--
Note: this information is confidential. It is prohibited to share, post
online or otherwise publicize without Braintree's prior written consent.

Reply via email to