Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5652
@zentol To unblock this, I'd propose to add another constructor to
`MiniClusterResource` that takes a `enableClusterClient` parameter. Only if
that is true do we start in multi-actor-system mode.
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5652
@StephanEwen I think that's what the interface already does. For example,
`MiniClusterClient.submitJob()` does a `miniCluster.runDetached(jobGraph)`, and
`MiniClusterClient.cancel()` does
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5652
Would it work to have a "Flink Service" resource interface to which you can
submit jobs?
It may be backed by a cluster client or directly by the mini cluster, which
executes jobs
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5652
Could change `MiniClusterResource` to expect a `needsClusterClient()`
parameter or whatnot and normally start in single-actor-system mode. That's
probably what you had in mind ... ð
---
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5652
yup. But one profile is already scratching the 50m limit as is :/
---
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5652
We will see when we get the results from Travis for this one, right?
---
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5652
The alternative would be to make the `ClusterClient` functionality optional
and force tests to explicitly enable it.
---
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5652
All legacy tests going through the `MiniClusterResource` will take longer.
I don't know by how much, but we now have to start multiple actor systems and
the JM<->TM communication is no longer local.
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5652
Tests taking longer will be true for all tests or only those that use the
`ClusterClient`? What increase in time are we talking about?
---
