Java.lang.NoSuchFieldError: JAVA_9

[loserwang1024]

Search before asking

• I searched in the issues and found nothing similar.

Fluss version

0.9.0 (latest release)

Please describe the bug 🐞

When I read from kakfa and then write into fluss, erros occurs:

java.lang.NoSuchFieldError: JAVA_9
	at org.apache.fluss.utils.MapUtils.newConcurrentHashMap(MapUtils.java:31) ~[?:?]
	at org.apache.fluss.rpc.metrics.ClientMetricGroup.<init>(ClientMetricGroup.java:32) ~[?:?]
	at org.apache.fluss.client.FlussConnection.<init>(FlussConnection.java:83) ~[?:?]
	at org.apache.fluss.client.FlussConnection.<init>(FlussConnection.java:68) ~[?:?]
	at org.apache.fluss.client.ConnectionFactory.createConnection(ConnectionFactory.java:55) ~[?:?]
	at org.apache.fluss.flink.source.lookup.FlinkAsyncLookupFunction.open(FlinkAsyncLookupFunction.java:92) ~[?:?]
	at org.apache.flink.table.runtime.functions.table.lookup.CachingAsyncLookupFunction.open(CachingAsyncLookupFunction.java:82) ~[flink-table-runtime-1.20-vvr-11.5.0-2-jdk11.jar:1.20-vvr-11.5.0-2-jdk11]
	at AsyncLookupFunction$3.open(Unknown Source) ~[?:?]
	at org.apache.flink.api.common.functions.RichFunction.open(RichFunction.java:119) ~[flink-dist-1.20-vvr-11.5.0-2-jdk11.jar:1.20-vvr-11.5.0-2-jdk11]
	at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34) ~[flink-dist-1.20-vvr-11.5.0-2-jdk11.jar:1.20-vvr-11.5.0-2-jdk11]
	at org.apache.flink.table.runtime.operators.AbstractAsyncFunctionRunner.open(AbstractAsyncFunctionRunner.java:50) ~[flink-table-runtime-1.20-vvr-11.5.0-2-jdk11.jar:1.20-vvr-11.5.0-2-jdk11]
	at org.apache.flink.table.runtime.operators.join.lookup.AsyncLookupJoinRunner.open(AsyncLookupJoinRunner.java:92) ~[flink-table-runtime-1.20-vvr-11.5.0-2-jdk11.jar:1.20-vvr-11.5.0-2-jdk11]
	at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34) ~[flink-dist-1.20-vvr-11.5.0-2-jdk11.jar:1.20-vvr-11.5.0-2-jdk11]
	at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102) ~[flink-dist-1.20-vvr-11.5.0-2-jdk11.jar:1.20-vvr-11.5.0-2-jdk11]
	at org.apache.flink.streaming.api.operators.async.AsyncWaitOperator.open(AsyncWaitOperator.java:223) ~[flink-dist-1.20-vvr-11.5.0-2-jdk11.jar:1.20-vvr-11.5.0-2-jdk11]

In lower common-lang3 dependency's org.apache.commons.lang3.JavaVersion, no JAVA_9 existed.

Solution

Two solutions:

1. shaded common-lang3 or implement our own SystemUtils.isJavaVersionAtLeast
2. Only use ConcurrentHashMap because currently fluss is recommanded to use jdk11+ now.

Are you willing to submit a PR?

• I'm willing to submit a PR!