weixin_54702937: 这个管用

好记忆不如烂笔头abc: 为啥我这报错？ Flink SQL> CREATE TABLE oracle_j ( > ID INT NOT NULL, > PRIMARY KEY(ID) NOT ENFORCED > ) WITH ( > 'connector' = 'oracle-cdc', > 'hostname' = '192.168.205.58', > 'port' = '1521', > 'username' = 'ogg', > 'password' = 'ogg', > 'database-name' = 'lndb', > 'schema-name' = 'GISTAR', > 'table-name' = 'J'); [INFO] Execute statement succeed. Flink SQL> select * from oracle_j; [ERROR] Could not execute SQL statement. Reason: java.lang.ClassNotFoundException: org.apache.kafka.connect.data.Schema Flink SQL>

FlyPig_Ren: 我看官方文档给的参数里面并没有文件上传所对应的参数，他的文件对应的参数还有上传的url是什么

CSDN-Ada助手: 哇, 你的文章质量真不错，值得学习！不过这么高质量的文章, 还值得进一步提升, 以下的改进点你可以参考下: (1)增加除了各种控件外，文章正文的字数；(2)使用更多的站内链接；(3)增加条理清晰的目录。

Denny辉: 在发送请求之前添加