UnsupportedOperationException from org.apache.flink.shaded.asm6.org.objectweb.asm.ClassVisitor.visitNestHostExperimental using Java 11

[Rauch, Jochen]

Hi all,

 

I have implemented following code snippet with Apache Flink 1.8:

flinkConfiguration.getEnvironment().readTextFile(outputFile.getAbsolutePath(), "ISO-8859-1")

.flatMap(new FlatMapFunction<String, Tuple2<Map<ParameterBean, Object>, Integer>>() {

                ….

}) ….

 

It works fine with Java 8, but using Java 11 I get this error stacktrace:

                at org.apache.flink.shaded.asm6.org.objectweb.asm.ClassVisitor.visitNestHostExperimental(ClassVisitor.java:158)

                at org.apache.flink.shaded.asm6.org.objectweb.asm.ClassReader.accept(ClassReader.java:541)

                at org.apache.flink.shaded.asm6.org.objectweb.asm.ClassReader.accept(ClassReader.java:391)

                at org.apache.flink.api.java.ClosureCleaner.cleanThis0(ClosureCleaner.java:115)

                at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:75)

                at org.apache.flink.api.java.DataSet.clean(DataSet.java:186)

                at org.apache.flink.api.java.DataSet.flatMap(DataSet.java:267)

                at de.idsem.xploit.ief.control.FlinkETLOutputPipeline.execute(FlinkETLOutputPipeline.java:66)

 

Could you please help with this issue?

 

Many thanks in advance and best regards

Jochen

 

 

---------------------------------------------------------

Dipl.-Inform. (FH) Jochen Rauch

Health Information Systems

 

Fraunhofer Institute for Biomedical Engineering

Joseph-von-Fraunhofer-Weg 1

66280 Sulzbach

Germany

 

Visit: Ensheimer Str. 48, 66386 St. Ingbert, Germany

Phone: [phone]

email: [hidden email]

http://www.ibmt.fraunhofer.de

 

[Chesnay Schepler]

Flink only supports Java 8.

On 04/07/2019 15:34, Rauch, Jochen wrote:

Hi all,

 

I have implemented following code snippet with Apache Flink 1.8:

flinkConfiguration.getEnvironment().readTextFile(outputFile.getAbsolutePath(), "ISO-8859-1")

.flatMap(new FlatMapFunction<String, Tuple2<Map<ParameterBean, Object>, Integer>>() {

                ….

}) ….

 

It works fine with Java 8, but using Java 11 I get this error stacktrace:

                at org.apache.flink.shaded.asm6.org.objectweb.asm.ClassVisitor.visitNestHostExperimental(ClassVisitor.java:158)

                at org.apache.flink.shaded.asm6.org.objectweb.asm.ClassReader.accept(ClassReader.java:541)

                at org.apache.flink.shaded.asm6.org.objectweb.asm.ClassReader.accept(ClassReader.java:391)

                at org.apache.flink.api.java.ClosureCleaner.cleanThis0(ClosureCleaner.java:115)

                at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:75)

                at org.apache.flink.api.java.DataSet.clean(DataSet.java:186)

                at org.apache.flink.api.java.DataSet.flatMap(DataSet.java:267)

                at de.idsem.xploit.ief.control.FlinkETLOutputPipeline.execute(FlinkETLOutputPipeline.java:66)

 

Could you please help with this issue?

 

Many thanks in advance and best regards

Jochen

 

 

---------------------------------------------------------

Dipl.-Inform. (FH) Jochen Rauch

Health Information Systems

 

Fraunhofer Institute for Biomedical Engineering

Joseph-von-Fraunhofer-Weg 1

66280 Sulzbach

Germany

 

Visit: Ensheimer Str. 48, 66386 St. Ingbert, Germany

Phone: [phone]

email: [hidden email]

http://www.ibmt.fraunhofer.de

 

[KristoffSC]

Hi,
are there any plans to support Java 11?

Thanks,
Krzysztof



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

[Piotr Nowojski-3]

Hi,

Yes, this is work in progress [1]. It looks like the Java 11 support is targeted for Flink 1.10 which should be released this or the following month.

Piotrek

[1] https://issues.apache.org/jira/browse/FLINK-10725

On 9 Jan 2020, at 15:56, KristoffSC <[hidden email]> wrote:

Hi,
are there any plans to support Java 11?

Thanks,
Krzysztof



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/