[Bug] flink CDCExample不能用

[XiaoZhiSnow]

Search before asking

• [X] I searched in the issues and found nothing similar.

Version

iotdb 1.3.2

Describe the bug and provide the minimal reproduce step

参考官方例子： public static void main(String[] args) { EnvironmentSettings settings = EnvironmentSettings.newInstance().inStreamingMode().build(); TableEnvironment tableEnv = TableEnvironment.create(settings); // source Schema sourceTableSchema = Schema.newBuilder() .column("Time_", DataTypes.BIGINT()) .column("root.zhang.table3.id", DataTypes.INT()) .column("root.zhang.table3.name", DataTypes.STRING()) .column("root.zhang.table3.address", DataTypes.STRING()) .build();

    TableDescriptor tableDescriptor =
            TableDescriptor.forConnector("IoTDB")
                    .schema(sourceTableSchema)
                    .option("mode", "CDC")
                    .option("cdc.task.name", "test2")
                    .option("cdc.pattern", "root.zhang.table3")
                    .option("cdc.port", "18089")
                    .build();
    tableEnv.createTemporaryTable("source_table", tableDescriptor);

    // output table
    tableEnv.from("source_table").execute().print();

发现执行后，没有数据打印

在iot界面，这个实体是有数据的

What did you expect to see?

期望官方例子 CDCExample，能够正确执行

What did you see instead?

no

Anything else?

No response

Are you willing to submit a PR?

• [ ] I'm willing to submit a PR!

[CritasWang]

@xuanronaldo