Hi Lingfeng, I believe Java 8 or 11 is appropriate for the Flink cluster at this point. I'm not sure that Flink 1.13 supports Java 16 officially.
Thanks, Youngwoo On Mon, May 31, 2021 at 2:49 PM Lingfeng Pu <p...@mtu.edu> wrote: > Hi, > > I'm new to Flink. I got a problem when running the local cluster on my > computer. Some key software information as follows: > > 1. Flink version: 1.13.0 for Scala 2.11; > 2. OS: Fedora 34; > 3. Java version: 16; > 4. Scala version: 2.11.12. > > When I started up the local cluster by command line, everything seems fine > from the command line, BUT I could not access the localhost:8081 is failed > to open. Furthermore, the exception comes out when I running the Flink > example, please see all the details below: > > [root@localhost flink-1.13.0]# ./bin/start-cluster.sh > Starting cluster. > Starting standalonesession daemon on host fedora. > Starting taskexecutor daemon on host fedora. > [root@localhost flink-1.13.0]# ./bin/flink run > examples/streaming/WordCount.jar > Executing WordCount example with default input data set. > Use --input to specify file input. > Printing result to stdout. Use --output to specify output path. > > ------------------------------------------------------------ > The program finished with the following exception: > > org.apache.flink.client.program.ProgramInvocationException: The main > method caused an error: Unable to make field private final byte[] > java.lang.String.value accessible: module java.base does not "opens > java.lang" to unnamed module @2baf3d81 > at > org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:372) > at > org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222) > at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:114) > at > org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:812) > at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:246) > at > org.apache.flink.client.cli.CliFrontend.parseAndRun(CliFrontend.java:1054) > at > org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:1132) > at > org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:28) > at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1132) > Caused by: java.lang.reflect.InaccessibleObjectException: Unable to make > field private final byte[] java.lang.String.value accessible: module > java.base does not "opens java.lang" to unnamed module @2baf3d81 > at > java.base/java.lang.reflect.AccessibleObject.checkCanSetAccessible(AccessibleObject.java:357) > at > java.base/java.lang.reflect.AccessibleObject.checkCanSetAccessible(AccessibleObject.java:297) > at java.base/java.lang.reflect.Field.checkCanSetAccessible(Field.java:177) > at java.base/java.lang.reflect.Field.setAccessible(Field.java:171) > at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:106) > at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:132) > at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:132) > at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:69) > at > org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.clean(StreamExecutionEnvironment.java:2053) > at > org.apache.flink.streaming.api.datastream.DataStream.clean(DataStream.java:203) > at > org.apache.flink.streaming.api.datastream.DataStream.addSink(DataStream.java:1243) > at > org.apache.flink.streaming.api.datastream.DataStream.print(DataStream.java:937) > at > org.apache.flink.streaming.examples.wordcount.WordCount.main(WordCount.java:94) > at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native > Method) > at > java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:78) > at > java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > at java.base/java.lang.reflect.Method.invoke(Method.java:567) > at > org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355) > ... 8 more > > I tried search solutions online, but nothing useful for me so far. I > urgently need some specific advice about how to solve this issue! I'll be > grateful for that :) > >
