[
https://issues.apache.org/jira/browse/FLINK-35785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863848#comment-17863848
]
Weijie Guo edited comment on FLINK-35785 at 7/8/24 4:04 PM:
------------------------------------------------------------
Hi [~martijnvisser]
I download flink-1.20.0 binary from
[https://dist.apache.org/repos/dist/dev/flink/flink-1.20.0-rc0/flink-1.20.0-bin-scala_2.12.tgz]
Then I start a local cluster in standalone mode and submit the SQL you
mentioned, but I can't get the ClassNotFoundException.
What deployment mode are you using, yarn/k8s session/application?
was (Author: weijie guo):
I download flink-1.20.0 binary from
[https://dist.apache.org/repos/dist/dev/flink/flink-1.20.0-rc0/flink-1.20.0-bin-scala_2.12.tgz]
Then I start a local cluster in standalone mode and submit the SQL you
mentioned, but I can't get the ClassNotFoundException.
What deployment mode are you using, yarn/k8s session/application?
> Executing query in SQL client results in "java.lang.ClassNotFoundException:
> org.apache.flink.core.execution.RestoreMode"
> ------------------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-35785
> URL: https://issues.apache.org/jira/browse/FLINK-35785
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Checkpointing, Table SQL / Client
> Reporter: Martijn Visser
> Priority: Blocker
>
> Tested with Flink 1.20 RC0
> Reproducer:
> {code:sql}
> CREATE TABLE `product` (
> id INT,
> brandId INT,
> PRIMARY KEY (id) NOT ENFORCED
> ) WITH (
> 'connector' = 'datagen',
> 'rows-per-second' = '10',
> 'fields.id.kind' = 'random',
> 'fields.brandId.min' = '1',
> 'fields.brandId.max' = '100'
> );
> {code}
> Followed by:
> {code:sql}
> SELECT * FROM product
> {code}
> Results in:
> [ERROR] Could not execute SQL statement. Reason:
> java.lang.ClassNotFoundException: org.apache.flink.core.execution.RestoreMode
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
