You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Κωνσταντίνος Αγαπίδης <cs...@csd.uoc.gr> on 2022/04/20 20:01:52 UTC
Restore Job from CheckPoint in IntelliJ IDE - MiniCluster
Hi everyone,
I have a technical question about a problem I am dealing with in my Flink Jobs. I am using
IntelliJ, Java 1.8 and Flink Version 1.15.0 Libraries and Maven Dependencies in my jobs.
I am trying to restore a job in Flink Minicluster Local Environment but I cannot find documentation
about this in the web. I found a deprecated solution in a mail archive, but it didn't work in my
case. First of all I want to ask if it is possible to restore a Job in my Intellij IDE when
executing a Job Locally (MiniCluster). I ask because I want to experiment with some concepts about
state management within IntelliJ, without building a jar and deploying my job.
Deprecated Solution: https://lists.apache.org/thread/q1nj5pvwy4t4t9q76z6gkqw64ydth1k0
Thank you in advance!
--
Best Regards,
Kostas
RE: Restore Job from CheckPoint in IntelliJ IDE - MiniCluster
Posted by Schwalbe Matthias <Ma...@viseca.ch>.
Happy to hear that
(back-posted to usr list)
Thias
-----Original Message-----
From: Κωνσταντίνος Αγαπίδης <cs...@csd.uoc.gr>
Sent: Friday, April 22, 2022 3:50 PM
To: Schwalbe Matthias <Ma...@viseca.ch>
Subject: Re: Restore Job from CheckPoint in IntelliJ IDE - MiniCluster
*** EXTERNAL MESSAGE – CAUTION: Think Before You Click ***
Hi Thias,
I set the "execution.savepoint.path" config option in the beggining of the job and it worked for me too. Thanks for your help!
Best Regards,
Kostas
21 Απριλίου 2022 10:20 ΠΜ, "Schwalbe Matthias" <Ma...@viseca.ch> έγραψε:
> Hi Kostas,
>
> Did you give setting execution.savepoint.path a try?
>
> You can set the property on local environment by means of env.configure(...).
> This work for me ... (didn't try yet on Flink 1.15)
>
> Thias
>
> [1]
> https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deploy
> ment/config/#execution-savepoi
> t-path
>
> -----Original Message-----
> From: Κωνσταντίνος Αγαπίδης <cs...@csd.uoc.gr>
> Sent: Wednesday, April 20, 2022 10:02 PM
> To: user@flink.apache.org
> Subject: Restore Job from CheckPoint in IntelliJ IDE - MiniCluster
>
> *** EXTERNAL MESSAGE – CAUTION: Think Before You Click ***
>
> Hi everyone,
>
> I have a technical question about a problem I am dealing with in my
> Flink Jobs. I am using IntelliJ, Java 1.8 and Flink Version 1.15.0 Libraries and Maven Dependencies in my jobs.
>
> I am trying to restore a job in Flink Minicluster Local Environment
> but I cannot find documentation about this in the web. I found a
> deprecated solution in a mail archive, but it didn't work in my case.
> First of all I want to ask if it is possible to restore a Job in my
> Intellij IDE when executing a Job Locally (MiniCluster). I ask because I want to experiment with some concepts about state management within IntelliJ, without building a jar and deploying my job.
>
> Deprecated Solution:
> https://lists.apache.org/thread/q1nj5pvwy4t4t9q76z6gkqw64ydth1k0
>
> Thank you in advance!
>
> --
> Best Regards,
> Kostas
> Diese Nachricht ist ausschliesslich für den Adressaten bestimmt und
> beinhaltet unter Umständen vertrauliche Mitteilungen. Da die
> Vertraulichkeit von e-Mail-Nachrichten nicht gewährleistet werden
> kann, übernehmen wir keine Haftung für die Gewährung der
> Vertraulichkeit und Unversehrtheit dieser Mitteilung. Bei irrtümlicher
> Zustellung bitten wir Sie um Benachrichtigung per e-Mail und um Löschung dieser Nachricht sowie eventueller Anhänge. Jegliche unberechtigte Verwendung oder Verbreitung dieser Informationen ist streng verboten.
>
> This message is intended only for the named recipient and may contain
> confidential or privileged information. As the confidentiality of
> email communication cannot be guaranteed, we do not accept any
> responsibility for the confidentiality and the intactness of this message. If you have received it in error, please advise the sender by return e-mail and delete this message and any attachments.
> Any unauthorised use or dissemination of this information is strictly prohibited.
Diese Nachricht ist ausschliesslich für den Adressaten bestimmt und beinhaltet unter Umständen vertrauliche Mitteilungen. Da die Vertraulichkeit von e-Mail-Nachrichten nicht gewährleistet werden kann, übernehmen wir keine Haftung für die Gewährung der Vertraulichkeit und Unversehrtheit dieser Mitteilung. Bei irrtümlicher Zustellung bitten wir Sie um Benachrichtigung per e-Mail und um Löschung dieser Nachricht sowie eventueller Anhänge. Jegliche unberechtigte Verwendung oder Verbreitung dieser Informationen ist streng verboten.
This message is intended only for the named recipient and may contain confidential or privileged information. As the confidentiality of email communication cannot be guaranteed, we do not accept any responsibility for the confidentiality and the intactness of this message. If you have received it in error, please advise the sender by return e-mail and delete this message and any attachments. Any unauthorised use or dissemination of this information is strictly prohibited.
RE: Restore Job from CheckPoint in IntelliJ IDE - MiniCluster
Posted by Schwalbe Matthias <Ma...@viseca.ch>.
Hi Kostas,
Did you give setting execution.savepoint.path a try?
You can set the property on local environment by means of env.configure(...).
This work for me ... (didn't try yet on Flink 1.15)
Thias
[1] https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/config/#execution-savepoint-path
-----Original Message-----
From: Κωνσταντίνος Αγαπίδης <cs...@csd.uoc.gr>
Sent: Wednesday, April 20, 2022 10:02 PM
To: user@flink.apache.org
Subject: Restore Job from CheckPoint in IntelliJ IDE - MiniCluster
*** EXTERNAL MESSAGE – CAUTION: Think Before You Click ***
Hi everyone,
I have a technical question about a problem I am dealing with in my Flink Jobs. I am using IntelliJ, Java 1.8 and Flink Version 1.15.0 Libraries and Maven Dependencies in my jobs.
I am trying to restore a job in Flink Minicluster Local Environment but I cannot find documentation about this in the web. I found a deprecated solution in a mail archive, but it didn't work in my case. First of all I want to ask if it is possible to restore a Job in my Intellij IDE when executing a Job Locally (MiniCluster). I ask because I want to experiment with some concepts about state management within IntelliJ, without building a jar and deploying my job.
Deprecated Solution: https://lists.apache.org/thread/q1nj5pvwy4t4t9q76z6gkqw64ydth1k0
Thank you in advance!
--
Best Regards,
Kostas
Diese Nachricht ist ausschliesslich für den Adressaten bestimmt und beinhaltet unter Umständen vertrauliche Mitteilungen. Da die Vertraulichkeit von e-Mail-Nachrichten nicht gewährleistet werden kann, übernehmen wir keine Haftung für die Gewährung der Vertraulichkeit und Unversehrtheit dieser Mitteilung. Bei irrtümlicher Zustellung bitten wir Sie um Benachrichtigung per e-Mail und um Löschung dieser Nachricht sowie eventueller Anhänge. Jegliche unberechtigte Verwendung oder Verbreitung dieser Informationen ist streng verboten.
This message is intended only for the named recipient and may contain confidential or privileged information. As the confidentiality of email communication cannot be guaranteed, we do not accept any responsibility for the confidentiality and the intactness of this message. If you have received it in error, please advise the sender by return e-mail and delete this message and any attachments. Any unauthorised use or dissemination of this information is strictly prohibited.