Re: Flink MiniCluster: Multiple Task Managers

2022-05-17 Thread Κωνσταντίνος Αγαπίδης
l it. >> >> https://nightlies.apache.org/flink/flink-docs-master/api/java/org/apache/flink/runtime/minicluster/M >> niCluster.html#startTaskManager-- >> >> I thought that I need to get the current MiniCluster somehow, before >> starting the Job Excecution. But how? >> >> Thank you in advance! >> >> -- >> Best Regards, >> Kostas -- Με εκτίμηση, Κωνσταντίνος Αγαπίδης

Flink MiniCluster: Multiple Task Managers

2022-05-14 Thread Κωνσταντίνος Αγαπίδης
Hi list, I am using Java 8, Flink 1.15, and IntelliJ. I wonder if it is posible to open an additional TaskManager in a Stream Job in the Java code, to run it in IntelliJ Local Cluster (MiniCluster) Debug mode. I found this method in the code reference, but I don't know hot to call it. https://

Restore Job from CheckPoint in IntelliJ IDE - MiniCluster

2022-04-20 Thread Κωνσταντίνος Αγαπίδης
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 a