Re: 使用Flink SQL如何实现支付对帐超时告警？

[Shammon FY]

Hi

如果使用CEP，可以将两个流合并成一个流，然后通过subtype根据不同的事件类型来匹配，定义CEP的Pattern，例如以下这种
DataStream<E1> s1 = ...;
DataStream<E2> s2 = ...;
DataStream<E> s = s1.union(s1)...;
Pattern<Event, ?> = Pattern.begin("first")
    .subtype(E1.class)
    .where(...)
    .followedBy("second")
    .subtype(E2.class)
    .where(...)

如果使用Flink SQL，可以直接使用双流Join+窗口实现

Best,
Shammon FY




On Wed, May 10, 2023 at 2:24 AM casel.chen <casel_c...@126.com> wrote:

> 需求：业务端实现支付功能，需要通过第三方支付平台的交易数据采用Flink
> SQL来做一个实时对账，对于超过30分钟内未到达的第三方支付平台交易数据进行告警。
> 请问这个双流实时对帐场景使用Flink CEP SQL要如何实现？
>
> 网上找的例子都是基于单条流实现的，而上述场景会用到两条流，一个是PlatformPaymentStream，另一个是ThirdPartyPaymentStream。