Flink CDC已经创建好的table 可以增加字段吗?

可以,就把ddl语句同步过来就行了
，此回答整理自钉群“Flink CDC 社区”

是的，Flink CDC创建的表可以通过修改表模式来增加字段。这可以在Flink SQL中进行，也可以通过修改表的模式元信息来实现。

以下是在Flink SQL中增加字段的方法：

ALTER TABLE table_name ADD COLUMNS (
column1 datatype,
column2 datatype,
...
);

以下是通过修改表的模式元信息来增加字段的方法：

ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env, TableSchema.builder().fields(tableSchema).build());
TableSchema newSchema = TableSchema.builder().fields(tableSchema).field("newColumn", DataTypes.STRING()).build();
tableEnv.alterTable(tableName, newSchema);