陈韬说的是对的，cdc connector只有source的， 你写入的是mysql表，需要加下jdbc connector 的依赖
祝好
Leonard
>
>> 2020年9月10日 下午3:54，杨帅统 写道：
>>
>> pvuv_test_back
>
Mysql-cdc只是source，我的理解您pvuv_test_back应该用jdbc作为sink。
Best,
TonyChen
> 2020年9月10日 下午3:54，杨帅统 写道：
>
> pvuv_test_back
lib 目录下的包如上图 flink是本地模式 也尝试过重启 ./bin/start-cluster.sh 命令 但还是提示一样的错误信息
在 2020-09-09 21:16:58，"Leonard Xu" 写道：
>Hi
>
>这个错误是jar包没有正确地加载，看代码应该没啥问题，添加jar包后需要重启下集群，你测试的时候重启了吗？
>
>
>祝好
>Leonard
>
>> 在 2020年9月9日，16:48，杨帅统 写道：
>>
>> 公司希望将MySQLA库的数据实时同步到B库中，我想通过fink1.11的CDC功能不知道是否可行。
>> 在做测试
Hi
这个错误是jar包没有正确地加载，看代码应该没啥问题，添加jar包后需要重启下集群，你测试的时候重启了吗？
祝好
Leonard
> 在 2020年9月9日，16:48，杨帅统 写道：
>
> 公司希望将MySQLA库的数据实时同步到B库中，我想通过fink1.11的CDC功能不知道是否可行。
> 在做测试的时候定义一张cdc源表和一张sink表
> CREATE TABLE pvuv_test (
> id INT,
> dt STRING,
> pv STRING,
> uv STRING ,
> proc_time AS PROCTIME() --使用维表时
Hi 杨帅统
MySQL-MySQL数据实时同步也可以使用阿里开源的otter
https://github.com/alibaba/otter/
发件人: 杨帅统
发送时间: Wednesday, September 9, 2020 4:49 PM
收件人: user-zh@flink.apache.org
主题: flink-cdc sink mysql 问题
公司希望将MySQLA库的数据实时同步到B库中，我想通过fink1.11的CDC功能不知道是否可行。
在做测试的时候定义一张cdc源表和一张sink表
CREATE TABLE pvuv_test (
id INT
公司希望将MySQLA库的数据实时同步到B库中，我想通过fink1.11的CDC功能不知道是否可行。
在做测试的时候定义一张cdc源表和一张sink表
CREATE TABLE pvuv_test (
id INT,
dt STRING,
pv STRING,
uv STRING ,
proc_time AS PROCTIME() --使用维表时需要指定该字段
) WITH (
'connector' = 'mysql-cdc', -- 连接器
'hostname' = 'localhost', --mysql地址
'port' = '3306', --
