I need help to figure out the problem with sql-client.
With postgres-cdc jar copied to lib and execute the following sql statements, got ClassNotFoundException. Error: Flink SQL> SELECT * FROM shipments; [ERROR] Could not execute SQL statement. Reason: java.lang.ClassNotFoundException: org.apache.flink.streaming.api.functions.source.SourceFunction Sql statements executed: Flink SQL> CREATE TABLE shipments ( > shipment_id INT, > order_id INT, > origin STRING, > destination STRING, > is_arrived BOOLEAN > ) WITH ( > 'connector' = 'postgres-cdc', > 'hostname' = 'localhost', > 'port' = '5432', > 'username' = 'postgres', > 'password' = 'postgres', > 'database-name' = 'postgres', > 'schema-name' = 'public', > 'table-name' = 'shipments', > 'slot.name' = 'flink', > -- experimental feature: incremental snapshot (default off) > 'scan.incremental.snapshot.enabled' = 'true' > ); [INFO] Execute statement succeeded. Flink SQL> SELECT * FROM shipments; [ERROR] Could not execute SQL statement. Reason: java.lang.ClassNotFoundException: org.apache.flink.streaming.api.functions.source.SourceFunction flink/lib:
