腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
2
回答
有没有一种使用SQL查询正在运行的
Flink
作业的方法
、
、
我是新的
Flink
,并试图创建一个原型,可以做一个连续的查询以及按需的查询。第一部分已经起作用了(使用预定义的查询),但与第二个部分斗争。有可以使用的SQL。我已经看到了
Flink
木星笔记本集成,这告诉我,这应该工作的方式从一个网页界面。但是,不知道如何做到这一点,每次都不提交一个完整的JAR。见和 对我们还能探索什么有什么建议吗?
浏览 12
提问于2022-01-15
得票数 0
回答已采纳
3
回答
是否有一些好的
开源
连接器可以实现从InfluxDB到
Flink
的数据传输?
、
、
在每一开始,我们都试图了解流入DB和
Flink
之间的数据传输过程。我们的基本思想是:
Flink
读取来自influxDB的数据,
Flink
利用这些数据进行一些基于
Flink
的ML库的建模。但是,我们只找到一些
开源
存储库,它们提供了一个接收器,可以将数据从
Flink
发送到InfluxDB (例如
Flink
InfluxDB连接器)。因此,如果你知道一些好的例子,如我所描述的,请告诉我。
浏览 0
提问于2019-12-12
得票数 1
回答已采纳
1
回答
查询以缩小未发送数据的传感器
、
、
、
上下文:我们使用动态分析来处理我们的传感器数据并发现传感器数据中的异常。以下方法已经在中尝试过,但没有成功:CREATE OR REPLACE PUMP "STREAM_PUMP_ALERT_DOSCONNECTION" AS INSERT INTO "INTERMEDIATE_SQL_STREAM" SELECT STREAM "deviceID" as "device_key", c
浏览 13
提问于2022-03-14
得票数 1
2
回答
工作流引擎和事件流框架是编排层的替代方案吗?
、
、
、
要求该层具有灵活性,以便可以快速实现不同类型文档的不同流另一种思考方式是--工作流。
浏览 7
提问于2019-10-23
得票数 3
2
回答
链接到NiFi连接器
、
、
在使用Scala代码将数据从输出NiFi端口传输到
Flink
方面,我需要一些帮助。import org.apache.
flink
.streaming.connectors.nifi.NiFiSourceimport org.apache.
flink
.streaming.api.functions.sourc
浏览 0
提问于2017-07-17
得票数 0
回答已采纳
1
回答
flink
中的“外部状态”是什么?
、
虽然
Flink
网站上的所有文档都没有提到“外部状态”,但我们在一篇论文中遇到了这个概念(http://www.vldb.org/pvldb/vol10/p1718-carbone.pdf 4.1节)。
浏览 26
提问于2020-09-03
得票数 0
回答已采纳
1
回答
Flink
1.32 akka.tcp
、
://
flink
@master1 1:6123/user/作业管理器注册(尝试1,超时
时间
: 500毫秒)INFO org.apache.
flink</em
浏览 0
提问于2018-03-21
得票数 0
1
回答
结构流:前n行
、
、
我需要获得50条最新的事件-
时间
记录作为输出,但是结构流给了我一个完整的无界表或几个更新的结果。我在网上搜索了很多,有几种方法如下:(2)使用
Flink
捕获最新的事件
时间
记录。同时使用
flink
和structure streaming是件很麻烦的事情。如下所示,我已经尝试使用
flink
1.6,statics是一个表格吗?我不知道如何处理,因为没有输出。
浏览 3
提问于2018-06-11
得票数 0
1
回答
带有Apache
Flink
的自定义水印
您能创建一个包含
时间
戳和k/v对(this=that, that=this)的水印吗? 因此,水印将保存{12DEC180500GMT,this=that, that=this}。
浏览 0
提问于2018-06-20
得票数 1
回答已采纳
1
回答
Flink
CEP和事件顺序
、
我是
Flink
和
Flink
CEP的新手。使用事件
时间
时,
Flink
CEP是否以升序(事件-)
时间
顺序迭代事件以检查模式?提前感谢!
浏览 33
提问于2019-02-28
得票数 0
回答已采纳
1
回答
流式数据
Flink
中的全局聚合
、
我目前正在使用
Flink
1.0编写一个聚合用例,作为我需要获取过去10分钟内登录的api的计数的用例的一部分。
浏览 3
提问于2016-04-07
得票数 1
2
回答
在zookeeper升级期间,
flink
作业管理器是否会崩溃?
我正在尝试理解在zookeeper升级期间
flink
作业管理器的行为是否是预期的。 我在kubernetes中运行
flink
1.11.2,使用zookeeper服务器3.5.4-beta。当我进行zookeeper升级时,zookeeper有20秒的停机
时间
。我希望
flink
作业在这20秒内重新启动,或者在日志中显示一些警告。相反,我看到整个
flink
JVM崩溃(后来pod重启)。(ClientCnxnSocketNIO.java:366) ~[
flink
-shaded-zookee
浏览 75
提问于2021-02-09
得票数 0
回答已采纳
1
回答
flink
并行使用rabbitmq消息,如何确保顺序消耗
我通过
flink
收听mysql的binlog,然后将它放到rabbitmq队列中,在
flink
中使用rabbitmq消息,将并行性设置为1以便连续地消耗消息,但是这会导致
flink
任务oom,有什么方法可以支持多并行性并按顺序消费吗
浏览 11
提问于2022-08-25
得票数 0
2
回答
Flink
SQL凭空创建了一些东西
、
、
、
早些时候,我问
Flink
是否可以,答案是肯定的。现在,我将更多地研究
Flink
SQL的功能。对于
Flink
SQL,我不太确定,当然,如果您想要运行一个快速测试或构建一个可移植的示例,那么它可以消除对其他解决方案的任何硬依赖。从概念上讲,
时间
窗口上的计数(*)可以工作,但我还没有让它正常工作。也许这是一个特性,如果没有任何可计数的输出,则输出将为零(而不是0)。除了窗口之外,我在
Flink
SQL中看不到有
时间
概念的任何东西,因此在外部,我怀疑这是不可能的。 从一
浏览 0
提问于2021-03-27
得票数 1
1
回答
事件和流记录中的
Flink
时间
戳
、
查看
Flink
的文档和书籍,我对
时间
戳有疑问:如果流设置为事件-
时间
模式,这意味着
时间
戳具有进入
Flink
之前的源
时间
(甚至在通过消息队列(可能是Kafka)之前),为什么
Flink
将
时间
戳作为元数据附加到记录幻灯片3根据
时间
戳的用途列出了不同类型的
时间
戳: 如果
时间
戳位于事件内部,为什么要将该值传递给记录的元数据?另外,事件和记录之间的确切区别是什么?
浏览 5
提问于2021-02-22
得票数 0
2
回答
是否有像Nifi或流集数据收集器这样的可视化编程环境用于
flink
或beam?
、
、
我正在寻找一个可视化的编程工具,以抽象化的代码,当创建数据流流,以建立在
Flink
或束-
Flink
中的CEP应用程序。类似于Nifi或流设置数据收集器的图形设计器。 有人知道这样的计划吗?
浏览 5
提问于2017-04-30
得票数 4
回答已采纳
1
回答
如何使用处理
时间
模型检查流中某个项目的内部
flink
时间
戳?
我正在寻找标记在我的流中的数据到达
flink
的
时间
,以便我可以执行一些计算。我认识到当使用事件
时间
模型时,我可以直接控制它,但我希望有一些简单的方法来发现
flink
在对流进行窗口决策时使用的
时间
戳
flink
。
浏览 3
提问于2017-09-30
得票数 0
回答已采纳
1
回答
用
Flink
CEP测量事件
时间
延迟
、
我用
Flink
实现了一个模式,它匹配三个事件,比如A->B->C。PatternSelectFunction这就像一种魅力,但我对所有匹配事件的活动
时间
感兴趣我知道传统的
Flink
流API提供了丰富的功能,允许您注册
Flink
的内部延迟跟踪器,如本所述。我还看到
Flink
1.8增加了一个新的RichPatternSelectFunction。但不幸的是,我不能设置<em
浏览 0
提问于2019-01-21
得票数 1
回答已采纳
1
回答
Flink
用Java自定义类设置基本的Kafka生产者消费者
、
、
、
、
', name: '
flink
-connector-kafka_2.11', version: '1.9.0' // https://mvnrepository.com/artifact/org.apache.
浏览 4
提问于2020-03-09
得票数 0
回答已采纳
1
回答
Apache
Flink
-如何实现自定义的反序列化程序实现DeserializationSchema
、
我正在使用
Flink
,我正在使用Kafka连接器。我从
flink
收到的消息是一个逗号分隔的项目列表。"'a','b',‘c’,1,0.1....‘12:01:00.000’“其中一个包含事件
时间
,我想将此事件
时间
用于每个分区的水印(在kafka源代码中),然后使用此事件
时间
进行会话窗口。我的情况与往常有点不同,因为据我所知,人们通常使用"kafka
时间
戳“和SimpleStringSchema()。
Flink
提
浏览 69
提问于2020-10-24
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
关于Flink中的时间概念
Flink 的事件时间(Event Time)和处理时间(Processing Time)是什么?
Stateful Functions开源:集成了Flink和FaaS的流处理优点
从Storm到Flink:大数据处理的开源系统及编程模型
Flink基础教程(二):初探Flink
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
云直播
活动推荐
运营活动
广告
关闭
领券