flinkSQL无法实现两个timestamp(3) 相减

2023-03-06 Thread
我们需要对两个时间相减,精度为毫秒。但是无论是TIMESTAMPDIFF函数,还是先转成UNIX_TIMESTAMP,都只支持秒的精度。请问还有其他方法吗?

Re: flink taskmanger重启失败的问题

2023-02-23 Thread
, > Weihua > > > On Thu, Feb 23, 2023 at 11:16 AM 唐世伟 wrote: > >> 我们有一个flink任务,同时写10几张doris表,每次doris出问题的时候任务就挂,flink的重启策略没有效果。 >> flink的重启配置入下: >> restart-strategy: failure-rate >> restart-strategy.failure-rate.delay: 60 s >> restart-strategy.failure-ra

flink taskmanger重启失败的问题

2023-02-22 Thread
我们有一个flink任务,同时写10几张doris表,每次doris出问题的时候任务就挂,flink的重启策略没有效果。 flink的重启配置入下: restart-strategy: failure-rate restart-strategy.failure-rate.delay: 60 s restart-strategy.failure-rate.failure-rate-interval: 10 min restart-strategy.failure-rate.max-failures-per-interval: 3

Re: batch mode如何同步等待执行结果

2022-11-08 Thread
谢谢回复,这个应该只能在table api或者sql的情况下使用,stream api应该不行吧 > 2022年11月8日 下午8:10,yuxia 写道: > > set table.dml-sync = true > 是不是可以 > > Best regards, > Yuxia > > - 原始邮件 - > 发件人: "唐世伟" > 收件人: "user-zh" > 发送时间: 星期二, 2022年 11 月 08日 下午 8:06:1

batch mode如何同步等待执行结果

2022-11-08 Thread
通过./bin/flink run 提交一个batch mode的任务到yarn集群。命令只会返回任务是否正常被提交并返回applicationId。任务本身是否执行成功不会返回。当我们通过离线调度平台来调度flink batch任务的时候,没法捕捉到任务执行结果。请问有什么方式可以同步等待执行结果的吗?