Hi, currently I think there is no ha about gateway. When the gateway crashes,
the job about being submitted sync will be cancelled, and the async job will
continue running. When the gateway restarts, the async job could be found by
gateway. BTW, the work about ha is in continuous progress.
At
Thanks both for your advice, I will give them a try!
From: Schwalbe Matthias
Sent: 10 October 2022 08:35
To: 仙路尽头谁为峰 ; Qing Lim
Cc: User
Subject: RE: Re:Question about Flink Broadcast State event ordering
Hi Qing again,
Another point to consider: broadcast streams are subject to watermarking
the
time )
Best regards
Thias
From: 仙路尽头谁为峰
Sent: Wednesday, October 5, 2022 10:13 AM
To: Qing Lim
Cc: User
Subject: [SPAM] 回复: Re:Question about Flink Broadcast State event ordering
⚠EXTERNAL MESSAGE – CAUTION: Think Before You Click ⚠
Hi Qing:
The key point is that the broadcast
Oh, thank you for your explanation!
From: 仙路尽头谁为峰
Sent: 05 October 2022 09:13
To: Qing Lim
Cc: User
Subject: 回复: Re:Question about Flink Broadcast State event ordering
Hi Qing:
The key point is that the broadcast side may have different partitions that
interleaves. If you can make sure
收件人: xljtswf2022
抄送: User
主题: RE: Re:Question about Flink Broadcast State event ordering
Hi, thanks for answering my question.
Is there anyway to make the order reflecting the upstream? I wish to broadcast
messages that has deletion semantic, so ordering matters here.
I guess worst case I can
: 05 October 2022 03:02
To: Qing Lim
Cc: User
Subject: Re:Question about Flink Broadcast State event ordering
Hi Qing:
> I think this is refering to the order between broadcasted element and non
> broadcasted element, right?
No, as broadcast and nonbroadcast stream are different s
Hi Qing:
> I think this is refering to the order between broadcasted element and non
> broadcasted element, right?
No, as broadcast and nonbroadcast stream are different streams, they will
usually transfer with different tcp connection, we can not control the order of
elements in different
should be schema.field(“msg”, Types.ROW(...))?
And you should select msg.f1 from table.
Best
Jingsong Lee
来自阿里邮箱 iPhone版
--Original Mail --
From:圣眼之翼 <2463...@qq.com>
Date:2019-09-03 09:22:41
Recipient:user
Subject:question
How do you do:
My problem is flink
