开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

我想问一下,我这边把cdc需要的包放到了flink的lib目录下,执行了flink启动命令,然后通过

我想问一下,我这边把cdc需要的包放到了flink的lib目录下,执行了flink启动命令,然后通过sql-client 提交flink sql,创建表成功了,但是表里没数据,MySQL里面binlog日志是开启的,请问是什么情况CREATE TABLE account_give_config_source ( id BIGINT NOT NULL, uuid VARCHAR, user_uuid VARCHAR, commodity_uuid VARCHAR, amount_single INT, number_day INT, fail_hour INT ) WITH ( 'scan.incremental.snapshot.enabled' = 'false', 'connector' = 'mysql-cdc', 'hostname' = '192.168.50.84', 'port' = '3306', 'username' = 'root', 'password' = '123456', 'database-name' = 'local_test', 'table-name' = 'account_give_config' );

展开
收起
毛毛虫雨 2022-11-27 09:41:20 280 0
0 条回答
写回答
取消 提交回答

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载