腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
2
回答
如何在应用程序模式下将java参数传递给
Flink
作业工件
、
、
我刚刚将
Flink
从版本1.10升级到1.11。在1.11中,
Flink
提供了新功能,用户可以在Kubernetes上以应用程序模式部署作业。https://ci.apache.org/projects/
flink
/
flink
-docs-release-1.11/ops/deployment/kubernetes.html#deploy-session-cluster在V1.10中,我们启动
Flink
K8s
浏览 74
提问于2020-09-02
得票数 1
回答已采纳
1
回答
K8s
上
Flink
的最新稳定版本
我有
Flink
1.12,我正在使用Yarn集群进行部署。我想迁移到
K8s
,但首先我想升级到在
K8s
上稳定的最新版本。在
K8s
上稳定的最新
Flink
版本是什么?
浏览 2
提问于2021-10-13
得票数 0
1
回答
如何处理
flink
管理和
k8s
管理
、
、
、
我正在考虑使用
K8s
部署
Flink
。我是
Flink
的新手,有一个简单的问题: 说我使用
K8s
来管理码头工人并将TaskManager部署到码头工人中。据我的理解,
K8s
可以在它失败时重新启动一个对接器,当它失败时可以由
Flink
重新启动一个任务。如果任务在停靠器容器中运行,而容器由于某种原因突然失败,在
Flink
视图中,任务失败,因此应该重新启动任务,而在
K8s
视图中,容器失败,因此应该重新启动对接器。
浏览 3
提问于2020-05-12
得票数 0
回答已采纳
1
回答
Kubernetes中的
Flink
。如何将提交作业步骤添加到jobmanager
flink
docker?
、
、
、
、
我在
K8s
中使用
Flink
。一切正常,但是当jobmanager启动时,我必须手动提交jar。在这种情况下,如果JM关闭,
K8s
将启动新的pod并重新提交作业。 我说的对吗?有没有人为
flink
做了这样的docker改变?
浏览 46
提问于2018-07-27
得票数 0
回答已采纳
1
回答
Kubernetes中的
Flink
会话集群和作业提交
、
我们的团队在我们的
K8S
集群中设置了一个
Flink
会话集群。我们选择
Flink
会话集群而不是工作集群,因为我们有许多不同的
Flink
作业,因此我们希望将
Flink
的开发和部署与我们的作业分离开来。我们的
Flink
设置包含: 我们在单独的存储库中开发作业,并在代码合并时部署到
Flink
集群。现在,我们
浏览 0
提问于2020-02-27
得票数 1
回答已采纳
1
回答
K8 HA模式下的
Flink
隔离错误
、
flink
-dist_2.12-1.12.1.jar:1.12.1]at akka.actor.ActorCell.invoke(ActorCell.scala:561) ~[
flink
-dist(ForkJoinWorkerThread.java:107) [
flink
-dist_2.12-1.1
浏览 232
提问于2021-02-16
得票数 0
回答已采纳
1
回答
如何使
Flink
任务管理器在
K8s
上运行
、
、
我使用以下命令在本机
K8s
上使用会话模式创建了一个
Flink
集群:基于。 我能够向集群提交作业并查看
Flink
UI。但是,我注意到,
Flink
只在作业提交时创建一个任务管理器结荚,并在作业完成后立即删除它。因此,是否有一种方法可以让任务管理器始终使用
K8s
Flink
部署来运行,从而减少作业启动
浏览 10
提问于2022-08-30
得票数 1
回答已采纳
1
回答
基于Kubernetes的Apache部署-可用性和可伸缩性
、
、
我希望使用同样的方法来部署我的一些
Flink
作业。
Flink
作业是关键的-有些作业是无状态的,它们处理每一个数据(准确地说是一次),有些作业是有状态的,可以在流中查找模式或对时间作出反应。没有作业能够容忍长时间的停机或频繁的关闭(因为编程错误,
Flink
退出的方式)。
Flink
pod可以复制多个吗
浏览 0
提问于2020-02-13
得票数 3
1
回答
如何扩大/缩小正在运行的
Flink
集群?
我正在对库伯奈特斯进行弗林克调查。我想如果我更新了TaskManager部署的副本,Kubernetes会为我增加/减少TM的数量,但我不确定这是否是我所需要做的全部。我还需要做些什么来使这份工作适应更多/更少的TMs吗?
浏览 3
提问于2019-11-10
得票数 1
回答已采纳
1
回答
如何在
K8s
上自动缩放
Flink
状态函数
、
、
我当前的
Flink
应用程序 我的有状态函数是
Flink
remote services,也就是说,它们是常规的
k8s
services。只有当http请求来自
Flink
的工作人
浏览 54
提问于2022-01-26
得票数 0
1
回答
Kubernetes上的
Flink
JobManager HA
JobManager HA上的最新
Flink
1.9 doc仅涵盖单机版和纱线版。我正在寻找如何在Kubernetes上启用HA。
浏览 49
提问于2020-01-08
得票数 1
1
回答
在Kubernetes中扩展Apache
Flink
、
我的
Flink
流媒体工作在当地的Kubernetes中启动和运行。作业从Kafka主题中读取,对其进行一些(无状态)计算,并将其写回另一个Kafka主题。作业的检查点保存在S3中。
Flink
的命令行工具在单荚(副本)中部署作业,那么如何增加副本以并行地增加对数据的操作&作业的吞吐量?
浏览 21
提问于2022-08-01
得票数 0
1
回答
即使在PerJob部署模式下完成作业执行后,TaskManagers仍处于运行状态
、
我正在尝试使用docker-compose进行
Flink
Per-Job部署。./ ports: command: standalone-job --job-classnamecom.organization.BatchJob - | jobmanager.rpc.address: jobm
浏览 37
提问于2020-08-10
得票数 0
1
回答
如何在删除
flink
jobmanager之前删除rocksdb(
flink
state)文件?
、
我想在删除
flink
作业群集之前/之后删除所有rocksdb文件。我们在
K8s
上部署了
flink
作业。我们将每个作业集群的状态存储在rocksdb上。
浏览 39
提问于2020-02-21
得票数 0
回答已采纳
1
回答
在
K8S
上为更新策略执行rollingUpdate时,
Flink
的恢复机制是什么?
、
我想知道在
k8s
上滚动更新重新启动作业时,
Flink
中的检查点或保存点的恢复过程。我
浏览 3
提问于2022-10-13
得票数 0
回答已采纳
2
回答
连接-6\f25
Flink
FLIP-6 \f6的-6\f25 ResourceManager -6\f6启动新的-6\f25“会话作业”-6\f6
、
、
我希望使用会话作业创建一个新的
k8s
部署;并在
flink
-conf.yaml中使用如下配置部署一个taskmanager jobmanager.rpc.address: analytics-jobkind: Service name: analytics-job type: ClusterIP: 30025 port: 8081 # nodePort: 300
浏览 14
提问于2019-04-26
得票数 1
回答已采纳
1
回答
用户"system:serviceaccount:default:
flink
“无法在集群范围内列出API组中的资源”节点“
、
我试图在一个
k8s
荚中调用
k8s
api。但遇到以下权限问题:apiVersion: v1metadata:---apiVersion: rbac.authoriza
浏览 21
提问于2021-10-12
得票数 2
回答已采纳
2
回答
Flink
SQL client:选择'hello‘引发的[错误]无法执行SQL语句
、
我正在跟踪
Flink
。打开
Flink
SQL客户端看起来很好,但是SELECT 'hello world'不能工作。$ /data/apache/
flink
/
flink
-1.12.0/bin/sql-client.sh embedded SLF4J: Class path contains multiple SLF4JSLF4J: Found binding in [jar:file:/data/apache/<
浏览 14
提问于2021-03-26
得票数 1
回答已采纳
2
回答
运行Apache
Flink
作业时
K8s
集群内存减少
、
、
我们正尝试在
K8s
集群上部署apache
Flink
作业,但我们注意到一个奇怪的行为,当我们开始作业时,任务管理器内存以分配的内存开始,在我们的例子中是3 GB。这种非常低的内存经常导致作业由于任务管理器心跳异常而终止,即使在尝试查看
Flink
仪表板上的日志或执行作业的过程时也是如此。
flink
-conf.yaml: |+ blob.server.port: 6124m
浏览 1
提问于2020-07-04
得票数 2
1
回答
启动新
Flink
作业时“无法分配内存”
、
我们正在3VM集群上运行
Flink
。每个VM有大约40 Go的RAM。每天我们停止一些工作,开始新的工作。我很确定这不是
Flink
的问题,但是有人能告诉我我们在这里做错了什么吗?
浏览 0
提问于2018-11-25
得票数 1
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Apache Flink进阶(四):Flink on Yarn/K8s原理剖析及实践
Flink支持与K8s集成对于流向处理资源优化的应用
Flink基础教程(二):初探Flink
Apache Flink 进阶(六):Flink 作业执行深度解析
《从0到1学习Flink》——Apache Flink 介绍
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券