小编Vin*_*til的帖子

流中记录的顺序

这是我的一些查询:

我有两个不同的流stream1stream2其中的元素是按顺序排列的。

1)现在,当我keyBy在这些流中的每一个上执行操作时,顺序会保持不变吗?(由于这里的每个小组将仅发送给一个任务管理器)我的理解是,记录将按小组的顺序排列,请在此处更正。

2)在keyBy两个流上之后,我正在共同分组以获取匹配和不匹配的记录。会将订单也保持在这里?因为这也适用于KeyedStream。我正在使用EventTime,并AscendingTimestampExtractor用于生成timestampwatermark

3)现在,我想matching_nonMatchingStream使用map / flatmap对2)得到的序列执行序列检查。我是否需要再次执行keyBy此处操作,或者如果保持连锁状态,则matching_nonMatchingStream运行是否相同TaskManager?我的理解是,链条将在这里起作用,纠正我,变得困惑。

4)slotSharingGroup-您能否根据文档详细说明:设置此操作的插槽共享组。TaskManager如果可能,在同一插槽共享组中的并行操作实例将位于同一插槽中。

apache-flink flink-streaming

1
推荐指数
1
解决办法
2866
查看次数

标签 统计

apache-flink ×1

flink-streaming ×1