腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(1342)
视频
沙龙
1
回答
如
何在
Apache
flink
中
启动
和
停止
flink
scala-shell
apache-flink
、
scala-shell
如
何在
apache
flink
中
启动
和
停止
flink
scala-shell
我已经使用命令/bin/start- scala -shell.sh local
启动
了
flink
scala shell。
浏览 50
提问于2019-05-22
得票数 0
1
回答
Apache
Flink
Kafka集成
apache-kafka
、
apache-flink
、
flink-streaming
我正在尝试将
Apache
Kafka 2.11-0.10.0.0与
Apache
Flink
1.1.2集成。我正在使用
scala-shell
对其进行测试,并得到以下错误。找不到类org.
apache
.
flink
.streaming.api.checkpoint.CheckpointNotifier 我已经将org.
apache
.
flink
.streaming jar添加到类路径
中
我一直导入到org.
apache
.<e
浏览 13
提问于2016-09-15
得票数 1
回答已采纳
1
回答
Apache
flink
1.6 HA独立群集:群集入口点出现致命错误
apache-flink
我正在尝试设置由2个主节点
和
1个工作节点组成的
Apache
Flink
独立集群。使用
Flink
1.6
和
Zookeeper。要
启动
和
停止
cluster,我使用了
Flink
的1.6文档
中
描述的过程,即,要
启动
cluster,我运行start-zookeeper-quorum.sh,然后运行start-cluster.sh,然后运行stop-cluster.sh来
停止
cluster 在
浏览 24
提问于2018-09-07
得票数 0
1
回答
Hpw将在本地Jconsole JMX控制台上用JMX报告器显示
Flink
指标
jboss
、
yaml
、
wildfly
、
jmx
、
apache-flink
请分享你的想法
和
帮助。 我已经安装了
Apache
通过自制,别名fstart
和
fstop
启动
/
停止
Flink
。基于这个JMX记者linkhttps://ci.
apache
.org/projects/
flink
/
flink
-docs-release-1.4/monitoring/
浏览 3
提问于2018-05-26
得票数 1
回答已采纳
1
回答
Flink
-如何将JVM选项传递给CLI
java
、
apache-flink
、
flink-streaming
我想在我的工作
中
添加一个JVM选项。因此,我在
flink
- line . the
中
添加了以下一行: org.
apache
.
fl
浏览 0
提问于2018-03-01
得票数 0
回答已采纳
1
回答
如何扩大/缩小正在运行的
Flink
集群?
apache-flink
我正在对库伯奈特斯进行弗林克调查。我想如果我更新了TaskManager部署的副本,Kubernetes会为我增加/减少TM的数量,但我不确定这是否是我所需要做的全部。我还需要做些什么来使这份工作适应更多/更少的TMs吗?
浏览 3
提问于2019-11-10
得票数 1
回答已采纳
1
回答
在生产中更新
flink
keyby函数
java
、
deployment
、
streaming
、
apache-flink
、
flink-streaming
我试图在我的产品
flink
作业
中
更新keyby函数,方法是向getKey函数添加一个新的keyby值,例如keyby函数是 value.getTimestampvalue.getTimestamp(), value.isRedirect()我正试图将新任务部署到uat服务器(以确保它在
启动
之前工作),方法是优雅地
停止
作业并使用保存点进行恢复,但是我得到了以下错误: java.lang.Excep
浏览 0
提问于2021-06-16
得票数 0
1
回答
如何处理卡夫卡水槽
中
的异常?
apache-kafka
、
apache-flink
、
flink-streaming
(FlinkKafkaProducerBase.java:373)at org.
apache
.
flink
.streaming.api.operators.AbstractStreamOperator$at org.
apache
.
flink
.streaming.runtime.tasks
浏览 1
提问于2018-09-13
得票数 1
回答已采纳
1
回答
很少有kafka分区没有分配给任何
flink
使用者
java
、
apache-kafka
、
apache-flink
我有一个kafka主题,有15个分区0-14,我正在运行5个并行的
flink
。因此,理想情况下,每个并行
flink
使用者应该分别使用3个分区。但是,即使在多次重启之后,很少有kafka分区不是由任何
flink
工作者订阅的。assign Subscribed to partition(s): topic_name-2, topic_name-3, topic_name-7 从上面的日志
中
可以看出,分区10
和
13已经被2个消费者订阅,而分区1
和
4根本没有被订阅。
Flink
浏览 10
提问于2020-09-08
得票数 1
回答已采纳
1
回答
Flink
文件系统支持
apache-flink
博士说“一个不完整的列表”。我在哪里可以找到一个完整的?
浏览 5
提问于2018-08-08
得票数 0
1
回答
如
何在
apache
-
flink
中
调度作业
apache-flink
我想写一个任务,每24小时后由
apache
flink
触发,然后由
flink
处理。要做到这一点,可能的方法是什么?
flink
是否提供任何作业调度功能?
浏览 10
提问于2018-03-13
得票数 3
2
回答
MapValue在
Flink
中
的应用
apache-flink
、
flink-streaming
、
flink-cep
Value> extends MapValue<K, V> { super();} at org.
apache
.
flink
.util.ReflectionUtil.getSuperTemplateTypes(ReflectionUtil.java:98) at org.
apache
.
flink
.ut
浏览 7
提问于2022-09-07
得票数 0
2
回答
java.util.List
和
java.util.Map的
Flink
序列化
java
、
apache-flink
我的
Flink
管道目前使用一个Pojo,其中包含一些列表
和
映射( Strings),按照 private List<String> myList =// getters + setters...出于性能原因,我想绕过Kryo序列化,因此我禁用了env.getConfig().disableGenericTypes();的通用回退,
如
中所述org.
apache
.
flink
.api.java.typeutils.Pojo
浏览 16
提问于2020-01-18
得票数 3
回答已采纳
1
回答
为什么
Flink
1.4
中
的每个处理槽都使用独立的内核?
hadoop
、
apache-flink
我有一个docker-compose与hadoop big-data-europe
和
Flink
1.10
和
1.4,我试图在单独的容器
中
启动
它们。我使用这个参考YARN Setup,其中有一个示例 示例:发出以下命令,分配10个任务管理器,每个任务管理器具有8 GB内存
和
32个处理插槽: ./bin/yarn-session.sh -n 10 -tm 8192 -s 32 当我使用
flink
1.10版本时,
启动
yarn会话的
F
浏览 23
提问于2020-09-07
得票数 0
回答已采纳
1
回答
Flink
1.5.4没有在Kubernetes中注册(GCS)文件系统,尽管它在docker容器
中
工作
docker
、
kubernetes
、
google-cloud-storage
、
apache-flink
注意:将键放入图像是最糟糕的,我在这里这样做是为了在调试过程
中
在Docker
和
Kubernetes之间创建一个二进制的相等的文件系统。我正在尝试
启动
一个在GCS
中
持久化状态的
flink
作业管理器,所以我在我的
flink
-conf.yaml
中
添加了一个
flink
-conf.yaml行,并且我正在构建我的Dockerfile,正如描述的/bin/bash一样在其中
启动
一个交互式shell,我就可以通过以下方式
启
浏览 0
提问于2018-10-04
得票数 1
回答已采纳
1
回答
重新
启动
后,
Flink
任务管理器不处理数据。
apache-flink
、
flink-streaming
、
flink-cep
我是
flink
的新手,我部署了我的
flink
应用程序,它基本上执行简单的模式匹配。它部署在库伯奈特斯集群,拥有1 JM
和
6 TM。我每10分钟发送一次4.4k
和
200k大小的消息,并执行负载测试。我添加了重新
启动
策略
和
检查指向,如下所示,我没有显式地使用代码
中
的任何状态,因为不需要它。Netty服务器的问题,我遵循这个链接,,
flink
,网络
和
堆内存优化,并在下面的设置
中
应用,一切都很好 taskmanager.ne
浏览 4
提问于2020-12-04
得票数 0
2
回答
如
何在
应用程序模式下将java参数传递给
Flink
作业工件
java
、
kubernetes
、
apache-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
中
,我们<e
浏览 74
提问于2020-09-02
得票数 1
回答已采纳
1
回答
如
何在
Flink
中
跳过损坏的消息?
apache-flink
如
何在
Flink
中
跳过损坏的消息 我有DAG: KafkaSrcConsumer > FlatMap > Window > SinkFunction 现在,如果我在操作符"KafkaSrcConsumer“
中
从Kafka获得corruptedMessage,我想抛出/跳过该消息,并且不想将损坏的消息转发给下一个操作符"FlatMap”。我们如
何在
Apache
Flink
中
实现这一点? (注意:从Kafka
浏览 27
提问于2019-04-05
得票数 0
回答已采纳
1
回答
Flink
EMR部署不能获取Yarn上下文,只能作为本地应用程序执行
apache-flink
、
amazon-emr
我正在AWS EMR 6.2上部署我的
Flink
应用程序我将该步骤配置为:
如
本文所述:集群
和
步骤都处于“运行”状态。/mnt/var/lib/hadoop/steps/s-309XLKSZGN4V4/trigger-service-***.jar startExec 'hadoop jar
浏览 0
提问于2021-02-24
得票数 3
1
回答
在执行纱线应用程序杀死并再次运行后,
flink
是否会从上一次偏移恢复?
apache-kafka
、
apache-flink
、
checkpoint
现在,我对偏移管理
和
检查点机制有点困惑。我已经知道
flink
将开始从使用者组的. https://ci.
apache
.org/projects/
flink
/
flink
-docs-stable/dev/connectors/kafka.html#kafka-consumers-start-position-configuration读取分区,并且偏移量将存储到远程fileSystem
中
的检查点中。https:&
浏览 6
提问于2019-11-04
得票数 2
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Apache Flink本地安装及Example运行
Flink on PaaSTA:Yelp运行在Kubernetes上的新流处理平台
从零开始搭建 Flink
本地模式安装Flink集群(单机版)
Apache Flink进阶(四):Flink on Yarn/K8s原理剖析及实践
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券