flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Victor Godoy Poluceno <victorpoluc...@gmail.com>
Subject Re: java.lang.IllegalArgumentException with 1.3.0 and Elastic Search connector
Date Thu, 29 Jun 2017 22:49:36 GMT
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>
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>
> 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.objectweb.asm.ClassVisitor.<init>(Unknown
> Source)
>     at 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
> [2] - https://issues.apache.org/jira/browse/FLINK-3328
>
> --
> hooray!
>
> --
> Victor Godoy Poluceno
>
>
>


-- 
hooray!

--
Victor Godoy Poluceno

Mime
View raw message