Apache flink job crashes with exception java.lang.IllegalAccessError: class org.apache.flink.util.NetUtils on start_cluster

Question

Just downloaded Flink 1.13.1 and wanted to run a small local test project. My java version is:

pneelaka@MacBook-Pro Apache %
pneelaka@MacBook-Pro Apache % $FLINK_HOME/bin/start-cluster.sh
Starting cluster.
Starting standalonesession daemon on host MacBook-Pro.
Starting taskexecutor daemon on host MacBook-Pro.
pneelaka@MacBook-Pro Apache %

The UI at localhost:8081 does not launch. I see the following in my logs:

java.lang.IllegalAccessError: class org.apache.flink.util.NetUtils (in unnamed module @0x76e041cf) cannot access class sun.net.util.IPAddressUtil (in module java.base) because module java.base does not export sun.net.util to unnamed module @0x76e041cf
    at org.apache.flink.util.NetUtils.unresolvedHostToNormalizedString(NetUtils.java:169) ~[flink-dist_2.12-1.13.1.jar:1.13.1]
    at org.apache.flink.util.NetUtils.unresolvedHostAndPortToNormalizedString(NetUtils.java:197) ~[flink-dist_2.12-1.13.1.jar:1.13.1]
    at org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils.getRpcUrl(AkkaRpcServiceUtils.java:173) ~[flink-dist_2.12-1.13.1.jar:1.13.1]
    at org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils.getRpcUrl(AkkaRpcServiceUtils.java:138) ~[flink-dist_2.12-1.13.

This heavily seems to be a java version issue ? But wouldn't flink be comptable with latest java? Will I have to go back Java 11 or 8 as it says here: https://ci.apache.org/projects/flink/flink-docs-release-1.13//docs/try-flink/local_installation/#step-1-download

Any suggestions? I have other java versions but my java home points to the latest i.e 16:

pneelaka@MacBook-Pro Apache % /usr/libexec/java_home -V
Matching Java Virtual Machines (5):
    16.0.1, x86_64: "OpenJDK 16.0.1"    /Users/pneelaka/Library/Java/JavaVirtualMachines/openjdk-16.0.1/Contents/Home
    16.0.1, x86_64: "Java SE 16.0.1"    /Library/Java/JavaVirtualMachines/jdk-16.0.1.jdk/Contents/Home
    14.0.2, x86_64: "OpenJDK 14.0.2"    /Users/pneelaka/Library/Java/JavaVirtualMachines/adopt-openjdk-14.0.2/Contents/Home
    11.0.11.1, x86_64:  "Amazon Corretto 11"    /Users/pneelaka/Library/Java/JavaVirtualMachines/corretto-11.0.11/Contents/Home
    1.8.0_292, x86_64:  "Amazon Corretto 8" /Users/pneelaka/Library/Java/JavaVirtualMachines/corretto-1.8.0_292/Contents/Home

UPDATE : Set my java home to point to java 11.0 using

export JAVA_HOME=/usr/libexec/java_home -v 11.0

and it worked

Ace McCloud · Accepted Answer · 2021-06-27 09:10:50Z

3

Set my java home to point to java 11.0 using

export JAVA_HOME=/usr/libexec/java_home -v 11.0

Flink runs with 1.8 or 11 but not the later ones

answered Jun 27, 2021 at 9:10

Ace McCloud

91015 silver badges34 bronze badges

Sign up to request clarification or add additional context in comments.

Comments

Saman Salehi · Accepted Answer · 2022-02-11 20:22:23Z

3

Flink runs on JVM from v1.8 up to v11 but not on the later ones. The official manual is misleading "Java 1.8.x or higher..."

If you use a package manager (yum, dnf, apt, etc.) then it's enough just make a clean install of java-1.8.0-openjdk and java-1.8.0-openjdk-devel. You won't need to export any environmental variables. But do not forget to remove any newer/older java versions.

If you have multiple Java versions or if you installed java manually, do:

export JAVA_HOME=/usr/libexec/java_home -v 1.8.0

or whatever your java path is. You might also need to set paths for JRE_HOME

edited Feb 11, 2022 at 20:22

Saman Salehi

1,0341 gold badge14 silver badges19 bronze badges

answered Feb 11, 2022 at 6:54

BBQ

358 bronze badges

Comments

kkrugler · Accepted Answer · 2021-06-27 17:05:16Z

0

Uhm, yes - if the question is whether the Flink documentation is correct, then I believe the answer is yes. From the page you referenced in your question:

To be able to run Flink, the only requirement is to have a working Java 8 or 11 installation

answered Jun 27, 2021 at 17:05

kkrugler

9,5506 gold badges26 silver badges21 bronze badges

Collectives™ on Stack Overflow

Apache flink job crashes with exception java.lang.IllegalAccessError: class org.apache.flink.util.NetUtils on start_cluster

3 Answers 3

Comments

Comments

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

3 Answers 3

Comments

Comments

Comments

Your Answer

Sign up or log in

Post as a guest

Related