腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
我是否可以在不使用内置print()函数的情况下在Apache
Flink
中打印DataSteam<T>的单个元素
、
我正在尝试打印在
Flink
中检测到的警告的值 DataStream<TemperatureEvent> warnings = tempPatternStream.select
浏览 14
提问于2017-08-11
得票数 0
回答已采纳
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
回答已采纳
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
回答已采纳
2
回答
是否有像Nifi或流集数据收集器这样的可视化编程环境用于
flink
或beam?
、
、
我正在寻找一个可视化的编程工具,以抽象化的代码,当创建数据流流,以建立在
Flink
或束-
Flink
中的CEP应用程序。类似于Nifi或流设置数据收集器的图形设计器。 有人知道这样的计划吗?
浏览 5
提问于2017-04-30
得票数 4
回答已采纳
1
回答
Google Cloud Dataproc支持的OSS
、
、
、
Dataproc是一种完全托管且高度可扩展的服务,用于运行Apache Spark、Apache
Flink
、Presto和30+
开源
工具和框架。
浏览 34
提问于2021-10-01
得票数 3
回答已采纳
2
回答
工作流引擎和事件流框架是编排层的替代方案吗?
、
、
、
要求该层具有灵活性,以便可以快速实现不同类型文档的不同流另一种思考方式是--工作流。
浏览 7
提问于2019-10-23
得票数 3
1
回答
Flink
savepoint与本地执行环境(如独立应用程序)
、
、
、
如何使用独立应用程序(本地执行环境或迷你集群)实现
flink
保存点。我在
flink
-config.yaml文件中配置了savepoint目录,但不确定如何在关闭应用程序之前获取保存点,以及如何在重新启动应用程序后恢复?是否有任何方法或必须先使用
flink
群集,然后再使用CLI。 感谢你的帮助。谢谢
浏览 0
提问于2020-08-18
得票数 0
1
回答
K8S上的
Flink
:如何向集群提供
Flink
配置?
、
我遵循创建集群,但不清楚如何向集群提供?例如,我想指定jobmanager.heap.size=2048m。
浏览 0
提问于2019-08-13
得票数 2
回答已采纳
1
回答
无法使用
flink
在scala中实例化用户函数
、
、
我正在尝试运行一个用Scala编写的大型
开源
项目。我正在使用3个docker图像运行它。 docker-compose文件是here。version: '2' streammachine: - "EXECUTION_TYPE=
flink
-cluster"- "
FLINK
_JOBMGR_HOST=jobmanager" - "
FLINK
_JOBMGR_PORT=8081&qu
浏览 12
提问于2019-08-26
得票数 3
回答已采纳
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
1
回答
如何使用
Flink
在电子病历上使用s3a文件系统?
、
、
我试图使用Table在
Flink
应用程序中利用s3a文件系统。我在EMR6.1(预装有
Flink
1.11.0)。org.apache.
flink
.core.fs.UnsupportedFileSystemSchemeException 指示s3://或s3a:// URI都不支持任何文件系统似乎
flink
run命令没有遵守EMR预先配置的hadoop类路径。
浏览 2
提问于2021-09-01
得票数 0
回答已采纳
0
回答
关于alermanager邮件模板 ?
、
您好: 在 alertmanager.yml 配置中
告警
接受定义指定html 时 发现获取不到key值 ,配置如下:receivers: #
告警
接收配置 send_resolved: true #
浏览 454
提问于2020-03-30
1
回答
关于这个会议室
告警
与恢复事件 问题?
、
、
、
关于这个会议室
告警
与恢复事件 它是只会在
告警
刚发生时发送一次事件通知吗?还是说如果
告警
存在就会一直发“
告警
生成”类型
告警
事件,直到该
告警
恢复就不会再发了,另外我看文档中写到如果回调失败会在1分钟、3分钟、6分钟进行重新发起回调请求,如果我这边因为网络或其他等问题导致在这3个时间段仍然没有回调成功,那等我这边服务恢复正常后这个
告警
还会发送事件进行通知吗?还是说就只会重试3次,3次之后没有回调成功那这个
告警
信息就不会再发事件了?
浏览 139
提问于2023-12-08
2
回答
实时流和回测应用程序的正确云服务是什么?
、
我希望以非常高的频率记录时间序列数据。我想知道是否有一个优雅的无服务器解决方案,允许我存储并对实时数据做出反应。AWS Kinesis streams似乎符合要求-但是,我不确定它是否仅用于实时反应,或者是否还收集历史数据,以便我可以脱机使用这些数据来构建模型。
浏览 0
提问于2017-08-11
得票数 0
2
回答
这是否是非侵入性的?
、
、
我想尝试apache
flink
、hadoop和solr来进行非侵入性的日志摄取,以便对它们进行处理和索引,并进行一些分析和查询。我在考虑使用
flink
对几个应用程序的应用程序日志进行数据处理,然后将它们放到hadoop上,然后使用solr对它们进行查询。问题是:这真的是非侵入性的吗?
Flink
的行为类似于flume,在我喜欢监视的服务器中安装和配置代理。
浏览 21
提问于2019-04-11
得票数 0
1
回答
如何监视mysql状态变量并将其推入松弛状态?
、
、
我一直试图找到一种免费的方法来监视mysql状态变量,并在某些变量达到阈值(即,大量连接)时推送松弛通知。当然,编写脚本相对容易,但我不确定从哪里开始编写脚本是最好的选择。我想这将是一个cron,它每5秒运行一次,得到状态变量,如果它们达到临界值,就调用web钩子。 有谁能对这样做的最佳方法提出建议吗?
浏览 0
提问于2018-06-05
得票数 0
回答已采纳
2
回答
AWS云监视报警状态
、
、
(使用公制过滤器) 任何帮助都将不胜感激。谢谢
浏览 0
提问于2018-05-31
得票数 0
回答已采纳
0
回答
prometheus配置
告警
推送至企业微信群?
prometheus配置
告警
推送至企业微信群,然后把非企业人员拉到
告警
群之后就无法正常接收
告警
,这个是本身不支持吗?
浏览 112
提问于2022-04-19
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
美团点评实时计算平台的Flink监控与告警实践
Stateful Functions开源:集成了Flink和FaaS的流处理优点
从Storm到Flink:大数据处理的开源系统及编程模型
Flink基础教程(二):初探Flink
运维告警管理充满挑战,智能告警平台持续助力
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
云直播
活动推荐
运营活动
广告
关闭
领券