阿里云支持与服务

分享阿里云全球技术服务部(GTS)团队最佳实践、经典案例与故障排查。

作为全球云计算的领先者,阿里云为全球230万企业提供着云计算服务,服务范围覆盖200多个国家和地区。我们致力于为企业、政府等组织机构提供安全可靠的云计算服务,给用户带来极速愉悦的服务体验。

1

回答

阿里云服务支持 评论 0

org.apache.flink.table.sqlserver.utils.SqlValidationException: A sequence of multiple statements to execute is supported if the last statement is a 'SELECT' statement or 'INSERT INTO' statement or 'CREATE TABLE IF NOT EXISTS ... AS TABLE' statement or 'CREATE DATABASE IF NOT EXISTS ... AS DATABASE' statement or 'AUTO OPTIMIZE TABLE|DATABASE' statements or multiple 'INSERT INTO' or 'CREATE TABLE IF NOT EXISTS ... AS TABLE' or 'CREATE DATABASE IF NOT EXISTS ... AS DATABASE' statements wrapped in a 'BEGIN STATEMENT SET' block and all other statements are CREATE TEMPORARY TABLE|VIEW|[SYSTEM] FUNCTION, 'SHOW', DESCRIBE, 'USE' statements. at

org.apache.flink.table.sqlserver.utils.SqlValidateUtils.validateSqlScript(SqlValidateUtils.java:103) at

org.apache.flink.table.sqlserver.execution.OperationExecutorImpl.validateAndGeneratePlan(OperationExecutorImpl.java:410) at

org.apache.flink.table.sqlserver.execution.DelegateOperationExecutor.lambda$validateAndGeneratePlan$28(DelegateOperationExecutor.java:251) at java.security.AccessController.doPrivileged(Native Method) at

javax.security.auth.Subject.doAs(Subject.java:422) at

org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1729) at

org.apache.flink.table.sqlserver.context.SqlServerSecurityContext.runSecured(SqlServerSecurityContext.java:72) at

org.apache.flink.table.sqlserver.execution.DelegateOperationExecutor.wrapClassLoader(DelegateOperationExecutor.java:298) at

org.apache.flink.table.sqlserver.execution.DelegateOperationExecutor.lambda$wrapExecutor$34(DelegateOperationExecutor.java:319) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at

java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1147) at

java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:622) at

java.lang.Thread.run(Thread.java:834)

报错原因:

①在DDL和DML同在一个文本中提交运行时,DDL没有声明为CREATE TEMPORARY TABLE。

②多个 DML 语句没有放到 'BEGIN STATEMENT SET;'及'END;'中间。

解决方案:

①在DDL和DML同在一个文本中提交运行时,DDL需要声明为CREATE TEMPORARY TABLE,而不是声明为CREATE TABLE。示例如下:CREATE TEMPORARY TABLE source_input/CREATE TEMPORARY VIEW source_input

②多个 DML 语句需要放到'BEGIN STATEMENT SET;'及'END;'中间,示例如下: BEGIN STATEMENT SET; INSERT INTO printSink SELECT b1 FROM datagenSource; INSERT INTO printSink2 SELECT b2 FROM datagenSource; END;

阿里云服务支持 评论 0

Flink控制台进不去/服务不可用排查步骤:

1、可以看下产品最新公告,对应时间点是否有进行发布,公告地址

2、检查SLB是否欠费,如果SLB欠费7天会被释放,导致Flink控制台不可用,只能新建集群做作业迁移。之前集群作业需要获取可以通过SDK调用GetDeployment接口的方式获取到,详情参考文档

3、可能是后端集群压力比较大,可以稍后再尝试访问。

阿里云服务支持 评论 0
阿里云服务支持 评论 0
阿里云服务支持 评论 0

1

回答

阿里云服务支持 评论 0

1

回答

阿里云服务支持 评论 0

2

回答

阿里云服务支持 评论 0
阿里云服务支持 评论 0
阿里云服务支持 评论 0

1

回答

阿里云服务支持 2022-12-20 214浏览量 回答数 1
阿里云服务支持 评论 0
阿里云服务支持 评论 0

公告

凝聚阿里云多年服务经验,携手合作伙伴与业界专家,匠心打造云服务技术共享!

展开