[Bug] flink CDCExample不能用

[XiaoZhiSnow]

Search before asking

• 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