flink 1.11任务提交的问题
请教下flink 1.11任务提交的问题。如果我的一个作业里既有sql dml提交（executeSQL执行），又通过DataStream.addSink来写出， 通过StreamExecutionEnvironment.execute提交，yarn per-job貌似会提交两个作业。这种情况下，我该如何处理呢？只想提交一个作业。 *来自志愿者整理的flink邮件归档
Flink1.10 history server无法监控 FlinkSQL任务
Flink 1.10 on yarn per job提交方式，如果是java datastream 以及table api开发的应用，能够被jm正常拉取统计信息，但是sql化的job没有办法被历史服务器监控。 使用的sql不完全是官网的，但是是经过转化为datastream，以on yarn per job方式提交到yarn运行的，只是多了个sql解析动作。不能理解 ，为什么历史服务器没有加载j....
flink任务挂掉后自动重启，如何解决？
flink任务一般都是7*24h在跑的，如果挂掉，有没有什么办法自动重启任务？之前都是任务挂掉然后手动再提交一次任务，但是不可能每次挂掉都可以手动重启；另外，如果对于没做checkpoints的任务，可以通过定时脚本监控yarn，如果任务不存在，则重新提交任务，但是，对于做了checkpoints的任务，我们提交的时候就需要指定ck的目录，这个目录都是在变的，那么又该如何让任务挂掉后能自动重启呢....
flink任务挂掉后自动重启，有什么解决方法嘛？
你好，重启策略确实可以解决任务故障重启，但是有的时候（例如集群资源不够），任务会直接被kill掉，我想问的是针对被kill掉的任务，有没有什么方法可以自动重启，特别是带有ck的任务，如果想要自动重启，如何在启动的时候自动去hdfs上获取最新的ck地址呢？*来自志愿者整理的flink
flink集群提交任务挂掉，需要特别的配置吗？
Hi,大家好： 现在我们遇到的场景是这样的,提交任务的时候会报错。我们使用的版本是1.12.1,搭建模式是standalone的。下面是报错信息。 java.lang.OutOfMemoryError: Direct buffer memory. The direct out-of-memory error has occurred. This can mean two things: eit.....
Flink 1.10读取kafka数据，打包jar，提交任务到集群运行测试，遇到问题
我在用Flink 1.10读取kafka数据，本地IDEA环境执行没有问题，将代码编译打包（不是fat jar）到集群上运行测试，执行提示：java.lang.NoClassDefFoundError: org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase问题。 我在Flink 1.10集群的每个节点下的 /lib下....
flink-1.10.0通过run -m yarn-cluster提交任务时异常
各位好， The program finished with the following exception: java.lang.IllegalArgumentException: The given host:port ('yarn-cluster') doesn't contain a valid port at org.apache.flink.util.NetUtils.vali...
Flink读写kafka数据聚集任务失败问题
大家好，请教一下，flink任务读取kafka数据进行聚集操作后将结果写回kafka，flink版本为1.8.0。任务运行一段时间后出现如下异常，之后flink任务异常挂掉，请问一下这个问题该如何解决呢？多谢 2020-02-19 10:45:45,314 ERROR org.apache.flink.runtime.io.network.netty.PartitionRequestQueue.....
Flink任务每运行20天均会发生内部异常是为什么？
麻烦请教大家一个问题。 有三个Flink任务以yarn-per-job模式运行在Flink-1.11.2版本的集群上，均使用RocksDB作为状态后端，数据以增量的方式写入RocksDB，且均配置了状态过期时间。 任务逻辑大致都是通过状态与历史数据进行自关联或双流join，每输入一条数据都会产出等量、1/2或多倍的数据到下游，当数据无法通过状态关联，任务则无法向下游产出数据。 奇怪的是三个...
flink能支持动态增加任务吗？
flink消费一个kafka主题，比如里面有一个字段分为a,b,c,d......，现在有一个需求就是要过滤出字段是a的数据，进行后续操作。写完这个任务提交了过后，过段时间又需要过滤出字段b进行后续操作，后续的操作都是一样的，现在我就要为它在开发一个任务，在提交一次，数据量都不大。但是每提交一次都会耗费资源。以后说不定还会要过滤c,d,e....有什么好办法解决这个问题吗 *来自志愿者整理的f.....
本页面内关键词为智能算法引擎基于机器学习所生成，如有任何问题，可在页面下方点击"联系我们"与我们沟通。
实时计算 Flink版更多任务相关
- 实时计算 Flink版控制台任务
- 实时计算 Flink版任务全量
- 实时计算 Flink版任务作业
- 实时计算 Flink版任务savepoint
- 实时计算 Flink版全量增量同步任务
- 实时计算 Flink版检查任务
- 实时计算 Flink版增量同步任务
- 实时计算 Flink版全量任务
- 实时计算 Flink版任务重启
- 实时计算 Flink版checkpoint任务
- 实时计算 Flink版任务报错
- 实时计算 Flink版yarn任务
- 实时计算 Flink版模式任务
- 实时计算 Flink版产品任务
- 任务实时计算 Flink版
- 实时计算 Flink版mysql任务
- 实时计算 Flink版任务运行
- 实时计算 Flink版任务yarn
- 实时计算 Flink版任务checkpoint
- 实时计算 Flink版任务异常
- 实时计算 Flink版任务日志
- 实时计算 Flink版任务内存
- 实时计算 Flink版集群任务
- 实时计算 Flink版运行任务
- 实时计算 Flink版版本任务
- 实时计算 Flink版任务设置
- 实时计算 Flink版任务集群
- 实时计算 Flink版任务配置
- 实时计算 Flink版k8s任务
- 实时计算 Flink版报错任务
实时计算 Flink版您可能感兴趣
- 实时计算 Flink版代码
- 实时计算 Flink版系统
- 实时计算 Flink版b站
- 实时计算 Flink版云原生
- 实时计算 Flink版实践
- 实时计算 Flink版CDC
- 实时计算 Flink版kafka
- 实时计算 Flink版数据链路
- 实时计算 Flink版湖仓
- 实时计算 Flink版湖仓一体
- 实时计算 Flink版数据
- 实时计算 Flink版SQL
- 实时计算 Flink版mysql
- 实时计算 Flink版报错
- 实时计算 Flink版同步
- 实时计算 Flink版flink
- 实时计算 Flink版实时计算
- 实时计算 Flink版版本
- 实时计算 Flink版oracle
- 实时计算 Flink版表
- 实时计算 Flink版配置
- 实时计算 Flink版产品
- 实时计算 Flink版Apache
- 实时计算 Flink版设置
- 实时计算 Flink版作业
- 实时计算 Flink版模式
- 实时计算 Flink版数据库
- 实时计算 Flink版运行
- 实时计算 Flink版连接
- 实时计算 Flink版checkpoint
