Flink CDC中File is not a valid field name有人遇到过吗？

1.检查表字段是否用了保留字
2.flinksql source表配置：database-name，schema-name，tabel-name三个属性值统一改为大写

当使用Flink CDC时，如果出现"File is not a valid field name"的错误消息，通常是当使用Flink CDC时，如果出现"File is not a valid field name"的错误消息，通常是因为源表中存在一个名为"file"的字段。在Flink CDC中，"file"是一个保留关键字，用于表示文件相关的信息。因此，如果源表中存在名为"file"的字段，Flink CDC将无法正确处理该字段。

要解决这个问题，可以采取以下几种方法之一：

1. 修改源表结构：将源表中名为"file"的字段重命名为其他名称，例如"file_name"或"file_path"。然后重新运行Flink CDC作业即可。

2. 忽略特定字段：如果你不需要处理源表中名为"file"的字段，可以在Flink CDC作业中使用--ignore-invalid-fields选项来忽略无效字段。这样，Flink CDC将不会尝试读取和处理这个字段。

下面是一个示例代码片段，展示了如何在Flink CDC作业中忽略无效字段：

DataStream<Row> sourceStream = env.addSource(new FlinkCDCTableSource<>(
    "source_catalog", "source_database", "source_table", new MySourceFunction(),
    MyDeserializationSchema.class));

sourceStream = sourceStream.ignoreInvalidFields();

通过上述方法之一，你应该能够解决"File is not a valid field name"的问题，并成功运行Flink CDC作业。