Re: 退订
如果需要取消订阅 u...@flink.apache.org 和 d...@flink.apache.org 邮件组,请发送任意内容的邮件到 user-unsubscr...@flink.apache.org 和 dev-unsubscr...@flink.apache.org ,参考[1] [1] https://flink.apache.org/zh/community/ On Fri, May 5, 2023 at 3:24 PM wuzhongxiu wrote: > 退订 > > > > | | > go574...@163.com > | > | > 邮箱:go574...@163.com > | > > > > > 回复的原邮件 > | 发件人 | willluzheng | > | 日期 | 2023年05月05日 15:22 | > | 收件人 | user-zh@flink.apache.org | > | 抄送至 | | > | 主题 | 退订 | > 退订
Re: 退订
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] 管理邮件订阅。 On Fri, May 5, 2023 at 2:59 PM 李浩 wrote: > >
Re: 退订
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] 管理邮件订阅。 Best Hongshun, [1] https://flink.apache.org/zh/community/#%e9%82%ae%e4%bb%b6%e5%88%97%e8%a1%a8 [2]https://flink.apache.org/community.html#mailing-lists On Tue, May 2, 2023 at 9:45 PM 胡家发 <15802974...@163.com> wrote: > 退订
Re: 退订
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] 管理邮件订阅。 Best Hongshun, [1] https://flink.apache.org/zh/community/#%e9%82%ae%e4%bb%b6%e5%88%97%e8%a1%a8 [2]https://flink.apache.org/community.html#mailing-lists On Sun, Apr 23, 2023 at 10:30 PM 朱静 wrote: > 退订
Re: flink issue可以登录,但是flink中文邮箱账号密码错误,是出现什么原因了嘛
> > flink issue可以登录 这个是jira账号吗? flink中文邮箱账号密码 什么是flink中文邮箱账号 ?有无登陆页面链接 On Wed, Apr 19, 2023 at 11:36 AM kcz <573693...@qq.com.invalid> wrote: > 请帮忙看看是我哪里出问题了嘛?我的账号是kcz。我想咨询大佬flink avro的问题 > > > > > kcz > 573693...@qq.com > > > >
Re: streaming.api.operators和streaming.runtime.operators的区别是啥?
我来谈一下我个人的看法,streaming.api.operators是提供给用户使用的stream api, 用户可以使用和扩展该接口。而streaming.runtime.operators是用户侧不感知,在执行时由flink自动调用的。比如: Sink用户可以自己设置,如kafkaSink。但是输出时的state处理和事务commit(CommitterOperator)是Flink根据不同类型的Sink自动生成的统一逻辑,用户无需自己设置和实现。 Best Hongshun On Sat, May 6, 2023 at 11:57 AM yidan zhao wrote: > 如题,想知道这个分类的标准是啥呢? >
Re: 退订
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] 管理邮件订阅。 Best Hongshun, [1] https://flink.apache.org/zh/community/#%e9%82%ae%e4%bb%b6%e5%88%97%e8%a1%a8 [2]https://flink.apache.org/community.html#mailing-lists On Fri, Apr 21, 2023 at 10:50 AM 杨光跃 wrote: > > > 退订 > | | > 杨光跃 > | > | > yangguangyuem...@163.com > | > >
Re: 退订
Please send email to user-zh-unsubscr...@flink.apache.org < de...@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] 管理邮件订阅。 Best Hongshun, [1] https://flink.apache.org/zh/community/#%e9%82%ae%e4%bb%b6%e5%88%97%e8%a1%a8 [2]https://flink.apache.org/community.html#mailing-lists On Sat, May 6, 2023 at 12:52 PM willluzheng wrote: > >
Re: 退订
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] 管理邮件订阅。 Best Hongshun, [1] https://flink.apache.org/zh/community/#%e9%82%ae%e4%bb%b6%e5%88%97%e8%a1%a8 [2]https://flink.apache.org/community.html#mailing-lists On Sun, May 7, 2023 at 10:14 PM 胡家发 <15802974...@163.com> wrote: > 退订
Re: 使用Flink SQL如何实现支付对帐超时告警?
Hi casel.chen, 我理解你的意思是: 希望在ThirdPartyPaymentStream一条数据达到的30分钟后,*再触发查询* ,如果此时该数据在PlatformPaymentStream中还未出现,说明超时未支付,则输入到下游。而不是等ThirdPartyPaymentStream数据达到时再判断是否超时,因为此时虽然超时达到,但是也算已支付,没必要再触发报警了。 如果是流计算,可以采用timer定时器延时触发。 对于sql, 我个人的一个比较绕的想法是(供参考,不一定对):是通过Pulsar Sink(或RocketMQ等有延迟队列的消息中间件)将PlatformPaymentStream的数据写入延迟队列(30分钟)[1], 然后延迟消费为PlatformPaymentStream2。然后将PlatformPaymentStream2 *left join* ThirdPartyPaymentStream, 如果join后的结果不包含ThirdPartyPaymentStream部分,说明没有及时付款。 [1] https://nightlies.apache.org/flink/flink-docs-master/zh/docs/connectors/datastream/pulsar/#%e6%b6%88%e6%81%af%e5%bb%b6%e6%97%b6%e5%8f%91%e9%80%81 Best Hongshun On Wed, May 10, 2023 at 8:45 AM Shammon FY wrote: > 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 SQL,可以直接使用双流Join+窗口实现 > > Best, > Shammon FY > > > > > On Wed, May 10, 2023 at 2:24 AM casel.chen wrote: > > > 需求:业务端实现支付功能,需要通过第三方支付平台的交易数据采用Flink > > SQL来做一个实时对账,对于超过30分钟内未到达的第三方支付平台交易数据进行告警。 > > 请问这个双流实时对帐场景使用Flink CEP SQL要如何实现? > > > > > 网上找的例子都是基于单条流实现的,而上述场景会用到两条流,一个是PlatformPaymentStream,另一个是ThirdPartyPaymentStream。 >
Re: 退订
如果需要取消订阅 user-zh@flink.apache.org 邮件组,请发送任意内容的邮件到 user-zh-unsubscr...@flink.apache.org ,参考[1] [1] https://flink.apache.org/zh/community/ On Wed, May 10, 2023 at 1:38 AM Zhanshun Zou wrote: > 退订 >
Re: Re:RE: RE: flink cdc动态加表不生效
Hi, casel chan, 社区已经对增量框架实现动态加表(https://github.com/apache/flink-cdc/pull/3024 ),预计3.1对mongodb和postgres暴露出来,但是Oracle和Sqlserver目前并没暴露,你可以去社区参照这两个框架,将参数打开,并且测试和适配。 Best, Hongshun