腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
2
回答
有没有一种使用SQL查询正在运行
的
Flink
作业
的
方法
、
、
我
是
新
的
Flink
,并试图创建一个原型,可以做一个连续
的
查询以及按需
的
查询。第一部分已经起作用了(使用预定义
的
查询),但与第二个部分斗争。有可以使用
的
SQL。我已经看到了
Flink
木星笔记本集成,这告诉我,这应该工作
的
方式从一个网页界面。但是,不知道如何做到这一点,每次都不提交一个完整
的
JAR。到目前为止,我
的
研究已经使我广泛地找到了这两种资源:
浏览 12
提问于2022-01-15
得票数 0
回答已采纳
3
回答
是否有一些好
的
开源
连接器可以实现从InfluxDB到
Flink
的
数据传输?
、
、
当我们试图构建自己
的
时态数据库系统时,我
的
团队遇到了一些问题。在每一开始,我们都试图了解流入DB和
Flink
之间
的
数据传输过程。我们
的
基本思想
是
:
Flink
读取来自influxDB
的
数据,
Flink
利用这些数据进行一些基于
Flink
的
ML库
的
建模。(如图中
的
红圈)。但是,我们只找到一些
开源
存储库,它们提供了一个接收器,可以将数据从
Fli
浏览 0
提问于2019-12-12
得票数 1
回答已采纳
2
回答
链接到NiFi连接器
、
、
在使用Scala代码将数据从输出NiFi端口传输到
Flink
方面,我需要一些帮助。import org.apache.
flink
.streaming.connectors.nifi.NiFiSourceimport org.apache.
flink
.streaming.api.functi
浏览 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
回答已采纳
2
回答
工作流引擎和事件流框架
是
编排层
的
替代方案吗?
、
、
、
要求该层具有灵活性,以便可以快速实现不同类型文档
的
不同流另一种思考方式
是
--工作流。将其设计为在Apache Airflow或Uber Cadence等工作流引擎上运行
的
工作流。 什么
是
更好
的
方法。
浏览 7
提问于2019-10-23
得票数 3
1
回答
K8S上
的
Flink
:如何向集群提供
Flink
配置?
、
我遵循创建集群,但不清楚如何向集群提供?例如,我想指定jobmanager.heap.size=2048m。
浏览 0
提问于2019-08-13
得票数 2
回答已采纳
1
回答
如何使用
Flink
在电子病历上使用s3a文件系统?
、
、
我试图使用Table在
Flink
应用程序中利用s3a文件系统。我在EMR6.1(预装有
Flink
1.11.0)。org.apache.
flink
.core.fs.UnsupportedFileSystemSchemeException奇怪
的<
浏览 2
提问于2021-09-01
得票数 0
回答已采纳
1
回答
查询以缩小未发送数据
的
传感器
、
、
、
上下文:我们使用动态分析来处理我们
的
传感器数据并发现传感器数据中
的
异常。 )下面
是
供您参考
的
测试用例测试用例1
的
输出: 我们希望弹出设备1,这样我们就知道哪个
浏览 13
提问于2022-03-14
得票数 1
1
回答
Google Cloud Dataproc支持
的
OSS
、
、
、
当我去https://cloud.google.com/dataproc
的
时候,我看到了这个...Dataproc
是
一种完全托管且高度可扩展
的
服务,用于运行Apache Spark、Apache
Flink
、Presto和30+
开源
工具和框架。
浏览 34
提问于2021-10-01
得票数 3
回答已采纳
1
回答
Flink
savepoint与本地执行环境(如独立应用程序)
、
、
、
如何使用独立应用程序(本地执行环境或迷你集群)实现
flink
保存点。我在
flink
-config.yaml文件中配置了savepoint目录,但不确定如何在关闭应用程序之前获取保存点,以及如何在重新启动应用程序后恢复?是否有任何方法或必须先使用
flink
群集,然后再使用CLI。 感谢你
的
帮助。谢谢
浏览 0
提问于2020-08-18
得票数 0
1
回答
无法使用
flink
在scala中实例化用户函数
、
、
我正在尝试运行一个用Scala编写
的
大型
开源
项目。我正在使用3个docker图像运行它。 docker-compose文件
是
here。version: '2' streammachine: - "EXECUTION_TYPE=
flink
-cluster"- "
FLINK
_JOBMGR_HOST=jobmanager" - "
FLINK
_J
浏览 12
提问于2019-08-26
得票数 3
回答已采纳
2
回答
这是否是非侵入性
的
?
、
、
我想尝试apache
flink
、hadoop和solr来进行非侵入性
的
日志摄取,以便对它们进行处理和索引,并进行一些分析和查询。我在考虑使用
flink
对几个应用程序
的
应用程序日志进行数据处理,然后将它们放到hadoop上,然后使用solr对它们进行查询。问题
是
:这真的是非侵入性
的
吗?
Flink
的
行为类似于flume,在我喜欢监视
的
服务器中安装和配置代理。hadoop和solr是不是一个很好
的
组合,可以索引大量日志,
浏览 21
提问于2019-04-11
得票数 0
1
回答
除了一个胖jar之外,所有东西都会在停靠
的
flink
集群中失败。
、
我有一个容器化
的
flink
集群,具有独立
的
JobManager和2个任务管理器。当我提交一个包含我需要
的
连接器和代码
的
胖jar时,一切都会正常运行,但是一个只有我
的
代码
的
jar将失败--尽管我已经将连接器jar添加到/opt/
flink
/lib,容器进程显示它们将被添加到类路径中。当我试图从IDE进行远程连接时,也会发生同样
的
失败;不用说,每次都要打包一个胖jar,这会带来糟糕
的
开发体验
浏览 0
提问于2019-04-12
得票数 1
回答已采纳
2
回答
出现java.lang.NoSuchMethodError异常
的
Flick WordCount示例失败
我正在尝试执行
Flink
中
的
基本WordCount示例,该示例位于以下链接- 中Exception in thread "main" java.lang.NoSuchMethodError: org.apache.
flink
.core.memory.MemorySegmentFactory.initializeFactory(Lorg/apache/
flink
/core/memory/Memo
浏览 0
提问于2017-03-17
得票数 2
2
回答
intellij找不到
Flink
测试Harness util
、
、
、
我试图使用Apache (org.apache.
flink
.streaming.util.OneInputStreamOperatorTestHarness)中
的
OneInputStreamOperatorTestHarness我跟踪了,这个官方
的
和
浏览 5
提问于2021-12-20
得票数 -1
2
回答
如何使用
Flink
的
TestHarness类?
、
我需要测试一个共享状态
的
CoFlatMapFunction。通过阅读,我得出结论,我应该使用per:https://ci.apache.org/projects/
flink
/
flink
-docs-stable/dev/stream/testing.html#testing-checkpointing-and-state-handling
的
TestHarness类 因为它不是公共api
的
一部分,所以我不知道如何在不复制和粘贴类本
浏览 104
提问于2019-02-16
得票数 0
回答已采纳
2
回答
flink
run -py与python run
的
区别
、
、
我们知道pyflink table API将流/批处理转换为表,并在其上做一些工作,最后到达您想要
的
位置。().build() t_env = BatchTableEnvironment.create(evnironment_settings = env_settings) 但是我发现其中一个样式只适用于
flink
我
的
问题
是
executionEnvironment和BatchTableEnvironment/StreamTableEnvironment有什么区别,什么时候可以使用
flink</e
浏览 107
提问于2020-12-18
得票数 0
2
回答
实时流和回测应用程序
的
正确云服务是什么?
、
我希望以非常高
的
频率记录时间序列数据。我想知道是否有一个优雅
的
无服务器解决方案,允许我存储并对实时数据做出反应。 我希望使用存储
的
数据创建统计模型,然后基于这些模型实时处理新数据。谷歌DataFlow和出版/订阅似乎也是相关
的
,但不确定它是否适合上述情况。
浏览 0
提问于2017-08-11
得票数 0
1
回答
Flink
1.12找不到在类路径中实现'org.apache.
flink
.table.factories.DynamicTableFactory‘
的
标识符“kafka”
的
任何工厂
我有一个在本地运行良好
的
Flink
作业,但是当我尝试在集群上
flink
run作业时失败了。它基本上
是
读卡夫卡,做一些转换,并写到一个水槽。这是我
的
pom.xml,包括
flink
-connector-kafka。 <shadedArtifactAttached<
浏览 16
提问于2021-03-10
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
什么是 Apache Flink?
Stateful Functions开源:集成了Flink和FaaS的流处理优点
华为海外内测“华为搜索”,我们关心的是,国内啥时候能用?
从Storm到Flink:大数据处理的开源系统及编程模型
Pinterest是如何基于Flink做实时分析的?
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
云直播
活动推荐
运营活动
广告
关闭
领券