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