Thanks for your advice, Alexey I will try adding JDK 11 to my server later... it is little annoying to manage different jvms on one server. maybe i should fall back to flink k8s again...
Best regards, Bill 发件人: Alexey Novakov <ale...@ververica.com> 发送时间: 2023年8月29日 23:05 收件人: Xu Bill <xuzhili1...@hotmail.com> 抄送: user@flink.apache.org <user@flink.apache.org> 主题: Re: InaccessibleObjectException issue H Bill, I would recommend you to try that example with JDK 11. Support of JDK 17 is coming in Flink 1.18 https://issues.apache.org/jira/browse/FLINK-15736 Best regards, Alexey On Tue, Aug 29, 2023 at 11:50 AM Xu Bill <xuzhili1...@hotmail.com> wrote: Hello, I'm new to Apache Flink. I followed the instrunctions to run examples after installation (as described here: https://nightlies.apache.org/flink/flink-docs-stable/docs/try-flink/local_installation/#submitting-a-flink-job) and also tried running an example java app (as described here: https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/learn-flink/datastream_api/) But both of them failed to start and gave me same error as below: Exception in thread "main" 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 @4ac3c60d 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:2317) at org.apache.flink.streaming.api.datastream.DataStream.clean(DataStream.java:202) at org.apache.flink.streaming.api.datastream.DataStream.addSink(DataStream.java:1244) at org.apache.flink.streaming.api.datastream.DataStream.print(DataStream.java:937) at test.flink.Example.main(Example.java:25) Could anybody help give a solution on this? I am using OpenJDK 17. openjdk version "17.0.1" 2021-10-19 OpenJDK Runtime Environment (build 17.0.1+12-39) OpenJDK 64-Bit Server VM (build 17.0.1+12-39, mixed mode, sharing) Best regards, Bill
