Hello,
In a single JVM, I'm running multiple flink batch jobs locally using the
MiniCluster (Java 17 and Flink 1.18).
At the beginning of the process, the Mini Cluster starts pretty much instantly.
However, I'm running into an issue where the more jobs I execute the longer the
MiniCluster take
e.war/org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:112)
~[flink-core-1.18.0.jar:1.18.0]
at
java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1768)
~[?:?]
... 3 more
Thanks,
Dulce Morim
ent.java:2303)
at
org.apache.flink.api.java.io.jdbc.JDBCOutputFormat.writeRecord(JDBCOutputFormat.java:205)
... 4 more
Only have a generic exception:
org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
Thanks,
Dulce Morim
ion_key".
Is it possible to connect these two streams? In this solution there seems to be
a 1 to 1 relationship, but we want a one to many relationship. Should this be
solved via another process?
Thanks,
Dulce Morim
