腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
2
回答
有没有一种使用SQL查询正在运行的
Flink
作业的方法
apache-flink
、
flink-streaming
、
flink-sql
我是新的
Flink
,并试图创建一个原型,可以做一个连续的查询以及按需的查询。第一部分已经起作用了(使用预定义的查询),但与第二个部分斗争。有可以使用的SQL。我已经看到了
Flink
木星笔记本集成,这告诉我,这应该工作的方式从一个网页界面。但是,不知道如何做到这一点,每次都不提交一个完整的JAR。见和 对我们还能探索什么有什么建议吗?
浏览 12
提问于2022-01-15
得票数 0
回答已采纳
1
回答
在eclipse中获取java中
Flink
的.print()错误
java
、
eclipse
、
runtime-error
、
apache-flink
、
flink-streaming
在eclipse中尝试执行基本的
Flink
程序时,由于.print()被datastream_name.print()调用来打印我的数据,我得到了错误。(ClosureCleaner.java:106) at org.apache.
flink
.api.java.ClosureCleaner.clean(ClosureCleaner.java:132) at org.ap
浏览 15
提问于2022-06-26
得票数 0
1
回答
Flink
savepoint与本地执行环境(如独立应用程序)
apache-flink
、
flink-streaming
、
flink-sql
、
flink-batch
如何使用独立应用程序(本地执行环境或迷你集群)实现
flink
保存点。我在
flink
-config.yaml文件中配置了savepoint目录,但不确定如何在关闭应用程序之前获取保存点,以及如何在重新启动应用程序后恢复?是否有任何方法或必须先使用
flink
群集,然后再使用CLI。 感谢你的帮助。谢谢
浏览 0
提问于2020-08-18
得票数 0
1
回答
无法为maven构建镜像:3.6-jdk-8-slim for
Flink
client和苹果M1核心
docker
、
maven
、
apache-flink
、
apple-m1
我想从这个docs - operations playground开始使用
flink
playground (
flink
13) docker-compose link进行docker-compose3.6s => [internal] load metadata for docker.io/apache/
flink
Build是OK的,但是作业启动后,kafka没有收到任何消息:命令没有显示内容: 另外,我尝试将
Flink
版本从pull request建议改为13.2。但是没有结果。
浏览 374
提问于2021-09-27
得票数 0
回答已采纳
1
回答
使用保存点重新启动闪烁扣带接收器会导致数据丢失
hadoop
、
hdfs
、
apache-flink
我正在使用从Kafka到HDFS的
Flink
bucketing接收器。
Flink
的版本是1.4.2。但是,如果我们由于磁盘使用而不能使用CompressionType.BLOCK,这可能是一个问题。这是
Flink
的一个已知问题吗?或者有人知道如何解决这个问题?
浏览 0
提问于2019-04-24
得票数 0
1
回答
为什么弗林克使用纱?
kubernetes
、
hadoop-yarn
、
apache-flink
我正在深入研究
Flink
内部,看看如何在项目中使用它,并向创作者/高级思想家提出了一个问题。为什么
Flink
使用Yarn作为默认的资源管理器?请注意-我是刚认识亚恩的-只是读了一下。也是新的
Flink
浏览 2
提问于2018-03-01
得票数 2
回答已采纳
1
回答
Flink
状态与
Flink
表API的连接
apache-flink
、
flink-statefun
我们感兴趣的是从连接到常规的
Flink
流应用程序,最好使用Table。这样做的想法是查阅Statefun在
Flink
中注册的表,是否有此可能,如何做才是正确的方法?FnEnrichmentCallback.TYPE, myTable.select("max(amount)").toString(), message);} 在Module.confi
浏览 2
提问于2020-04-11
得票数 2
1
回答
Flink
调度策略
apache-flink
我知道
Flink
Default Scheduler策略,但我想要更改某些situations.For示例中的启动策略,例如Io密集型和Cpu密集型,当群集资源在每个node.So中有很大差异时,我想更改默认值是否可以基于群集资源执行我的启动
浏览 5
提问于2018-12-09
得票数 0
1
回答
当设置运算符并行性大于默认并行性时,
Flink
任务槽的分布并不均匀。
apache-flink
、
flink-streaming
我正在一个包含3个任务管理器的集群上运行一个
Flink
作业(在3个Kubernetes吊舱之上)。作业的默认并行度为9,其中一个操作符设置为并行18。作业的任务槽数设置为18 (最大并行值)。(使用
Flink
v1.6.3运行)
浏览 0
提问于2019-03-26
得票数 3
回答已采纳
1
回答
基于apache
Flink
的异常检测
apache-flink
我想知道,对于流数据场景,是否有一个尚未解决的问题或一些相关的工作(发布、平台)目前正在使用Apache的异常检测方法。到目前为止,我刚刚找到了斯科特·基德( Scott )2017年的。是否有更近期的或在工作中的进展?谢谢!
浏览 3
提问于2020-04-03
得票数 0
1
回答
如何在Apache
Flink
中使用BucketingSink写入ORC文件?
hdfs
、
apache-flink
、
orc
我正在开发一个
Flink
流媒体程序,它可以读取卡夫卡消息,并将消息转储到亚马逊网络服务s3上的ORC文件。我发现没有关于
Flink
的BucketingSink和ORC文件写入器的集成的文档。
浏览 0
提问于2017-12-06
得票数 2
1
回答
Flink
版本升级后的最新跳跃后毫秒
apache-flink
、
flink-streaming
、
amazon-kinesis
我注意到一个非常奇怪的行为,最近的版本从
Flink
1.14.4到1.15.2。
浏览 9
提问于2022-09-17
得票数 0
1
回答
为什么
Flink
使用Pushgateway而不是Prometheus通常的一般度量集合拉模型?
apache-flink
、
flink-streaming
、
prometheus-pushgateway
我们可以看到,在将
Flink
度量暴露于外部系统(如Prometheus )时,
Flink
使用Pushgateway而不是Prometheus通常的拉模型进行一般度量集合。", jobName, e);} 然而,从Prometheus下面的官方文档中可以看出,"Prometheus直接或通过中间推送网关为短寿命作业从工具作业中收集指标“,显然
Flink
流作业不是短暂的工作,那么为什么
Flink
使用Pushgateway而不是Prometheus通常的一般指标收集模型呢?
浏览 2
提问于2018-08-19
得票数 0
回答已采纳
1
回答
flink
表SQL Api
scala
、
apache-flink
、
flink-streaming
、
flink-cep
我想知道我们能否使用
flink
表和SQL中的两个表( join)来编写查询。我的查询将类似于select...
浏览 4
提问于2017-06-02
得票数 0
回答已采纳
1
回答
带有Apache
Flink
1.5的Apache Bean 2.4.0
apache-flink
、
apache-beam
有没有一个地方我们可以快速参考和查看Apache beam和运行时环境(
Flink
,Spark等)之间的版本兼容性。我正在以一种艰难的方式学习它:我不确定我的问题有多少是由版本错误造成的。目前我使用的是光束2.4.0,看看
flink
runner pom (),它使用的是
flink
1.4.0 jars。所以我假设Apache beam 2.4.0可以与Apache
Flink
1.4.0一起工作。这是正确的解释吗? 不幸的是,
Flink
1.4.0 ()没有官方的docker镜像
浏览 0
提问于2018-06-14
得票数 0
1
回答
是否可以将火花ML CrossValidatorModel应用于
Flink
流数据流?
scala
、
apache-spark
、
machine-learning
、
apache-flink
Flink
是流媒体的一个明显的选择,然而Spark已经成熟了ML pipelines,它可以在spark中训练模型,将其保存为CrossValidatorModel并部署到
Flink
中的流媒体数据吗?
浏览 16
提问于2017-03-16
得票数 0
回答已采纳
1
回答
Apache Spark与
Flink
ML
machine-learning
、
apache-spark
对不起,如果我问错了
社区
的问题。火花ML和
Flink
ML以及火花和
Flink
在一般情况下有什么区别?这两个项目都是Apache的项目,我想知道为什么Foundation有两个类似的项目。溢出
社区
已经讨论过这个问题。主题是Apache和Apache有什么区别?
浏览 0
提问于2016-10-13
得票数 2
回答已采纳
2
回答
建议使用
Flink
和Scala的堆栈是什么?
eclipse
、
scala
、
apache-flink
我目前的尝试是: 每次更新到最新源代码时,都要重新构建Scala2.11的
Flink
。拥有正确的maven设置,以便在Eclipse中构建项目时,您的项目依赖关系不会被
Flink
正式构建(即用scala 2.11
Flink
build覆盖scala 2.10 build)覆盖。
浏览 1
提问于2015-09-15
得票数 1
回答已采纳
1
回答
Flink
中工作人员的任务分配不均匀
apache-flink
我有一个在大型数据集上操作的
Flink
批处理作业。我的集群由25个节点组成,作为一个独立的集群运行。有没有办法强制
Flink
为每个作业分配尽可能多的TM插槽?
浏览 94
提问于2019-03-04
得票数 3
3
回答
是否有一些好的
开源
连接器可以实现从InfluxDB到
Flink
的数据传输?
apache-flink
、
influxdb
、
flink-streaming
在每一开始,我们都试图了解流入DB和
Flink
之间的数据传输过程。我们的基本思想是:
Flink
读取来自influxDB的数据,
Flink
利用这些数据进行一些基于
Flink
的ML库的建模。但是,我们只找到一些
开源
存储库,它们提供了一个接收器,可以将数据从
Flink
发送到InfluxDB (例如
Flink
InfluxDB连接器)。因此,如果你知道一些好的例子,如我所描述的,请告诉我。
浏览 0
提问于2019-12-12
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Flink社区风波:比Flink快十倍的技术真存在吗?
Apache Flink 社区发布的 Stateful Functions 2.2.0 是什么?
Primas 与“Linux 中国”开源社区达成战略合作,带动开源社区升级
开源社区崛起:Hugging Face领衔AI开源界
Stateful Functions开源:集成了Flink和FaaS的流处理优点
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券