Martijn Visser created FLINK-35785:
--------------------------------------

             Summary: 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


Tested with Flink 1.20 RC0

Reproducer:

{code:sql}
-- Create the product table
CREATE TABLE `product` (
    id INT,
    brandId INT,
    grade STRING,
    PRIMARY KEY (id) NOT ENFORCED
) WITH (
    'connector' = 'datagen',
    'rows-per-second' = '10',
    'fields.id.kind' = 'random',
    'fields.brandId.min' = '1',
    'fields.brandId.max' = '100',
    'fields.grade.length' = '10'
);
{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)

Reply via email to