#准备工作#
看到一下图片说明执行成功！！！
异常处理及分析：
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 解决方法：
