1回答
我使用Flink DataStreams来加入两个流(一个是图书流，一个是出版商流)。我正在尝试使用evictor删除元素，以防它们被从数据库中删除，这由变量deleted表示。当我在没有evictor的情况下运行代码时，它工作得很好，但是当我添加evictor时，它失败了。value.id) .trigger(new ForeverTrigger<>())
.evictor:301
浏览 17提问于2021-04-30得票数 0
回答已采纳
flink流具有多个数据流，然后使用org.apache.flink.streaming.api.datastream.DataStream#union方法对这些数据流进行合并。然后，我得到了问题，数据流是混乱的，我不能设置窗口来对数据流中的数据进行排序。Sorting union of streams to identify user sessions in Apache Flink 我得到了答案，但com.liam.learn.flink.exam
浏览 30提问于2019-01-12得票数 2
我有一个管道，它使用Flink Global Window和基于事件时间的自定义触发器(从到达元素的时间戳开始)和Evictor，它从窗口中剪切不必要的元素并将其传递给ProcessFunction。.window(GlobalWindows.create()) .evictorapplySink(processedInput);
} 我知道我可以用提供水印操作的TestHarness测试MyWindowProcess
浏览 34提问于2021-11-18得票数 0
我已经编写了flink作业来使用数据集和数据流api。我已经从相同的main()方法启动了这两个程序，但现在当我将作业提交到flink Dashboard时。只有dataset api程序正在运行，仪表板显示作业已完成，流未被触发，flink仪表板也未显示有关数据流执行的任何内容。但是，当我从eclipse运行时，数据集和数据流api程序都在运行。是否有其他方法可以将作业提交给flink作业管理器以同时完成这两项工作？
浏览 16提问于2017-07-12得票数 1
org.apache.flink.streaming.api.TimeCharacteristicimport org.apache.flink.streaming.api.windowing.evictors.CountEvictor/&#x
浏览 26提问于2020-06-26得票数 0
回答已采纳
我正在为流分析方案评估Flink，并且还没有找到关于如何实现我们今天在遗留系统中所做的一种ETL设置的足够信息。一个非常常见的场景是，我们使用了关键的、慢吞吐量的元数据流，我们希望使用这些数据流在高吞吐量数据流上进行丰富，如下所示：这就引出了两个关于Flink的问题:如何通过缓慢更新时间窗口重叠但不相等的流来丰富快速移动的流如何有效地将多个(最多10个)数据流与Flink连接起来，比如一个数据流和9个不同的富集流？我知道我可以使用非窗口的外
浏览 3提问于2017-11-21得票数 1
回答已采纳
1回答
我正在尝试使用Flink以流的热情从消息队列中使用一个有限制的数据。GlobalWindow> fooWindow = fooDataStream.windowAll(GlobalWindows.create()).evictor(new Evictor<Foo, GlobalWindow>() { public void evictBefore(Iterable<TimestampedValue我还在研
浏览 0提问于2021-11-03得票数 0
回答已采纳
1回答
我正在尝试根据数据库中的某些规则从一个原始数据流中创建新的数据流。启动Flink作业后，如果我需要根据数据库中更新的条目创建新的数据流，我如何才能做到这一点。因此，这里我不想重新启动Flink作业，而是在运行时动态创建新的数据流，并将其添加到执行DAG中。
浏览 4提问于2016-06-27得票数 2
我正在尝试将基于Flink 0.10.1的示例迁移到Flink 1.1.1。示例中使用的TaxiRideSource数据流源实现了Flink 1.x不再提供的org.apache.flink.streaming.api.functions.source.EventTimeSourceFunction如何将TaxiRideSource移植到Flink 1.x？
浏览 2提问于2016-09-07得票数 1
回答已采纳
我有一个flink数据流，我正在使用KeyedProcessFunction对其进行一些处理，然后我需要在处理后将数据保存在MongoDB中，但我无法这样做。谁能给我一些关于如何将数据从flink数据流保存到Mongo的输入？
浏览 19提问于2020-12-09得票数 0
回答已采纳
我想知道，无论如何，Flink的数据流API是否可以用来从传入的记录中删除重复项(可能是在特定的时间窗口内)，就像Dataset API一样，它提供了一个称为"Distinct“的转换。或者，如果数据集被转换为数据流以便在Flink中进行内部处理，则无论如何都可以将该数据集转换为数据流。
在这方面请帮帮我。提前感谢！干杯!
浏览 1提问于2020-03-05得票数 0
给定来自Kafka的数据流，是否有内置的方法，或者执行SQL查找的最有效方法是什么。 例如，将流对象连接到sql表，并将其与Kafka数据流连接。给定可以在自组织基础上更新的sql表，
浏览 16提问于2020-04-15得票数 0
回答已采纳
1回答
一个键的多个会话窗口
、、、、
我正努力在flink中实现一个特定的自定义窗口。问题是这样的:我有一个特定身份的密钥流。对于流中的每个新元素，我需要为每个id保存多个“会话窗口”。
浏览 10提问于2021-12-29得票数 0
在处理每个数据流的多个数据流和多个操作符时，我试图理解Flink的运行时方面。用例:单个flink作业中的n个数据流(每个数据流代表一个设备--具有不同的时间延迟)，每个数据流被分成两个流，其中一个流被分成几个CEP操作符，另一个流为一个进程函数。问题：
在作业开始时，可以在运行时动态创建数据流吗？
浏览 2提问于2017-11-09得票数 1
1回答
我想用ALS算法在Apache Flink上实现一个实时推荐。为此，我需要一个起点，帮助我实现这个项目。
浏览 37提问于2021-02-20得票数 0
回答已采纳
众所周知，Flink有两个核心mode.So (数据流/数据集)，但是当我使用flink Sql客户端提交作业时，我不需要选择流或批处理API，因为Flink SQL客户端如何决定使用批处理模式和流模式那么，我想知道Flink SQL Client如何区分批处理模式和流模式？
浏览 29提问于2019-12-23得票数 0
回答已采纳
我希望在给定的键和公共窗口上加入三个或多个数据流或表。但是，我不知道如何正确地编写代码。正式文档给出了下面的示例，但是它只是连接两个数据流，那么如何在给定的键和公共窗口上连接三个或多个数据流？.});对于FlinK表API和SQ
浏览 1提问于2018-06-13得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
