same jobId, will it restore from the HA
first, or just start anew?
Best,
Shubham Bansal
On Sat, May 6, 2023 at 9:34 AM Weihua Hu wrote:
> Hi, Shubham
>
> Which Flink version are you using?
> AFAIK, the JobManager will recover the job from the HA store first, and it
> won't
Hello everyone,
Elastic scaling, as of now, has to be started in application mode. I am
having some trouble in making it work with HA.
I have a jobmanager pod and a single taskmanager pod, I use a post install
helm hook to start the jobmanager along with the single job (As it's
required in applica
would appreciate it if somebody can review these change sets as I want to
make the similar changes for 1.15 version after that.
Let me know if you need more information regarding this PR, I would be
happy to connect with you and explain the changes.
Thanks,
Shubham Bansal
Never mind. Figured out. Wrong connector arguments.
On Tue, May 10, 2022 at 11:19 PM Shubham Bansal <
shubham.bansal2...@gmail.com> wrote:
> Hi Everyone,
>
> I am trying to fix the flink-playground for version 1.14.4 and was working
> on fixing pyflink-walkthrough and I getti
Hi Everyone,
I am trying to fix the flink-playground for version 1.14.4 and was working
on fixing pyflink-walkthrough and I getting following error
Caused by: org.apache.flink.table.api.NoMatchingTableFactoryException:
Could not find a suitable table factory for
'org.apache.flink.table.factories.
