问答 2020-07-16 来自:开发者社区

请教一下,大家都是怎么对flink作业做监控的?我是想监控作业的运行状态,如果job挂 #Flink

请教一下,大家都是怎么对flink作业做监控的?我是想监控作业的运行状态,如果job挂了,然后进行自动重启 #Flink

问答 2020-06-29 来自:开发者社区

如何保证在一个job。执行完1,再去执行2?#Flink

1、A(Kafka)->B(mysql) 2、A(Kafka) leftjoin B(mysql) 如何保证在一个job。执行完1,再去执行2?#Flink

问答 2020-06-10 来自:开发者社区

有做过flink job 在两个job之间进行数据交互的呢?一般都怎样做的呢?#Flink

有做过flink job 在两个job之间进行数据交互的呢?一般都怎样做的呢?#Flink

问答 2020-06-03 来自:开发者社区

flink 通过 rest api submit job 的时候 如果 post 请#Flink

flink 通过 rest api submit job 的时候 如果 post 请求 body 过长 会被 截断 的现象 有人遇到过吗? #Flink

问答 2020-05-26 来自:开发者社区

在standalone启动job的时候报错,有大佬帮忙看一下吗?HADOOP_CONF #Flink

在standalone启动job的时候报错,有大佬帮忙看一下吗?HADOOP_CONF_DIR已经在环境变量中了。也不得行,看不到具体什么原因不能创建 #Flink

问答 2020-05-25 来自:开发者社区

当flink job中存在两个sink分别为mysql和phoenix。在初始化获取jd#Flink

当flink job中存在两个sink分别为mysql和phoenix。在初始化获取jdbc连接时遇到以下情况,Class.forName(driver);无法加载类,陷入阻塞状态。若去掉两者中的一个则能正常加载。代码如下:#Flink

问答 2020-05-18 来自:开发者社区

有基于flink做实时计算平台的吗,针对flink job打印大量日志,这些日志的存储 #Flink

有基于flink做实时计算平台的吗,针对flink job打印大量日志,这些日志的存储,加载和检索有什么好的技术方案吗? #Flink

问答 2020-05-18 来自:开发者社区

做一个机器学习任务也就是除了alink还得需要aiflow提交alink的job吗? #Flink

做一个机器学习任务也就是除了alink还得需要aiflow提交alink的job吗? #Flink

问答 2020-01-10 来自:开发者社区

EMR提交flink job jar冲突

项目中用到携程的Apollo框架,依赖guava-1.19.0, EMR环境使用的是 guava-1.11.0 。由于guava-1.16.0以后变化很大,新增了方法。现在启动flink job 去读取 hadoop classpath下的guava包,导致任务运行不起来,怎么解决呢

问答 2019-11-28 来自:开发者社区

各位大佬,请假个问题,Run a single Flink job on YARN 我采用这种模式提

各位大佬,请假个问题,Run a single Flink job on YARN 我采用这种模式提交任务,出现无法找到 开启 HA 的ResourceManager Failed to connect to server: xxxxx:8032: retries get failed due to exceeded maximum allowed retries number: 0 有大佬遇到....

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注