Hi Abhi,
> We see that even when all the Taskslots of that particular operator are
stuck in an INITIALISING state
Can you include the stack trace of these threads so that we can understand
what the operators are stuck on INITIALISING?
Regards
Keith
On Thu, May 9, 2024 at 6:58 AM Abhi Sagar Khat
Hello,
After bumping 'table.exec.resource.default-parallelism' from 1 to 4, I am
observing the following exception on restoring job from savepoint with an
unmodified statement set.
[ERROR] Could not execute SQL statement. Reason:
> java.lang.IllegalStateException: Failed to rollback to
> checkpoi
Flink doesn't
> currently provide a way to directly force specific UIDs for operators
> through configuration or SQL hints. This is primarily due to how Flink's
> internal planner optimizes execution plans.
>
> Talat
>
>
> On Tue, May 7, 2024 at 8:42 AM Keith Lee
&g
Hello,
I'm running into issues restoring from savepoint after changing SQL
statement.
[ERROR] Could not execute SQL statement. Reason:
> java.lang.IllegalStateException: Failed to rollback to
> checkpoint/savepoint
> file:/tmp/flink-savepoints/savepoint-52c344-3bedb8204ff0. Cannot map
> checkpoin