Flink CDC这种方式提交flink 作业,,直接用 java -jar 来执行,报如下错误？

这个错误信息表示 Flink 在解析您的 SQL 语句时遇到了语法错误。具体来说，Flink 在解析行类型（ROW）时无法识别其中的某些字符。
要解决这个问题，您可以尝试以下方法：

1. 检查您的 SQL 语句是否正确。确保您使用了正确的语法和表名，并且没有遗漏任何必要的参数或关键字。
2. 确保您的 Flink 版本与使用的 CDC 连接器版本兼容。不兼容的版本可能会导致类似的问题。
3. 如果您正在使用自定义的数据类型，请确保这些数据类型在 Flink 中是可用的。如果您的数据类型不可用，您可能需要创建一个相应的 Flink 类型或者将数据转换为 Flink 支持的其他类型。

报错：Could not parse type at position 50: expected but was . Input type string: ROW
报错详情
用户在SQL编辑器中编写SQL时，使用UDTF出现语法检查错误（红色波浪线）。

Caused by: org.apache.flink.table.api.ValidationException: Could not parse type at position 50: <IDENTIFIER> expected but was <KEYWORD>. Input type string: ROW<resultId String,pointRange String,from String,to String,type String,pointScope String,userId String,point String,triggerSource String,time String,uuid String>

报错原因
当使用DataTypeHint定义函数的数据类型时，将系统保留的关键字直接作为了字段名称。

解决方案
将变量名换成非关键字的名称，例如to换成fto，from换成ffrom等。
将已经用关键字取名的变量名加上反撇号（``）。https://help.aliyun.com/zh/flink/support/faq-about-draft-development?spm=a2c4g.750001.0.i2