FlinkCDC这里为啥打印不到数据？

FlinkCDC这里为啥打印不到数据？而通过普通的source sink 是可以读到数据的 StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env);

    //2.使用FLINKSQL DDL模式构建CDC 表
    tableEnv.executeSql("CREATE TABLE ad_schedule_test (\n" +
            "                                    schedule_id Int,\n" +
            "schedule_no String,\n" +
            "schedule_name String,\n" +
            "schedule_status Int,\n" +
            "create_time TIMESTAMP\n" +
            ") WITH (\n" +
            "      'connector' = 'mysql-cdc',                   -- 必须为 'mysql-cdc'\n" +
            "      'hostname' = '172.20.150.109',               -- 数据库的 IP\n" +
            "      'port' = '3406',                             -- 数据库的访问端口\n" +
            "      'username' = 'test',                  -- 数据库访问的用户名（需要提供 SHOW DATABASES, REPLICATION SLAVE, REPLICATION CLIENT, SELECT, RELOAD 权限）\n" +
            "      'password' = 'test',               -- 数据库访问的密码\n" +
            "      'database-name' = 'bigdata',          -- 需要同步的数据库\n" +
            "      'scan.incremental.snapshot.enabled' = 'false',\n" +
            "       'scan.startup.mode' = 'initial', \n"+
            "      'table-name' = 'bigdata.ad_schedule_test'                -- 需要同步的数据表名\n" +
            "      )");

    //3.查询数据并转换为流输出
    Table table = tableEnv.sqlQuery("select * from coocaa_bigdata_ad_schedule_test");
    DataStream<Tuple2<Boolean, Row>> retractStream = tableEnv.toRetractStream(table, Row.class);
    retractStream.print();

    //4.启动
    env.execute();