我们必须使用flink吗?与spring(web框架)应用程序有什么不同？例如，我想在过去的5分钟内统计一个网站的页面浏览量。我可以用弗林克的窗户数数。在官方欺诈检测用例()中，我可以用flink的状态和窗口检测可疑事务。我想知道flink与传统的web+database堆栈相比的好处。
浏览 6提问于2022-12-03得票数 2
我是新的Flink，并试图创建一个原型，可以做一个连续的查询以及按需的查询。第一部分已经起作用了(使用预定义的查询)，但与第二个部分斗争。有可以使用的SQL。我已经看到了Flink木星笔记本集成，这告诉我，这应该工作的方式从一个网页界面。但是，不知道如何做到这一点，每次都不提交一个完整的JAR。见和
对我们还能探索什么有什么建议吗？
浏览 12提问于2022-01-15得票数 0
回答已采纳
我正在构建一个要求低于要求的应用程序，我刚刚开始使用flink。摄入卡夫卡的数据，比如50个分区(输入速率- 100,000毫希/秒)
将输出存储在Cassandra上我正在寻找一个实时流媒体平台，并发现Flink是一个非常适合实时和批处理。我是否需要在google数据流中编写数据管道来执行flink上的步骤序列，还是有其他方法来执行实时流的步骤序列？假设我的每一次计算花费
浏览 2提问于2016-06-10得票数 3
我的目标是创建一个与Kafka > Flink > ElasticSearch > Kibana相关的实时处理项目。我可以在Flink中使用卡夫卡的信息，但不能连接Flink和ElasticSearch。我如何发送卡夫卡信息Flink消费到ElasticSearch？
浏览 5提问于2022-07-01得票数 -1
回答已采纳
在每一开始，我们都试图了解流入DB和Flink之间的数据传输过程。我们的基本思想是: Flink读取来自influxDB的数据，Flink利用这些数据进行一些基于Flink的ML库的建模。但是，我们只找到一些开源存储库，它们提供了一个接收器，可以将数据从Flink发送到InfluxDB (例如Flink InfluxDB连接器)。因此，如果你知道一些好的例子，如我所描述的，请告诉我。
浏览 0提问于2019-12-12得票数 1
回答已采纳
1回答
我们如何实时监控flink作业。例如，如果作业失败，则会生成一些警报。是否存在任何外部库，或者flink中已有可用的库。提前谢谢。
浏览 14提问于2021-06-02得票数 1
我想使用NAT流服务器来流式传输数据，并使用Flink来处理数据。
如何通过NATS流服务器使用apache flink处理实时流数据？
浏览 8提问于2020-03-30得票数 2
1回答
我想用ALS算法在Apache Flink上实现一个实时推荐。为此，我需要一个起点，帮助我实现这个项目。
浏览 37提问于2021-02-20得票数 0
回答已采纳
1回答
我正在搜索一个低延迟图形DB，它允许深度查询，同时实时更新。是否可以通过Flink进程实时更新Dgraph？我想验证一个想法如下：
复制/提升最新版本的Dgraph以执行计算
浏览 1提问于2016-10-05得票数 1
回答已采纳
我需要使用flink-sql实时计算“每日活跃用户”，这就像是对每日数据的“count(distinct )”操作。
我的问题是，如果userA像预期的那样在凌晨1点登录，并且flink将DAU加1。现在，userA在晚上10点再次登录，flink-sql怎么知道今天早上userA已经被处理了？是否需要对全天的登录日志重复做count(distinct )？如果不是，flink如何处理这个senario？
浏览 6提问于2020-09-14得票数 0
2回答
在使用Scala代码将数据从输出NiFi端口传输到Flink方面，我需要一些帮助。import org.apache.flink.streaming.connectors.nifi.NiFiSourceimport org.apache.flink.streaming.api.functions.sourc
浏览 0提问于2017-07-17得票数 0
回答已采纳
我的项目目前构建在Azure上(数据存储在Azure SQL server中)，我目前正在尝试通过利用PyFilnk将流/批处理功能引入到我的项目中。但是，我没有找到任何关于如何将PyFlink连接到Azure SQL server的文档，有没有一种方法可以在PyFlink中使用Azure SQL server作为数据源？
浏览 13提问于2021-07-22得票数 0
2回答
我们知道Flink是一个真正的实时流处理引擎，它可以在记录到达时处理记录，我们也知道火花流是一个微批量流处理引擎。
然而，我们也知道星星之火发布了结构化的流媒体，它怎么样？它是否也是一个真正的实时流处理引擎，就像Flink一样，它可以在记录到达时立即处理记录，而不是微批处理，或者仍然使用微批处理模式？
浏览 3提问于2017-06-27得票数 3
回答已采纳
IBM MQ -> Kafka连接-> Flink -> MongoDBIBM MQ部件是不能更改的遗留组件。可能会使用confluent或cloudera平台来容纳流程中的Kafka和Flink部分。
我可以使用一些关于上述方法的想法/建议。
浏览 2提问于2019-02-23得票数 0
我是Flink的新手。如何了解flink的生产群集要求。以及如何在纱线集群模式下确定每个作业执行的作业内存、任务内存和任务槽。对于ex-我每天必须使用数据流处理大约6-7亿条记录，因为它是实时数据。
浏览 20提问于2020-07-11得票数 0
回答已采纳
2回答
我对flink (Java)很陌生，我试图将netapp文件服务器上的xml文件作为文件路径移动到安装了flink的服务器上。
如何实时进行批处理或流处理，以获取进入文件夹的文件并将其与s3合并。我在flink-starter中找不到从本地文件系统读取文件的例子，flink至少是这个用例的正确选择吗？如果是这样的话，我在哪里可以找到资源来监听文件夹和管理检查点/保存点？
浏览 0提问于2019-09-07得票数 0
回答已采纳
在火花流中，我们设置了几乎实时的微批处理的批处理间隔。在Flink (DataStream)或Storm中，流是实时的，所以我想没有这样的批处理间隔的概念。在卡夫卡，消费者在拉，我想象星火使用批参数从卡夫卡经纪人提取消息，那么Flink和Storm是如何做到的呢？我设想Flink和Storm在一个快速循环中拉出Kafka消息形成实时流源，如果是这样的话，如果我将火花批处理间隔设置为100 as、50 as甚至更小，那么我们是否与Flink或Storm之间有显著差异我没有
浏览 5提问于2016-10-24得票数 7
回答已采纳
虽然Flink网站上的所有文档都没有提到“外部状态”，但我们在一篇论文中遇到了这个概念(http://www.vldb.org/pvldb/vol10/p1718-carbone.pdf 4.1节)。
浏览 26提问于2020-09-03得票数 0
回答已采纳
我正在构建一个Flink流系统，它可以同时处理实时数据和历史数据。所有数据都来自同一个源，然后在split中进入历史和动态。实时数据得到时间戳和水印，而历史数据则按顺序接收.在活动流被加窗后，两个流被合并并流到相同的处理管道中。如果EventTime流环境中的所有记录都需要时间戳，或者Flink甚至可以同时处理这种实时和历史数据，我就找不到了。这是一个可行的方法，还是会造成我经验不足而看不到的问题？每个流都是由一个id键决定的，我们发送历史数据来替换一个id的观测数据，同时不影响其他id的实时</
浏览 2提问于2018-12-13得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
