本文汇总了Flink全托管常见问题与解决方案。

Flink全托管集群如何访问公网?

  • 背景说明
    Flink全托管集群默认不具备访问公网的能力,但阿里云提供的NAT网关可以实现VPC网络与公网网络互通,以满足部分Flink全托管集群用户通过UDX或Datastream代码访问公网的需求。背景说明
  • 解决方案
    通过在VPC中创建NAT网关,并创建SNAT条目,将Flink全托管集群所在的交换机绑定至弹性公网IP(EIP),即可通过EIP访问公网。具体配置方法请参见:

如何访问跨VPC里的存储资源?

您可以通过以下几种方式跨VPC访问存储资源:
  • 提交工单,产品名称选择VPC,要求通过高速通道或其它产品打通网络,但是此种方式需要付费。
  • 使用VPN网关建立VPC到VPC的VPN连接,详情请参见建立VPC到VPC的连接
  • 退掉和Flink全托管不同VPC的存储服务后,重新购买一个与Flink全托管相同VPC的存储服务。
  • 释放Flink全托管服务后,重新购买一个和存储服务相同VPC的Flink全托管服务。
  • 开通Flink全托管的公网访问能力,通过公网访问存储服务。Flink全托管集群默认不具备访问公网的能力,如有需求,详情请参见Flink全托管集群如何访问公网?
    说明 因为在延迟性方面,公网不如内网,所以不推荐使用此方式。

如何查找引发告警的作业?

告警事件中包含JobID和DeploymentID信息,但是由于作业Failover后导致JobID发生变化,因此您需要通过Deployment ID查找是哪个作业报错。目前,Flink全托管控制台上暂无Deployment ID信息,您需要在作业的URL中获取Deployment ID信息。Deployment ID

如何查看工作空间ID等信息?

在管理控制台目标工作空间名称右侧,单击其他 > 工作空间详情工作空间详情

如何在OSS控制台上传JAR包?

  1. 在Flink全托管控制台上查看当前集群的OSS Bucket。OSS Bucket
    OSS Bucket信息如下图所示。bucket详情
  2. 登录OSS控制台,上传JAR包至目标Bucket的/artifats/namespeace目录下。jar目录
  3. 在Flink全托管控制台左侧导航栏,单击资源上传,查看通过OSS控制台上传的JAR包。查看jar包

SQL作业如何配置Rocksdb Statebackend?

在目标作业详情页面右上角,单击编辑后,在其他配置中,添加如下两行代码后保存生效。
state.backend: rocksdb 
state.backend.incremental: true
详情

报错:undefined

  • 报错详情报错信息
  • 报错原因

    您的JAR包较大。

  • 解决方案

    您可以在OSS 管理控制台上传JAR包。

报错: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. 重启全托管作业。

报错:exceeded quota: resourcequota

  • 报错详情
    作业启动运行事件中报错。报错
  • 报错原因

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

  • 解决方案

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