#准备工作#

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

异常处理及分析：

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 解决方法：