flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: java.lang.IllegalArgumentException with 1.3.0 and Elastic Search connector
Date Fri, 07 Jul 2017 14:02:52 GMT
Luckily, someone else figured out what the problem is: https://issues.apache.org/jira/browse/FLINK-7133
<https://issues.apache.org/jira/browse/FLINK-7133>

Best,
Aljoscha

> On 30. Jun 2017, at 00:49, Victor Godoy Poluceno <victorpoluceno@gmail.com> wrote:
> 
> Hi Aljoscha,
> 
> I am using Kafka connector (flink-connector-kafka-0.8) as source.
> 
> Thank you!
> 
> On Tue, Jun 27, 2017 at 11:52 AM, Aljoscha Krettek <aljoscha@apache.org <mailto:aljoscha@apache.org>>
wrote:
> Hi Victor,
> 
> What are you using as a Source? The stack trace you posted indicates that the problem
is happening while specifying the source. This might be caused by some interactions with the
Elasticsearch dependency.
> 
> Best,
> Aljoscha
> 
>> On 17. Jun 2017, at 18:36, Victor Godoy Poluceno <victorpoluceno@gmail.com <mailto:victorpoluceno@gmail.com>>
wrote:
>> 
>> Hi,
>> 
>> after migrating to Flink 1.3.0, I started to get this exception when running in local
mode:
>> 
>> [error] (run-main-0) java.lang.IllegalArgumentException
>> java.lang.IllegalArgumentException
>>     at org.apache.flink.shaded.org <http://org.apache.flink.shaded.org/>.objectweb.asm.ClassVisitor.<init>(Unknown
Source)
>>     at org.apache.flink.shaded.org <http://org.apache.flink.shaded.org/>.objectweb.asm.ClassVisitor.<init>(Unknown
Source)
>>     at org.apache.flink.api.scala.InnerClosureFinder.<init>(ClosureCleaner.scala:279)
>>     at org.apache.flink.api.scala.ClosureCleaner$.getInnerClasses(ClosureCleaner.scala:95)
>>     at org.apache.flink.api.scala.ClosureCleaner$.clean(ClosureCleaner.scala:115)
>>     at org.apache.flink.streaming.api.scala.StreamExecutionEnvironment.scalaClean(StreamExecutionEnvironment.scala:670)
>>     at org.apache.flink.streaming.api.scala.StreamExecutionEnvironment.addSource(StreamExecutionEnvironment.scala:600)
>>     at org.azion.com.Job$.main(Job.scala:39)
>>     at org.azion.com.Job.main(Job.scala)
>>     at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>>     at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
>>     at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
>>     at java.lang.reflect.Method.invoke(Method.java:497)
>> 
>> This exception only happens when using the Flink Elastic Search connector, everything
works fine ES connector is removed from the dependencies.
>> 
>> I am using, Scala 2.11.11, Elastic Search Connector 2 and Java OpenJDK version "1.8.0_111".
>> 
>> Any ideas about the problem here?
>> 
>> By the way, this seems very close to this: [1], [2]
>> 
>> [1] - http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/asm-IllegalArgumentException-with-1-0-0-td5411.html
<http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/asm-IllegalArgumentException-with-1-0-0-td5411.html>
>> [2] - https://issues.apache.org/jira/browse/FLINK-3328 <https://issues.apache.org/jira/browse/FLINK-3328>
>> 
>> -- 
>> hooray!
>> 
>> --
>> Victor Godoy Poluceno
> 
> 
> 
> 
> -- 
> hooray!
> 
> --
> Victor Godoy Poluceno


Mime
View raw message