Re: Flink CEP 使用Keyby之后无法输出结果

Tue, 13 Apr 2021 20:07:40 -0700 

你这个数据是啥样，预期的结果是啥样。 KeyedStream 会为每个key单独去匹配的

HunterXHunter <[email protected]> 于2021年1月13日周三 下午5:41写道：

> Pattern.<KafkaTopicOffsetTimeMsg>begin("start")
>                         .where(new
> SimpleCondition<KafkaTopicOffsetTimeMsg>() {
>                             @Override
>                             public boolean filter(KafkaTopicOffsetTimeMsg
> kafkaTopicOffsetTimeMsg) throws Exception {
>                                 return
> kafkaTopicOffsetTimeMsg.msg().equals("start");
>                             }
>                         })
>                         .next("middle")
>                         .where(new
> SimpleCondition<KafkaTopicOffsetTimeMsg>() {
>                             @Override
>                             public boolean filter(KafkaTopicOffsetTimeMsg
> kafkaTopicOffsetTimeMsg) throws Exception {
>                                 return
> kafkaTopicOffsetTimeMsg.msg().equals("middle");
>                             }
>                         })
>
> 当我有next的时候 使用 KeyedStream 无法生效，使用DataStream 可以。
> 但是如果只有一个start的话，KeyedStream就可以生效了。
> 请教下：
> 这是 CEP本身设计的（可能是keyby之后无法保证有一个链路的数据会在一个task），还是我代码的问题？
>
>
>
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/
>

回复