Details
-
Bug
-
Status: Closed
-
Blocker
-
Resolution: Cannot Reproduce
-
None
-
None
-
None
Description
Tested with Flink 1.20 RC0
Reproducer:
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' );
Followed by:
SELECT * FROM product
Results in:
[ERROR] Could not execute SQL statement. Reason:
java.lang.ClassNotFoundException: org.apache.flink.core.execution.RestoreMode