Hi.
Turned out that the cause was non-replicated (replication factor = 1)
topics in Kafka.
On Wed, Jul 24, 2019 at 4:20 PM Yitzchak Lieberman <
yitzch...@sentinelone.com> wrote:
> Hi.
>
> Do we have an idea for this exception?
>
> Thanks,
> Yitzchak.
>
> On Tue, Jul 23, 2019 at 12:59 PM Fabian H
Hi Abhinav
If the leader jobmanager fails during savepoint, that savepoint would fail and
new jobmanager would then restore from previous jobgraph with latest completed
checkpoint in the high-availability storage. That's why new jobmanager could
not know anything with regard to previous savepoi
Hi,
Thanks for your reply. I have tried both CTE and sql subquery, but it seems
that sql plan
optimizer will do filter pushdown. Therefore, where conditions will end up
being together in
physical plan.
However, the visualization of physical plans on Flink UI were different for
these three SQL
que
