腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
电子病历上S3的外部检查点
、
、
、
、
我正在尝试为我的
Flink
程序
部署
一个生产集群。我使用的是一个
安装
了
Flink
1.3.2的标准hadoop-core EMR集群,使用YARN来运行它。我尝试下载Hadoop2.7.2二进制文件,并将它们复制到
flink
/libs目录中。所有这些都会导致相同的错误。 有没有人成功地让
Flink
能够在电子病历上写入S3?/
flink
-1.3.2/
flink
-1.3.2-bin-hadoop27-scala_2.11.tgz
浏览 1
提问于2017-09-11
得票数 1
1
回答
Windows 11和Apache
Flink
部署
、
我正试图在我的Windows 11计算机上运行本地
Flink
集群。我按照推荐文档的步骤
安装
了Java和Cygwin。
Flink
似乎从start-cluster.sh脚本开始很好,但是我无法连接到WebUI。在Windows上
部署
Flink
v1.14.3的推荐方法是什么?
浏览 1
提问于2022-01-26
得票数 0
1
回答
基于Kubernetes的Apache
部署
-可用性和可伸缩性
、
、
我使用Kubernetes (Openshift)
部署
许多微服务。我希望使用同样的方法来
部署
我的一些
Flink
作业。
Flink
作业是关键的-有些作业是无状态的,它们处理每一个数据(准确地说是一次),有些作业是有状态的,可以在流中查找模式或对时间作出反应。没有作业能够容忍长时间的停机或频繁的关闭(因为编程错误,
Flink
退出的方式)。 我发现文档大多倾向于将k8s中的
Flink
作业
部署
为Job Cluster。虽然k8s可以重新启动失败的pod,但是
Flink</
浏览 0
提问于2020-02-13
得票数 3
2
回答
如何使用命令在helm 3中显示特定版本并
安装
特定版本的图表
我想使用helm 3
部署
flink
,我希望看到
flink
版本在舵机上,我应该使用什么命令来查看舵机3中的舵机图表版本?我在网上读过文档和搜索过,并尝试过:Error: unknown shorthand flag: 'r' in -rError: failed t
浏览 6
提问于2020-08-19
得票数 0
回答已采纳
1
回答
无法使用
Flink
CLI将流
部署
到Apache
Flink
的HA集群
我可以将流
部署
到Apache的独立
安装
(使用一个JobManager和多个TaskManagers),没有问题:但是,当我运行相同的命令并
部署
到独立的HA集群时,这个命令会引发错误:从
Flink
仪表板
部署
对独立的HA集群很好。当我仅通过<
浏览 7
提问于2016-04-14
得票数 1
回答已采纳
1
回答
kafkastreams -增加更多的处理能力
、
、
我正在开发一个POC,将现有的
Flink
应用程序/拓扑转换为使用KafkaStreams。我的问题是关于
部署
。具体来说,在
Flink
中,可以向
flink
安装
添加"Worker节点“,然后为拓扑添加更多的并行化,以跟上不断增长的数据速率。 如何随着数据速率的增加而增加KStreams容量?
浏览 4
提问于2016-08-17
得票数 3
回答已采纳
1
回答
Flink
和k8s
部署
、
根据
Flink
的文档,我们可以在Kubernetes之上
部署
一个独立的
Flink
集群,使用
Flink
的独立
部署
,或者使用本地Kubernetes
部署
在Kubernetes上
部署
Flink
。文件上说 是因为本地Kubernetes更容易开始,还是因为独立模式是一种遗产?在本机Kubernetes模式中
浏览 7
提问于2022-01-05
得票数 1
1
回答
如何在远程纱线集群上运行
Flink
作业
、
、
我在通过scala API远程
部署
Flink
作业时遇到了一些问题。我想要的是直接使用IDE运行我的作业。ExecutionEnvironment.createRemoteEnvironment("mymaster", 6123, "myjar-with-dependencies.jar") 这不起作用,我确实意识到我并没有用它来声明任何YARN
部署
浏览 21
提问于2017-03-15
得票数 1
回答已采纳
1
回答
嵌入式
Flink
实例的JobManager在哪里?
、
我使用
Flink
(通过Kafka)在服务之间传输消息。
Flink
嵌入在Java应用程序中,每个应用程序都在单独的docker容器中运行。这是我第一次尝试
Flink
,在看完文档后,我仍然觉得我遗漏了一些基本的东西。JobManager在哪里运行?谢谢, 摩西
浏览 1
提问于2017-03-29
得票数 0
1
回答
大状态运算符的
Flink
任务调度
是否有可能影响任务管理器
Flink
将对每个这些操作符实例进行调度?
浏览 0
提问于2018-12-10
得票数 0
回答已采纳
1
回答
在流水线
部署
时自动化AWS EMR集群中
Flink
作业提交的推荐方法
、
、
我是
Flink
和EMR集群
部署
的新手。目前,我们有一个
Flink
作业,我们正在通过
Flink
CLI停止/启动作业命令在AWS EMR集群上手动
部署
它。我想要自动化这个过程(在通过保存点的管道进行的每个
部署
中自动更新
flink
作业jar ),并需要一些关于可以探索的方法的建议。
浏览 3
提问于2022-04-22
得票数 0
1
回答
Kubernetes上的
Flink
JobManager HA
JobManager HA上的最新
Flink
1.9 doc仅涵盖单机版和纱线版。我正在寻找如何在Kubernetes上启用HA。
浏览 49
提问于2020-01-08
得票数 1
2
回答
运行多个
flink
作业时出现问题(在
Flink
群集上)
各位朋友:每个
flink
作业都使用以下内容来运行-> > env.execute("
FLINK
-JOB");>//
浏览 5
提问于2019-02-22
得票数 1
1
回答
为
Flink
开发工作
、
我有来自Kafka的实时数据,我想使用
Flink
进行一些转换。 使作业工件在/opt/
flink<
浏览 5
提问于2022-01-08
得票数 0
回答已采纳
3
回答
州的乐趣是给予org.apache.
flink
.client.program.ProgramInvocationException类加载器。家长-第一模式。额外;
、
/bin/
flink
运行-c -c<?xml version="1.0" encoding="UTF-8"?<archive> <mainClass>org.apache.
flink
.statefun.
flink
.core.StatefulFunctionsJob,org.apache.<em
浏览 4
提问于2020-05-23
得票数 0
1
回答
如何向
Flink
kubernetes操作员
部署
CRD添加标签?
、
、
我
部署
了
Flink
kubernetes操作符,在为“
Flink
deployment”
部署
自定义资源时,我需要向
部署
规范中添加几个元数据标签,因为我们的组织有一个允许few钩子来验证自定义标签,如'app_id‘、'env’等,以便在
部署
对象中。CRD是https:/github.com/apache/
flink
-kubernetes-operator/blob/main/helm
浏览 23
提问于2022-11-07
得票数 0
2
回答
如何在没有DC/OS的Mesos集群上
安装
Flink
?
、
、
我们已经
安装
了带有3个主节点和3个从节点的Apache &马拉松,现在我们正在尝试
安装
没有DC/OS的Apache,就像这里提到的那样。我在这里有几个问题: 如果需要在所有节点上下载
flink
,那么
flink
目录的位置应该是什么,或者如果有任何脚本我可以指定它呢?在主节点上运行“me
浏览 2
提问于2017-09-08
得票数 4
回答已采纳
1
回答
在Yarn上运行
Flink
1.5
我们在hadoop 2.6群集上运行
Flink
1.5.0 Yarn会话。./bin/yarn-session.sh -n 4 -jm 1024 -tm 4096 -qu但是这不会启动任何任务管理器。日志上说
Flink
JobManager是从leader id 000000开始的...在JobManager web界面中也没有任务管理器。当我们向这个jobManager提交一个
flink
作业时,一些任务管理器确实会在执行该作业的web界面上产生。这是从
Flink
1.5.0开始的预期行为吗?以同样的方式
浏览 10
提问于2018-08-21
得票数 0
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
回答
用Presto写S3的
Flink
、
我想使用presto接口和S3从
Flink
1.4.2写到BucketingSink。我按照说明添加了
flink
-
flink
. added s3.s3.access key和s3-秘-key,并将
flink
-s3-fs-presto-1.4.2.jar放在lib文件夹中。(BucketingSink.java:1206) at org.apache.
flink
.streaming.connectors.fs.bucketing.BucketingSink.initFileSystem(BucketingS
浏览 0
提问于2018-03-29
得票数 2
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Apache Flink本地安装及Example运行
安装部署vcenter
Docker 安装部署
Flink 中的应用部署:当前状态与新应用模式
Flink中的应用部署(三):自定义窗口处理
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券