我刚刚将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
回答已采纳
我有Flink 1.12，我正在使用Yarn集群进行部署。我想迁移到K8s，但首先我想升级到在K8s上稳定的最新版本。在K8s上稳定的最新Flink版本是什么？
浏览 2提问于2021-10-13得票数 0
1回答
我正在考虑使用K8s部署Flink。我是Flink的新手，有一个简单的问题：
说我使用K8s来管理码头工人并将TaskManager部署到码头工人中。据我的理解，K8s可以在它失败时重新启动一个对接器，当它失败时可以由Flink重新启动一个任务。如果任务在停靠器容器中运行，而容器由于某种原因突然失败，在Flink视图中，任务失败，因此应该重新启动任务，而在K8s视图中，容器失败，因此应该重新启动对接器。
浏览 3提问于2020-05-12得票数 0
回答已采纳
我在K8s中使用Flink。一切正常，但是当jobmanager启动时，我必须手动提交jar。在这种情况下，如果JM关闭，K8s将启动新的pod并重新提交作业。
我说的对吗？有没有人为flink做了这样的docker改变？
浏览 46提问于2018-07-27得票数 0
回答已采纳
我们的团队在我们的K8S集群中设置了一个Flink会话集群。我们选择Flink会话集群而不是工作集群，因为我们有许多不同的Flink作业，因此我们希望将Flink的开发和部署与我们的作业分离开来。我们的Flink设置包含：
我们在单独的存储库中开发作业，并在代码合并时部署到Flink集群。现在，我们
浏览 0提问于2020-02-27得票数 1
回答已采纳
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回答
我使用以下命令在本机K8s上使用会话模式创建了一个Flink集群：基于。
我能够向集群提交作业并查看Flink UI。但是，我注意到，Flink只在作业提交时创建一个任务管理器结荚，并在作业完成后立即删除它。因此，是否有一种方法可以让任务管理器始终使用K8s Flink部署来运行，从而减少作业启动
浏览 10提问于2022-08-30得票数 1
回答已采纳
我希望使用同样的方法来部署我的一些Flink作业。Flink作业是关键的-有些作业是无状态的，它们处理每一个数据(准确地说是一次)，有些作业是有状态的，可以在流中查找模式或对时间作出反应。没有作业能够容忍长时间的停机或频繁的关闭(因为编程错误，Flink退出的方式)。
Flink pod可以复制多个吗
浏览 0提问于2020-02-13得票数 3
我正在对库伯奈特斯进行弗林克调查。我想如果我更新了TaskManager部署的副本，Kubernetes会为我增加/减少TM的数量，但我不确定这是否是我所需要做的全部。我还需要做些什么来使这份工作适应更多/更少的TMs吗？
浏览 3提问于2019-11-10得票数 1
回答已采纳
1回答
我当前的Flink应用程序
我的有状态函数是Flink remote services，也就是说，它们是常规的k8s services。只有当http请求来自Flink的工作人
浏览 54提问于2022-01-26得票数 0
JobManager HA上的最新Flink 1.9 doc仅涵盖单机版和纱线版。我正在寻找如何在Kubernetes上启用HA。
浏览 49提问于2020-01-08得票数 1
我的Flink流媒体工作在当地的Kubernetes中启动和运行。作业从Kafka主题中读取，对其进行一些(无状态)计算，并将其写回另一个Kafka主题。作业的检查点保存在S3中。Flink的命令行工具在单荚(副本)中部署作业，那么如何增加副本以并行地增加对数据的操作&作业的吞吐量？
浏览 21提问于2022-08-01得票数 0
我正在尝试使用docker-compose进行Flink Per-Job部署。./ ports: command: standalone-job --job-classnamecom.organization.BatchJob - | jobmanager.rpc.address: jobm
浏览 37提问于2020-08-10得票数 0
我想在删除flink作业群集之前/之后删除所有rocksdb文件。我们在K8s上部署了flink作业。我们将每个作业集群的状态存储在rocksdb上。
浏览 39提问于2020-02-21得票数 0
回答已采纳
我想知道在k8s上滚动更新重新启动作业时，Flink中的检查点或保存点的恢复过程。我
浏览 3提问于2022-10-13得票数 0
回答已采纳
我希望使用会话作业创建一个新的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
回答已采纳
我试图在一个k8s荚中调用k8s api。但遇到以下权限问题：apiVersion: v1metadata:---apiVersion: rbac.authoriza
浏览 21提问于2021-10-12得票数 2
回答已采纳
我正在跟踪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
回答已采纳
我们正尝试在K8s集群上部署apache Flink作业，但我们注意到一个奇怪的行为，当我们开始作业时，任务管理器内存以分配的内存开始，在我们的例子中是3 GB。这种非常低的内存经常导致作业由于任务管理器心跳异常而终止，即使在尝试查看Flink仪表板上的日志或执行作业的过程时也是如此。flink-conf.yaml: |+ blob.server.port: 6124m
浏览 1提问于2020-07-04得票数 2
我们正在3VM集群上运行Flink。每个VM有大约40 Go的RAM。每天我们停止一些工作，开始新的工作。我很确定这不是Flink的问题，但是有人能告诉我我们在这里做错了什么吗？
浏览 0提问于2018-11-25得票数 1
云服务器
ICP备案
云直播
即时通信 IM
对象存储
腾讯云开发者
