search

databendcloud / flink-connector-databend

Flink SQL connector for Databend.
Apache License 2.0
4 stars 1 forks source link

flink connector databend can't read #10

Closed wubx closed 12 months ago

wubx commented 1 year ago 
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
hantmac commented 12 months ago

This problem caused by DatabendRowConverter not implements Serializable.