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: +49 (0)6897/9071-417

email: jochen.rauch@ibmt.fraunhofer.de

http://www.ibmt.fraunhofer.de