我是新的Flink，并试图创建一个原型，可以做一个连续的查询以及按需的查询。第一部分已经起作用了(使用预定义的查询)，但与第二个部分斗争。有可以使用的SQL。我已经看到了Flink木星笔记本集成，这告诉我，这应该工作的方式从一个网页界面。但是，不知道如何做到这一点，每次都不提交一个完整的JAR。见和
对我们还能探索什么有什么建议吗？
浏览 12提问于2022-01-15得票数 0
回答已采纳
在每一开始，我们都试图了解流入DB和Flink之间的数据传输过程。我们的基本思想是: Flink读取来自influxDB的数据，Flink利用这些数据进行一些基于Flink的ML库的建模。但是，我们只找到一些开源存储库，它们提供了一个接收器，可以将数据从Flink发送到InfluxDB (例如Flink InfluxDB连接器)。因此，如果你知道一些好的例子，如我所描述的，请告诉我。
浏览 0提问于2019-12-12得票数 1
回答已采纳
我希望以非常高的频率记录时间序列数据。我想知道是否有一个优雅的无服务器解决方案，允许我存储并对实时数据做出反应。AWS Kinesis streams似乎符合要求-但是，我不确定它是否仅用于实时反应，或者是否还收集历史数据，以便我可以脱机使用这些数据来构建模型。
浏览 0提问于2017-08-11得票数 0
比较Flink和Spark Streaming，Flink和Storm，Storm和Heron有很多问题。这个问题的来源是Apache Flink和Twitter Heron都是真正的流处理框架(而不是像Spark Streaming这样的微批处理框架)。在Flink和Flink vs Spark上有斯利姆·巴尔塔吉的精彩演讲：关于Flink vs Storm的有趣想法：
但我还
浏览 27提问于2016-06-05得票数 9
2回答
在使用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/conf文件中更改日志级别的文章，以帮助我解决这个问题。
但后来我读到flink有两个日志框架选项。那么现在如何确定我的Flink应用程序使用的是哪个框架呢？
浏览 18提问于2022-06-02得票数 2
回答已采纳
将flink嵌入到其他程序中意味着什么？我想知道更多这方面的情况。比如如何实现这一目标。一个示例程序将非常有用。我们能以个体演员的身份运行flink程序吗？
我有一些基于配置文件的Flink作业/程序，我只想要某些Flink作业/程序来处理输入数据，而这在配置文件的基础上一直在改变。因此，Flink</em
浏览 4提问于2020-03-20得票数 0
是否可以在运行时更改flink框架的日志级别？什么时候flink集群已经在运行？我参考了下面的文件，没有提到它。https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/logging.html
浏览 267提问于2020-11-24得票数 0
虽然Flink网站上的所有文档都没有提到“外部状态”，但我们在一篇论文中遇到了这个概念(http://www.vldb.org/pvldb/vol10/p1718-carbone.pdf 4.1节)。
浏览 26提问于2020-09-03得票数 0
回答已采纳
当我启动一个flink独立集群时，它会在conf/log4j.properties文件中提到的文件中记录守护进程日志，当我在该集群中提交flink作业时，它会使用相同的属性文件来记录应用程序日志并在任务管理器上写入相同的日志文件我希望为在flink独立集群中提交的每个应用程序都有单独的日志文件。有什么办法可以做到这一点吗？
浏览 1提问于2016-11-08得票数 1
自学，自己摸索 白白浪费大把时光 二是，降低他人的学习成本。
三是，别人对自己学习结果的审核。
浏览 355提问于2020-09-25
我目前正在使用HiBench框架和为Flink实现的WordCount微基准。我注意到，如果在执行过程中杀死一个TaskManager，Flink操作符的状态会在自动“重新部署”之后恢复，但是会有很多(全部？)从基准发送到Kafka的元组被忽略(存储在Kafka中，但没有在Flink中接收)。
浏览 0提问于2018-04-06得票数 3
回答已采纳
2回答
有没有办法在Apache Flink中使用PCA？ 当我在谷歌上搜索它进行研究时，我认为找不到任何实现的代码。 如果是这样的话，我应该自己开发吗？ 谢谢。
浏览 14提问于2019-02-13得票数 0
回答已采纳
Dataproc是一种完全托管且高度可扩展的服务，用于运行Apache Spark、Apache Flink、Presto和30+开源工具和框架。
浏览 34提问于2021-10-01得票数 3
回答已采纳
我是Kubernetes的新手，并试图了解Flink在它们上的部署有何不同。如果对内部结构有任何了解，这将是非常有帮助的。
浏览 53提问于2020-08-06得票数 3
回答已采纳
1回答
Flink保存运算符的托管状态(用于检查点或逻辑运算符之间的通信(即沿作业图的边缘))是什么格式？背景:我正在考虑从JSON切换到使用AVRO，既可以将中的数据摄取到我的源中，也可以由向我的Sinks发送数据。然而，由Avro创建的自动生成的POJO类相当嘈杂.因此，在作业图(用于Flink操作符之间的通信)中，我正在考虑使用像Avro这样的二进制序列化格式是否对性能有什么好处。它可能没有实质性
浏览 4提问于2017-12-21得票数 2
回答已采纳
我正在寻找一个可视化的编程工具，以抽象化的代码，当创建数据流流，以建立在Flink或束-Flink中的CEP应用程序。类似于Nifi或流设置数据收集器的图形设计器。
有人知道这样的计划吗？
浏览 5提问于2017-04-30得票数 4
回答已采纳
我们必须使用flink吗?与spring(web框架)应用程序有什么不同？例如，我想在过去的5分钟内统计一个网站的页面浏览量。我可以用弗林克的窗户数数。在官方欺诈检测用例()中，我可以用flink的状态和窗口检测可疑事务。我想知道flink与传统的web+database堆栈相比的好处。
浏览 6提问于2022-12-03得票数 2
1回答
在一个受保护的Hadoop集群中，我试图访问Flink am页面并从纱线中登录，并看到以下错误：User %remoteUser are not authorized to view application%appIDAMContainerSpec是ContainerLaunchContext类，它有一个PB实现，从框架端提交从Flink中，该对象是在Ab
浏览 3提问于2018-06-14得票数 0
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号