本文为您介绍实时计算Flink版的SQL常见问题,包括作业开发报错和作业运维报错。

报错:undefined

报错:Object '****' not found

  • 报错详情
    单击运行后,验证报错详情如下。报错详情
  • 报错原因

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

  • 解决方案

    在DDL和DML同在一个文本中提交运行时,DDL需要声明为CREATE TEMPORARY TABLE,而不是声明为CREATE TABLE。

报错:Only a single 'INSERT INTO' is supported

  • 报错详情
    单击运行后,验证报错详情如下。报错详情
  • 报错原因

    多个DML语句没有写在关键语句BEGIN STATEMENT SET;END;之间。

  • 解决方案

    将多个DML语句写在BEGIN STATEMENT SET;END;之间。详情请参见DML数据操作语句(INSERT INTO)

报错:OSSException

  • 报错详情
    新作业启动或已上线作业重启时报错。报错
  • 报错原因

    对象存储OSS开启了版本控制,导致存在大量的Object。

  • 解决方案
    1. OSS管理控制台,关闭版本控制,详情请参见版本控制相关操作
    2. oss://{bucket}/flink-jobs/namespaces/{namespace}/jobs/下的Object全部删除。
      ./ossutil64 rm oss://{bucket}/flink-jobs/namespaces/{namespace}/jobs/ --all-versions -r
      说明
      • 本文以ossutil工具为例,您也可以使用其他方式删除Object。
      • 命令详情参见rm(删除)
    3. 重启Flink全托管作业。

报错:exceeded quota: resourcequota

  • 报错详情
    作业启动过程中报错。报错
  • 报错原因

    当前项目空间资源不足导致作业启动失败。

  • 解决方案

    您需要对项目资源进行资源变配,详情请参见单项目资源变配

报错:Exceeded checkpoint tolerable failure threshold

  • 报错详情
    作业运行过程中报错。详情
  • 报错原因

    未设置任务允许Checkpoint失败的次数,系统默认Checkpoint失败一次就触发一次Failover。

  • 解决方案
    1. 在作业开发页面右侧,单击高级配置
    2. 更多Flink配置文本框,输入如下参数。
      execution.checkpointing.tolerable-failed-checkpoints: num
      您需要设置num值来调整任务允许Checkpoint失败的次数。num需要为0或正整数。如果num为0时,则表示不允许存在任何Checkpoint异常或者失败。

报错:Flink version null is not configured for sql

  • 报错详情
    StatusRuntimeException: INTERNAL: Flink version null is not configured for sql.
  • 报错原因

    系统升级至VVR 4.0.8,导致作业的Flink计算引擎版本信息没有了。

  • 解决方案
    在作业开发页面右侧高级配置面版中,配置正确的Flink计算引擎版本。引擎版本
    说明 如果您需要使用SQL Preview功能,则还需要检查Session集群页面的引擎版本是否选择正确。

报错:java.util.concurrent.CompletionException: java.lang.IllegalArgumentException

  • 报错详情
     Caused by: java.util.concurrent.CompletionException: java.lang.IllegalArgumentException: The bucket name "fakeBucket" is invalid. A bucket name must: 1) be comprised of lower-case characters, numbers or dash(-); 2) start with lower case or numbers; 3) be between 3-63 characters long. 
  • 报错原因

    您在作业高级配置面板的更多Flink配置中,配置了state.backend参数,但未配置对应的state.checkpoints.dir参数。

  • 解决方案
    配置了state.backend参数,必须配置对应的state.checkpoints.dir参数。
    说明 您也可以直接删除state.backend参数。

INFO:org.apache.flink.fs.osshadoop.shaded.com.aliyun.oss

  • 报错详情报错详情
  • 报错原因

    OSS每次创建新目录时,会先检查是否存在该目录,如果不存在,就会报这个INFO信息,但该INFO信息不影响Flink作业运行。

  • 解决方案

    在日志模板中添加<Logger level="ERROR" name="org.apache.flink.fs.osshadoop.shaded.com.aliyun.oss"/>。详情请参见配置作业日志