在flinksql format debezium-json中解析失败，格式不同，要怎么办？

{
  "version": "1.0",
  "connector": "mysql",
  "name": "inventory-connector",
  "config": {
    "hostname": "localhost",
    "port": "3306",
    "username": "root",
    "password": "password",
    "database": "inventory",
    "table.whitelist": "products",
    "timestamp.format.standard": "ISO-8601",
    "include.schema.changes": "false",
    "deserialization.format": "debezium-json"
  }
}

可以通过配置JSON Schema来解决这个问题。

{"name": "create_time", "type": "string",
        "logicalType": "timestamp-millis",
        "doc": "MySQL timestamp converted to FlinkSQL timestamp-millis type",
        "transform": {"expr": "from_unixtime(to_unix_timestamp(substring($,1,19), 'yyyy-MM-dd HH:mm:ss'))*1000"}},