-
Notifications
You must be signed in to change notification settings - Fork 1
Closed
Description
link SQL> CREATE TABLE dproducts (id INT,name String,description String, PRIMARY KEY (`id`) NOT ENFORCED)
> WITH ('connector' = 'databend',
> 'url'='databend://localhost:8000',
> 'username'='wubx',
> 'password'='wubxwubx',
> 'database-name'='default',
> 'table-name'='dproducts',
> 'sink.batch-size' = '5',
> 'sink.ignore-delete' = 'false',
> 'sink.flush-interval' = '1000',
> 'sink.max-retries' = '3');
[INFO] Execute statement succeed.
Flink SQL> select * from dproducts;
[ERROR] Could not execute SQL statement. Reason:
java.io.NotSerializableException: org.apache.flink.connector.databend.internal.converter.DatabendRowConverter
Metadata
Metadata
Assignees
Labels
No labels