Re: Re: Looking for help with Job Initialisation issue

2024-05-09 Thread Keith Lee
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

SQL failed to restore from savepoint after change in default-parallelism

2024-05-08 Thread Keith Lee
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

Re: Re: Evolving Flink SQL statement set and restoring from savepoints

2024-05-08 Thread Keith Lee
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

Evolving Flink SQL statement set and restoring from savepoints

2024-05-07 Thread Keith Lee
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