#准备工作#

看到一下图片说明执行成功！！！

异常处理及分析：

Could not execute SQL statement. Reason:
org.apache.flink.sql.parser.impl.ParseException: Encountered "\'connector\'" at line 21, column 3.
Was expecting one of:

应该是你sql前面每一行有用tab缩进的原因导致的。

java.io.StreamCorruptedException: unexpected block data 解决方法：

类加载顺序问题，flink默认是child-first，在flink的flink-conf.yaml文件中添加classloader.resolve-order: child-first 改成parent-first，重启集群即可。