Hi
如果使用CEP,可以将两个流合并成一个流,然后通过subtype根据不同的事件类型来匹配,定义CEP的Pattern,例如以下这种
DataStream s1 = ...;
DataStream s2 = ...;
DataStream s = s1.union(s1)...;
Pattern = Pattern.begin("first")
.subtype(E1.class)
.where(...)
.followedBy("second")
.subtype(E2.class)
.where(...)
如果使用Flink
Hi,这个应该是FLINK-31839已经确定的ISSUE,在1.17.1中已经修复了,可以参考:
https://issues.apache.org/jira/browse/FLINK-31839
On Sat, May 6, 2023 at 5:00 PM maker_d...@foxmail.com <
maker_d...@foxmail.com> wrote:
> flink version:flink-1.17.0
> k8s application模式模式
>
> 已经在flink-conf中禁用delegation token:
>
如果需要取消订阅 user-zh@flink.apache.org 邮件组,请发送任意内容的邮件到
user-zh-unsubscr...@flink.apache.org ,参考[1]
[1] https://flink.apache.org/zh/community/
Best,
Yuxin
胡家发 <15802974...@163.com> 于2023年5月7日周日 22:14写道:
> 退订
需求:业务端实现支付功能,需要通过第三方支付平台的交易数据采用Flink SQL来做一个实时对账,对于超过30分钟内未到达的第三方支付平台交易数据进行告警。
请问这个双流实时对帐场景使用Flink CEP SQL要如何实现?
网上找的例子都是基于单条流实现的,而上述场景会用到两条流,一个是PlatformPaymentStream,另一个是ThirdPartyPaymentStream。
退订
The following is the content of the forwarded email
From:"胡家发" <15802974...@163.com>
To:user-zh
Date:2023-05-07 22:13:55
Subject:退订
退订
Please send email to user-zh-unsubscr...@flink.apache.org
if you want to unsubscribe the mail from
user-zh-unsubscr...@flink.apache.org , and you can
refer[1][2] for more details.
请发送任意内容的邮件到 user-zh-unsubscr...@flink.apache.org
地址来取消订阅来自 user-zh@flink.apache.org 邮件组的邮件,你可以参考[1][2] 管理邮件订阅。
退订