Exception in thread "main" org.apache.flink.table.api.SqlParserException: SQL parse failed. Non-query expression encountered in illegal context at org.apache.flink.table.calcite.FlinkPlannerImpl.parse(FlinkPlannerImpl.scala:99) at org.apache.flink.table.api.internal.TableEnvImpl.sqlQuery(TableEnvImpl.scala:428) at com.ci123.cidata.platform.flink.outline.module.operator.BSql.getTableActual(BSql.java:39) at com.ci123.cidata.platform.flink.outline.module.operator.BSql.process(BSql.java:27) at com.ci123.cidata.platform.flink.outline.module.operator.BSql.process(BSql.java:21) at com.ci123.cidata.platform.flink.common.framework.base.LinearModule.processMany(LinearModule.java:15) at com.ci123.cidata.platform.flink.common.framework.base.SubMultiDataModule.processMany(SubMultiDataModule.java:33) at com.ci123.cidata.platform.flink.common.framework.base.MultiDataModule.process(MultiDataModule.java:33) at com.ci123.cidata.platform.flink.common.framework.base.Job.createTopology(Job.java:121) at com.ci123.cidata.platform.flink.common.framework.base.Job.start(Job.java:37) at com.ci123.cidata.platform.flink.Main.lambda$main$2(Main.java:14) at com.ci123.cidata.platform.flink.util.Parameters.execute(Parameters.java:51) at com.ci123.cidata.platform.flink.Main.main(Main.java:11) Caused by: org.apache.calcite.sql.parser.SqlParseException: Non-query expression encountered in illegal context at org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.convertException(FlinkSqlParserImpl.java:368) at org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.normalizeException(FlinkSqlParserImpl.java:167) at org.apache.calcite.sql.parser.SqlParser.handleException(SqlParser.java:147) at org.apache.calcite.sql.parser.SqlParser.parseQuery(SqlParser.java:162) at org.apache.calcite.sql.parser.SqlParser.parseStmt(SqlParser.java:187) at org.apache.flink.table.calcite.FlinkPlannerImpl.parse(FlinkPlannerImpl.scala:95) ... 12 more