Re: Flink MiniCluster: Multiple Task Managers

2022-05-17 Thread Κωνσταντίνος Αγαπίδης
Hi Roman, Just used it. Thanks for your help. 14 Μαΐου 2022 10:06 ΜΜ, "Roman Grebennikov" έγραψε: > Hey Κωνσταντίνος, > > check out this sample code we use for testing > https://github.com/metarank/metarank . It is in > scala, but should be quite straightforward to port to java: > > val clus

Re: Flink MiniCluster: Multiple Task Managers

2022-05-14 Thread Roman Grebennikov
Hey Κωνσταντίνος, check out this sample code we use for testing https://github.com/metarank/metarank . It is in scala, but should be quite straightforward to port to java: val cluster = new MiniClusterWithClientResource( new MiniClusterResourceConfiguration.Builder() .setNumbe

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://