阿里云 blink 相关错误码问题解决
1、使用阿里云的flink平台是,有时重启任务会有shell cmd的报错信息,错误代码如下:
Submit job for the [21] times,last error occurred at [Sun Jan 10 18:36:31 CST 2021],lastErrorMessage is as follows:run instance failed, BLINK error: bayes submit job failed.job name:[test_kafka], brs errorCode:[30013], brs errorMessage:code:[30013], brief info:[error occur while run app], context info:[details:
>>>>>
shell cmd execute failed2021-01-10 18:36:26,104 INFO org.apache.flink.yarn.cli.FlinkYarnSessionCli - No path for the flink jar passed. Using the location of class org.apache.flink.yarn.YarnClusterDescriptor to locate the jar
2021-01-10 18:36:26,104 INFO org.apache.flink.yarn.cli.FlinkYarnSessionCli - No path for the flink jar passed. Using the location of class org.apache.flink.yarn.YarnClusterDescriptor to locate the jar
2021-01-10 18:36:26,105 INFO org.apache.flink.yarn.cli.FlinkYarnSessionCli - org.apache.commons.cli.CommandLine@7fd50002
2021-01-10 18:36:26,105 INFO org.apache.flink.yarn.cli.FlinkYarnSessionCli - org.apache.commons.cli.CommandLine@7fd50002
org.apache.commons.cli.CommandLine@7fd50002------------------------------------------------------------The program finished with the following exception:org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:610)at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:469)at org.apache.flink.client.program.OptimizerPlanEnvironment.getOptimizedPlan(OptimizerPlanEnvironment.java:94)at org.apache.flink.client.program.PackagedProgramUtils.createJobGraph(PackagedProgramUtils.java:81)at org.apache.flink.client.program.PackagedProgramUtils.createJobGraph(PackagedProgramUtils.java:134)at org.apache.flink.client.cli.CliFrontend.runProgram(CliFrontend.java:253)at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:217)at org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:1075)at org.apache.flink.client.cli.CliFrontend.lambda$main$9(CliFrontend.java:1151)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:1682)at org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1151)
Caused by: com.alibaba.blink.launcher.autoconfig.UnexpectedConfigurationException:
************
ERR_ID:CLI-00000001
CAUSE:AutoConf: an error occurred while applying the resource configuration file.Node or edge number in stream graph and json file not matched, please generate a new json.
ACTION:The reason may be that the content of the SQL has been modified or the blink version number has been changed.Please regenerate the resource configuration file.
DETAIL:************at com.alibaba.blink.launcher.autoconfig.StreamGraphConfigurer.checkValid(StreamGraphConfigurer.java:58)at com.alibaba.blink.launcher.autoconfig.StreamGraphConfigurer.configure(StreamGraphConfigurer.java:45)at com.alibaba.blink.launcher.JobLauncher.execute(JobLauncher.java:663)at com.alibaba.blink.launcher.JobLauncher.runStream(JobLauncher.java:545)at com.alibaba.blink.launcher.JobLauncher.main(JobLauncher.java:159)at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)at java.lang.reflect.Method.invoke(Method.java:498)at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:593)... 13 more
<<<<<], cause:shell cmd execute failed2021-01-10 18:36:26,104 INFO org.apache.flink.yarn.cli.FlinkYarnSessionCli - No path for the flink jar passed. Using the location of class org.apache.flink.yarn.YarnClusterDescriptor to locate the jar
2021-01-10 18:36:26,104 INFO org.apache.flink.yarn.cli.FlinkYarnSessionCli - No path for the flink jar passed. Using the location of class org.apache.flink.yarn.YarnClusterDescriptor to locate the jar
2021-01-10 18:36:26,105 INFO org.apache.flink.yarn.cli.FlinkYarnSessionCli - org.apache.commons.cli.CommandLine@7fd50002
2021-01-10 18:36:26,105 INFO org.apache.flink.yarn.cli.FlinkYarnSessionCli - org.apache.commons.cli.CommandLine@7fd50002
org.apache.commons.cli.CommandLine@7fd50002------------------------------------------------------------The program finished with the following exception:org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:610)at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:469)at org.apache.flink.client.program.OptimizerPlanEnvironment.getOptimizedPlan(OptimizerPlanEnvironment.java:94)at org.apache.flink.client.program.PackagedProgramUtils.createJobGraph(PackagedProgramUtils.java:81)at org.apache.flink.client.program.PackagedProgramUtils.createJobGraph(PackagedProgramUtils.java:134)at org.apache.flink.client.cli.CliFrontend.runProgram(CliFrontend.java:253)at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:217)at org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:1075)at org.apache.flink.client.cli.CliFrontend.lambda$main$9(CliFrontend.java:1151)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:1682)at org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1151)
Caused by: com.alibaba.blink.launcher.autoconfig.UnexpectedConfigurationException:
************
ERR_ID:CLI-00000001
CAUSE:AutoConf: an error occurred while applying the resource configuration file.Node or edge number in stream graph and json file not matched, please generate a new json.
ACTION:The reason may be that the content of the SQL has been modified or the blink version number has been changed.Please regenerate the resource configuration file.
DETAIL:************at com.alibaba.blink.launcher.autoconfig.StreamGraphConfigurer.checkValid(StreamGraphConfigurer.java:58)at com.alibaba.blink.launcher.autoconfig.StreamGraphConfigurer.configure(StreamGraphConfigurer.java:45)at com.alibaba.blink.launcher.JobLauncher.execute(JobLauncher.java:663)at com.alibaba.blink.launcher.JobLauncher.runStream(JobLauncher.java:545)at com.alibaba.blink.launcher.JobLauncher.main(JobLauncher.java:159)at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)at java.lang.reflect.Method.invoke(Method.java:498)at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:593)... 13 more
2、是因为改了执行计划,没有重新获取执行计划导致的,需要重新执行 “ 放弃当前配置” ==》“重新获取配置信息”==》“应用当前配置” 来解决这个问题
3、在执行监控的过程中,也发现某个流任务的停止和启动,也会影响下游流任务的延迟。
阿里云 blink 相关错误码问题解决相关推荐
- 阿里云ACP云计算错题集1-40
大家都来考个阿里云ACP认证吧,这里是阿里云ACP云计算错题集1-40,powered by zhengkai.blog.csdn.net. 1.在阿里云上创建专有网络VPC时,VPC会自动为用户创建 ...
- 阿里云视频点播报错Forbidden.RAM
阿里云视频点播报错Forbidden.RAM 问题描述 问题原因 解决方案 问题描述 在测试阿里云视频点播vod实现后台视频上传时报错,如下图: 问题原因 原因是没有为RAM用户授权, 为RAM用户授 ...
- 使用socket通信本地电脑与阿里云服务器报错connection time out及解决方案(java语言)
使用socket通信本地电脑与阿里云服务器报错connection time out及解决方案(java语言) 参考文章: (1)使用socket通信本地电脑与阿里云服务器报错connection t ...
- 阿里云ACP云计算错题集71-100
每天学一点阿里云ACP认证,这里是ACP错题集,今天先来复习几个概念:伸缩模式.伸缩组.伸缩配置.伸缩规则.伸缩活动. by Moshow郑锴(大狼狗) zhengkai.blog.csdn.net ...
- 阿里云视频点播相关代码
官网:阿里云登录 - 欢迎登录阿里云,安全稳定的云计算服务平台 依赖 版本: <aliyun-java-sdk-core.version>4.3.3</aliyun-java-sdk ...
- 阿里云ACP云计算错题集121-140
每天学一点阿里云ACP认证,这里是ACP错题集.温故而知新,从错题入手,可以更好理解出题点.难点. by zhengkai.blog.csdn.net 121.当您发现无法将指定的阿里云的块存储挂载到 ...
- 阿里云OSS 203 Non-Authoritative Information问题解决
问题描述: 203 Non-Authoritative Information 问题分析: 1.跨域问题,阿里云OSS没有配置跨域规则. 解决办法请参考以下博客. 阿里云OSS No 'Access- ...
- 阿里云ACP云计算错题集101-120
每天学一点阿里云ACP认证,这里是ACP错题集.温故而知新,从错题入手,可以更好理解出题点.难点. by zhengkai.blog.csdn.net 101.A公司基于阿里云服务构建了一套销售管理平 ...
- 阿里云服务器相关操作
1.centos8实例 2.连接阿里云服务器 使用xshell连接: 3.安装 jdk8 下载 jdk8 下载地址:https://www.oracle.com/java/technologies/d ...
最新文章
- java list多字段排序_java中list通过多条件排序
- API 版本控制的几种方式
- swoole mysql 并发_Swoole4 如何打造高并发的PHP7协程Mysql连接池?
- Linux中强大的输入输出重定向和管道
- 归纳一下:C#线程同步的几种方法
- 技术分享连载(二十七)
- 联邦学习产品及算法运行机制简介
- Docker 开启镜像加速 (网易和阿里)
- Moodle安装教程以及phpMyAdmin无法访问解决
- 解决vbox挂载VBoxGuestAdditions失败
- 网店系统SHOP++、V5shop、shopex全程分析比较
- 每日学点python之六(列表与元组)
- MySQL InnoDB Cluster部署方案与实践
- 关于google地图的一些使用
- 互联网创业必备工具盘点
- 【空间转录组】MIA分析
- python语法基础-cPickle.dump使用
- 2.光栅图形显示技术
- 【Joy of Cryptography 读书笔记】Chapter 2 可证明安全(Provable Security)基础
- oracle ocp考题,Oracle OCP 12c 062最新考试题库_062考试原题_OCP 062考试真题-优技培训(CUUG)...