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://nightlies.apache.org/flink/flink-docs-master/api/java/org/apache/flink/runtime/minicluster/MiniCluster.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

Reply via email to