腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
理解和分析
flink
代码,特别是调度部分
streaming
、
apache-flink
、
flink-streaming
、
bigdata
我正在改进apache
flink
的资源和任务调度,请分享任何关于apache
flink
内部
架构的教程或任何文档。还分享了调试
flink
代码的正确方法。您在分析
flink
代码方面的帮助和经验将不胜感激。
浏览 0
提问于2017-03-28
得票数 0
1
回答
导入KafkaSource在中不起作用
google-cloud-platform
、
apache-kafka
、
apache-flink
我尝试在Google上Shell中的ssh控制台中导入这个库:我以前安装过
flink
:tar -xzf
flink
-1.14.42.11.tgz 但是,当我运
浏览 12
提问于2022-05-12
得票数 0
2
回答
Apache和RxJava的使用
rx-java
、
apache-flink
、
flink-streaming
因为我的
flink
操作总是映射函数,并且在其中我更多地使用Rx,比如从
flink
获取元组并对它们进行异步操作(转到DB、写入队列等等),但是我最终没有使用
flink
向我公开的大多数方法,当Rxjava随着处理结束时你能告诉我,这是一个正确的使用
flink
,或如果有aa更好的方式做我需要做的。(喜欢使用它,但在
flink
步骤之间传递可观测值或类似的东西)。 谢谢。
浏览 4
提问于2016-06-10
得票数 1
回答已采纳
1
回答
为什么
flink
停止我的流应用程序?
apache-flink
、
flink-streaming
我的代码使用readTextFile读取日志文件,当我在
Flink
(/opt/
flink
-1.0.3/bin/
flink
run -m yarn-cluster -yn 2 /home/
flink
/
flink
-json-0.1.jar)中运行jar时,它成功地处理了
内部
的行,并停止了我的应用程序,而不是等待新的行。
浏览 2
提问于2016-06-10
得票数 0
回答已采纳
1
回答
如何在远程纱线集群上运行
Flink
作业
scala
、
remote-server
、
apache-flink
我在通过scala API远程部署
Flink
作业时遇到了一些问题。我想要的是直接使用IDE运行我的作业。
浏览 21
提问于2017-03-15
得票数 1
回答已采纳
1
回答
当有消息写入Kafka主题时,FlinkKafakProducer的numRecordsOut总是显示0
apache-kafka
、
apache-flink
、
flink-streaming
我设置了一个
Flink
工作,向Kafka主题写一些消息。它使用FlinkKafakProducer作为接收器。我验证了输出Kafka主题中写入了消息,但
Flink
指标numRecordsOut始终显示0。同样,在
Flink
Web UI中,发送的字节也始终显示0B。
浏览 20
提问于2019-03-28
得票数 1
回答已采纳
1
回答
Apache,事件流中的延迟服务是什么?
apache-flink
我几乎没有读过关于
Flink
的文章,当我在
Flink
上读博客的时候,我看到了短语“最多有60秒的服务延迟(事件不正常,最多1分钟) "。定义无序事件持续时间是否用于
Flink
中的“水印”技术,如果没有,
内部
用途是什么?
浏览 1
提问于2016-05-26
得票数 0
1
回答
org.apache.kafka.clients.consumer.ConsumerRecord 1.9 SQL客户端抛出ClassNotFoundException:
Flink
sql
、
client
、
apache-flink
、
classnotfoundexception
尝试将
Flink
1.9 SQL-Client与Kafka一起使用,但未成功。在弄清楚所需的jar文件并将它们复制到lib目录后,当执行SELECT * FROM table-name时,我得到了以下运行时异常:
Flink
SQL> select * from default_catalog.default_database.member_customer_newsletters/lib/
flink
-sql-connector-kafka-0.11_2.12-1.9.0.jar|grep 'Consum
浏览 231
提问于2019-09-20
得票数 0
1
回答
四个
Flink
表API/SQL数据类型包之间有什么关系?
apache-flink
、
flink-sql
Flink
/SQL有很多关于DataType系统的包,包括: org.apache.
flink
.table.api.DataTypesorg.apache.
flink
.table.api.Typesorg.apache.
flink
.table.types.DataTypeorg.apache.
flink
.table.data我对软件包之间的关系相当困惑,有人能给我一些提示来理解
Flink
开发人员的想法吗?
浏览 1
提问于2021-03-07
得票数 0
回答已采纳
1
回答
用
Flink
CEP测量事件时间延迟
apache-flink
、
flink-cep
我用
Flink
实现了一个模式,它匹配三个事件,比如A->B->C。我知道传统的
Flink
流API提供了丰富的功能,允许您注册
Flink
的
内部
延迟跟踪器,如本所述。我还看到
Flink
1.8增加了一个新的RichPatternSelectFunction。但不幸的是,我不能设置
Flink
1.8与
Flink
CEP。 最后,是否有办法获得所有匹配事件的事件时间?
浏览 0
提问于2019-01-21
得票数 1
回答已采纳
1
回答
Flink
如何保证运算符之间的数据顺序?
apache-flink
、
flink-streaming
、
flink-sql
我们知道,在
flink
中,对数据的处理是无序的,是使用窗口和水印。 但是,在
内部
flink
中,在操作符之间,如何保证数据的有序性?
flink
能否确保先处理高级数据?
浏览 265
提问于2020-09-22
得票数 0
回答已采纳
1
回答
如何在作业失败时终止
flink
ApplicationMaster
hadoop-yarn
、
apache-flink
当
flink
的
内部
作业失败时,如何使纱线上的
flink
应用程序终止或失败?无论有多少作业失败,应用程序仍在运行,因此无法立即发现问题。你有什么想法吗?
浏览 1
提问于2018-03-22
得票数 0
1
回答
Flink
1.5中的批处理表API问题--对流API需求的抱怨
apache-flink
、
flink-sql
我试图用
Flink
1.5.0创建一个面向批处理的
Flink
作业,并希望使用Table和SQL来处理数据。;import org.apache.
flink
.table.api.TableEnvironment;import org.apache.
flink
.table.sources
浏览 1
提问于2018-06-19
得票数 0
1
回答
Apache本地设置,独立JAR与start-cluster.sh之间的实际差异
apache-flink
StreamExecutionEnvironment.getExecutionEnvironment();env.execute();pom.xml (相关bits): <groupId>org.apache.
flink
</groupId></dependenc
浏览 1
提问于2019-11-18
得票数 1
回答已采纳
1
回答
事件和流记录中的
Flink
时间戳
apache-flink
、
flink-streaming
查看
Flink
的文档和书籍,我对时间戳有疑问:如果流设置为事件-时间模式,这意味着时间戳具有进入
Flink
之前的源时间(甚至在通过消息队列(可能是Kafka)之前),为什么
Flink
将时间戳作为元数据附加到记录幻灯片3根据时间戳的用途列出了不同类型的时间戳: 如果时间戳位于事件
内部
,为什么要将该值传递给记录的元数据?另外,事件和记录之间的确切区别是什么?
浏览 5
提问于2021-02-22
得票数 0
1
回答
Flink
文件读取堆内存异常
apache-flink
、
flink-streaming
我在
flink
中读取了一个文件: new AvroInputFormat[GenericRecord](new org.apache.
flink
.core.fs.PathGenericRecord])我遇到了一个异常: 异常错误: org.apache.
flink
.runtime.rest.util.RestClientException:
浏览 1
提问于2020-04-23
得票数 0
1
回答
Flink
(Kafka源代码)是如何管理抵消的?
apache-kafka
、
apache-flink
这是
Flink
内部
处理的吗?
浏览 2
提问于2017-01-28
得票数 2
回答已采纳
1
回答
Flink
的窗口操作是处理窗口末尾的元素,还是做滚动处理?
apache-flink
、
flink-streaming
我有一些困难,了解窗口是如何在
内部
实现
Flink
,并没有找到任何文章,以解释这一点的深入。在我看来,有两种方法可以做到。是否有人能帮助您理解
Flink
在现实中使用的方法(或者可能是不同的方法)。原因是,这两种方法各有优缺点,为了正确配置集群的资源,理解这两种方法是很重要的。
浏览 6
提问于2022-01-17
得票数 0
回答已采纳
1
回答
用Kafka和Pandas在Python上的
Flink
不会让它下沉
python
、
pandas
、
apache-kafka
、
apache-flink
我使用
Flink
1.11 (通过Python和Anaconda虚拟环境),并将Kafka作为我的源和接收器。我将我的
Flink
作业提交到一个集群中。所有的一切都是在码头(当地)进行的。DataTypes.STRING()])查看
Flink
浏览 3
提问于2020-08-28
得票数 0
1
回答
Flink
的"TypeSerializerOutputFormat“把奇怪的二进制数据写在一起
apache-flink
我使用
Flink
生成数组数据,以供其他应用程序使用。(对于数组,我不需要任何方法)我比较了
Flink
生成的二进制数据和文本数据,并在二进制数据中发现了一个奇怪的数据。
浏览 1
提问于2016-02-07
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Flink基础教程(二):初探Flink
Apache Flink 进阶(六):Flink 作业执行深度解析
《从0到1学习Flink》——Apache Flink 介绍
flink handbook-flink数据流编程模型
Flink基础教程(三):生产环境中的Flink
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券