开发者社区> 问答> 正文

求助:Flink DataStream 的 windowoperator 后面apply 方法不执行

streamSource.flatMap(new ComeIntoMaxFlatMapFunction())

.assignTimestampsAndWatermarks(new CommonAssignerPeriodWatermarks<>(Time.seconds(1).toMilliseconds()))

.connect(ruleConfigSource) .process(new MetricDataFilterProcessFunction()) .keyBy((KeySelector<Metric, MetricDataKey>) metric -> { MetricDataKey metricDataKey = new MetricDataKey(); metricDataKey.setDomain(metric.getDomain()); metricDataKey.setStationAliasCode(metric.getStaId()); metricDataKey.setEquipMK(metric.getEquipMK()); metricDataKey.setEquipID(metric.getEquipID()); metricDataKey.setMetric(metric.getMetric()); return metricDataKey; })

.window(SlidingEventTimeWindows.of(Time.seconds(2), Time.seconds(1))) .apply(new RichWindowFunction<Metric, MetricDataList, MetricDataKey, TimeWindow>() { @Override public void apply(MetricDataKey tuple, TimeWindow window, Iterable input, Collector out) throws Exception { input.forEach(x->{ System.out.println("--->>>"+x); }); } })

我定义这个Topology中能正常执行keyBy,但是无法执行apply中的 System.out.println("--->>>"+x); *来自志愿者整理的flink邮件归档

展开
收起
小阿矿 2021-12-03 16:45:00 928 0
1 条回答
写回答
取消 提交回答
  • 应该是 window 还没达到触发的条件,可以看下 watermark 是否在推进

    *来自志愿者整理的flink邮件归档

    2021-12-06 11:24:05
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载