1回答
如何在运行时更改apache flink的日志级别
logging、apache-flink
是否可以在运行时更改flink框架的日志级别？什么时候flink集群已经在运行？我参考了下面的文件，没有提到它。https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/logging.html
浏览 267提问于2020-11-24得票数 0
2回答
有没有一种使用SQL查询正在运行的Flink作业的方法
apache-flink、flink-streaming、flink-sql
我是新的Flink，并试图创建一个原型，可以做一个连续的查询以及按需的查询。第一部分已经起作用了(使用预定义的查询)，但与第二个部分斗争。有可以使用的SQL。我已经看到了Flink木星笔记本集成，这告诉我，这应该工作的方式从一个网页界面。但是，不知道如何做到这一点，每次都不提交一个完整的JAR。到目前为止，我的研究已经使我广泛地找到了这两种资源：
有一个<
浏览 12提问于2022-01-15得票数 0
回答已采纳
3回答
是否有一些好的开源连接器可以实现从InfluxDB到Flink的数据传输？
apache-flink、influxdb、flink-streaming
当我们试图构建自己的时态数据库系统时，我的团队遇到了一些问题。在每一开始，我们都试图了解流入DB和Flink之间的数据传输过程。我们的基本思想是: Flink读取来自influxDB的数据，Flink利用这些数据进行一些基于Flink的ML库的建模。(如图中的红圈)。但是，我们只找到一些开源存储库，它们提供了一个接收器，可以将数据从Flink发送
浏览 0提问于2019-12-12得票数 1
回答已采纳
1回答
FlinkKafkaConsumer和版本化使用者FlinkKafkaConsumer09/FlinkKafkaConsumer010/FlinkKafkaConsumer011之间的差异
apache-kafka、apache-flink、flink-streaming
Flink-kafka-consumer有两种类型的消费者，例如： 这两个消费者层次结构都扩展了相同的FlinkKafkaConsumerBase类。我想知道维护编号类背后的设计决策是什么？我们应该在什么时候使用其中一个呢？ 我注意到带有编号后缀的类有一些更多的功能(例如，分级限制)。https://github.com/apache/flink/blob/master/fl
浏览 6提问于2020-09-14得票数 0
2回答
Flink S3 Hadoop 2.8.0
apache-flink、flink-streaming、flink-cep
我们试图将S3用于Flink后端状态和检查点，并在法兰克福使用了一个桶(V4身份验证)--它给出了我在这里发布的错误()，这是由hadoop造成的。但是Hadoop2.8.0工作，但是还没有Flink支持。
我想我的问题是Flink什么时候会提供一个基于Hadoop2.8.0的版本？
浏览 0提问于2017-03-27得票数 1
回答已采纳
1回答
ExecutionEnvironment和StreamExecutionEnvironment之间的区别是什么
apache-flink、flink-streaming、flink-batch
我是flink的新手。在使用java进行flink编程的过程中，我多次注意到它有时被声明为StreamExecutionEnvironment，有时被声明为ExecutionEnvironment。这两个类的主要区别是什么。什么时候用什么。
浏览 367提问于2021-06-27得票数 0
1回答
使用Kafka源时终止Flink作业
apache-kafka、apache-flink、flink-streaming
当我的制作人把所有的消息都流到Kafka之后，在Flink完成处理之后，我希望能够终止Flink作业，这样它就不会继续运行了，这样我就可以知道Flink什么时候完成了所有的数据处理。我也不能使用批处理，因为我需要Flink运行平行于我的Kafka流。通常，Flink在一个isEndOfStream类中使用DeserializationSchema方法来查看它是否应该提前结束(返回方法中的true将自动结束作业)。但是，当使用F
浏览 13提问于2022-10-03得票数 0
1回答
flink什么时候会考虑一个检查点的完成？在水槽功能之前还是之后？
apache-flink、flink-streaming
flink什么时候会考虑一个检查点的完成？有两种方式：
flink将在所有接收器函数都收到检查屏障N后立即考虑检查点N完成。当所有接收器功能成功地处理了屏障N时，flink将考虑检查点N完成。因为我能找到任何关于这件事的文件。
浏览 1提问于2021-04-28得票数 1
回答已采纳
2回答
链接到NiFi连接器
scala、apache-flink、apache-nifi
在使用Scala代码将数据从输出NiFi端口传输到Flink方面，我需要一些帮助。import org.apache.flink.streaming.connectors.nifi.NiFiSourceimport org.apache.flink.streaming.api.functi
浏览 0提问于2017-07-17得票数 0
回答已采纳
2回答
Flink CheckpointedFunction的使用案例
apache-flink、flink-streaming
在浏览Flink官方文档时，我遇到了CheckpointedFunction。想知道你为什么以及什么时候会使用这个函数。我目前正在做一个有状态的Flink作业，它在很大程度上依赖于ProcessFunction来在RocksDB中保存状态。
浏览 109提问于2021-06-08得票数 2
2回答
像Hash这样的术语在Flink计划中意味着什么？
apache-flink、flink-streaming
这是在我部署工作时出现在仪表板上的Flink计划的图像。如您所见，操作符之间的连接被标记为FORWARD/HASH等。它们指的是什么？什么时候叫HASH，什么时候叫FORWARD
浏览 0提问于2019-01-25得票数 5
回答已采纳
1回答
Flink两种不同的ProcessWindowFunction包
scala、apache-flink、window-functions
问题
org.apache.flink.streaming.api.scala.function.ProcessWindowFunction对于窗口操作，就像在org.apache.flink.streaming.api.scala中
浏览 1提问于2019-07-07得票数 0
1回答
什么时候使用“操作符状态”，在Apache中“键控状态”和“会话窗口”有什么区别？
apache-flink、flink-streaming
关于在flink中使用states的最佳实践，我有两个问题：
我什么时候该用它？关于“键控状态”与“会话窗口”的
使用键控状态而不是使用映射到某些id的windowAssigner和sessionWindow有什么不同？
浏览 1提问于2019-07-22得票数 0
2回答
Apache Flink:窗口上的函数何时被调用？
apache-flink、flink-streaming
Flink什么时候会调用窗口转换函数？它是在窗口端边界调用一次还是在接收到每条消息时调用？
浏览 0提问于2018-04-10得票数 0
1回答
flink中的“外部状态”是什么？
apache-flink、flink-streaming
虽然Flink网站上的所有文档都没有提到“外部状态”，但我们在一篇论文中遇到了这个概念(http://www.vldb.org/pvldb/vol10/p1718-carbone.pdf 4.1节)。
浏览 26提问于2020-09-03得票数 0
回答已采纳
1回答
Flink精确一次-接收器处的检查点和屏障确认
apache-flink、flink-streaming、checkpointing
我有一个Flink作业，它的接收器是将数据写入MongoDB。接收器是RichSinkFunction的实现。
接收器在什么时候确认检查点屏障，在调用函数开始时还是在调用完成时？意味着它在确认障碍之前等待持久化(保存在MongoDB中)响应？如果提交
浏览 3提问于2018-05-31得票数 1
1回答
使用“在纱线上运行单个闪动作业”模型时的“纱线上闪动”参数
apache-flink
如果我想在yarn上运行flink作业，命令是./bin/flink run -m yarn-cluster ./examples/batch/WordCount.jar 但是这个命令会运行一个默认的集群，它有2个任务管理器；如果我只提交了一个任务，为什么默认的任务管理器设置为2？什么时候我需要在一个任务中有多个任务管理器？
浏览 19提问于2020-07-02得票数 1
1回答
我的Flink应用程序需要水印吗？如果不需要，我是否需要WatermarkStrategy.noWatermarks？
apache-flink、flink-streaming
我不确定我的Flink应用程序是否真的需要水印。它们什么时候是必要的？
如果我不需要它们，WatermarkStrategy.noWatermarks()的用途是什么？
浏览 4提问于2021-04-21得票数 0
1回答
如何在执行表连接时获得最后的结果(在flink sql中使用toRetractStream
apache-flink、flink-streaming、flink-sql、flink-table-api
下面是我使用flink sql API连接两个表的代码 tEnv.createTemporaryView("A", streamA,"speed_sum,cnt,window_start_time,window_end_timeRow>> streamResult = tEnv.toRetractStream(table, Row.class).;
streamResult.print("streamResult"); 我的输出是这样的
浏览 211提问于2021-10-27得票数 1
1回答
了解延迟事件与水印的Flink
apache-flink、flink-streaming
看看，它说关于水印
实际上，由于设置了允许延迟，是否导致了窗口的延迟评估？那么，水印的使用和允许的延迟究竟有什么区别呢？什么时候用哪种？
浏览 4提问于2021-01-31得票数 2
回答已采纳
云服务器
ICP备案
对象存储
云点播
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号