Hi,
这个错是因为JDBC connector 不支持INSERT OVERWRITE, 你看的文档是列出了目前 Flink SQL
支持的INSERT语法，但是不是所有的 connector 都支持 INSERT OVERWRITE， 目前支持的只有 Filesystem
connector 和 Hive table， 这些表一般不会有主键。其他connector 如 JDBC\ES\HBase 目前不支持 INSERT
OVERWRITE，现在 JDBC\ES\HBase connector都是支持upsert 插入的[1]，
就是在connector
Apache Zeppelin有自己的rest api，你可以用rest api来提交flink sql
以及拿sql结果，目前Zeppelin社区正在做一个Client API （Zeppelin SDK),
用户可以更加方便的调用Zeppelin的功能。具体可以参考
https://issues.apache.org/jira/browse/ZEPPELIN-4981
这里有Sample code 可以参考
非常感谢您的回复，恰好我的SQL中既用到了;
也用到了\n，但是非常奇怪的是，直接使用时前者会报语法异常，而后者不会，在把;使用Unicode转义后，作业能够正常运行，且数据处理也ok，flink
版本是 1.10，初步判断可能是前端SQL传递有问题
Leonard Xu 于2020年7月31日周五 下午9:13写道：
> Hi, zilong
>
> SPLIT_INDEX(${xxx}, ‘;’, 0)
>
> ‘;’ 分号不是特殊字符，编译时应该不会报错的，我在Flink 1.11.1 用DDL 测试了下, 能够work的，不知道你的环境是怎样的。
>
Hello
请问在flink 1.11.0文档[1]中发现可以使用时可以使用INSERTOVERWRITE... 尝试了一下,但是在执行语句"insert
overwrite mysqlsink select a,cast(b as varchar) b from mySource"时报如下错误
Exception in thread "main" org.apache.flink.table.api.ValidationException:
INSERT OVERWRITE requires JDBC:MySQL DynamicTableSink to implement
