I found in the “Flip6LocalStreamEnvironment” the following code, but with the
caveat that it doesn’t include slot reuse?
int slotsCount = 0;
for (org.apache.flink.runtime.jobgraph.JobVertex jobVertex :
flink.getStreamGraph().getJobGraph().getVertices()) {
slotsCount += jobVertex.getParallelism();
}
--
Jared Stehler
Chief Architect - Intellify Learning
o: 617.701.6330 x703
> On Oct 27, 2017, at 2:30 PM, Jared Stehler
> <jared.steh...@intellifylearning.com> wrote:
>
> Is there a way to determine via an API the required number of task manager
> slots for a particular job graph? I’ve looked at
> "flink.getStreamGraph().getJobGraph().getNumberOfVertices()” but it doesn’t
> seem to correspond with what the job actually ends up using.
>
> --
> Jared Stehler
> Chief Architect - Intellify Learning
> o: 617.701.6330 x703
>
>
>
