[Bug]: Flink 1.15 quickstart failed for java.lang.ClassNotFoundException

[Aireed]

What happened?

when do quickstart use flink 1.15, we get the exception。
Flink SQL> SELECT id, name FROM arctic.test_db.test_table/+OPTIONS('streaming' = 'true')/;
[ERROR] Could not execute SQL statement. Reason:
java.lang.ClassNotFoundException: com.netease.arctic.shaded.org.apache.flink.streaming.connectors.kafka.table.KafkaConnectorOptions

Affects Versions

0.3.2

What engines are you seeing the problem on?

Flink

How to reproduce

use flink 1.15 , according to the quickstart guide.

Relevant log output

Flink SQL> SELECT id, `name` FROM arctic.test_db.test_table/*+OPTIONS('streaming' = 'true')*/;
[ERROR] Could not execute SQL statement. Reason:
java.lang.ClassNotFoundException: com.netease.arctic.shaded.org.apache.flink.streaming.connectors.kafka.table.KafkaConnectorOptions

Anything else

No response

Code of Conduct

• I agree to follow this project's Code of Conduct