Hi Sean, I was looking for the max-parallelism value in the UI, but couldn't find it. Also the REST API does not seem to provide it. Would you mind opening a Jira issue for adding it to the REST API and the Web UI?
Thank you, Fabian Am Di., 30. Apr. 2019 um 06:36 Uhr schrieb Sean Bollin <s...@sean-bollin.com >: > Thanks! Do you know if it's possible somehow to verify the global > maxParallelism other than calling .getMaxParallelism? Either through > an API call or the UI? > > On Mon, Apr 29, 2019 at 8:12 PM Guowei Ma <guowei....@gmail.com> wrote: > > > > Hi, > > StreamExecutionEnvironment is used to set a default maxParallelism for > global. If a "operator"'s maxParallelism is -1 the operator will be set the > maxParallelism which is set by StreamExecutionEnvironment. > > > > >>>Any API or way I can verify? > > I can't find any easy way to do that. But you could use get the > StreamGraph from api StreamExecutionEnvironment.getStreamGraph and try to > print the StreamNode::maxParallelism. > > Best, > > Guowei > > > > > > Sean Bollin <s...@sean-bollin.com> 于2019年4月30日周二 上午8:19写道： > >> > >> Hi all, > >> > >> How do you verify what max parallelism is set to on the job level? I do > not see it in the 1.6 UI, for example. > >> > >> I’m setting maxParallelism to 4096 on the StreamExecutionEnvironment > before execution but printing out the maxParallelism in an operator still > displays -1. Since this is such an important setting I’d like some sanity > check to verify it is the value I expect. > >> > >> Any API or way I can verify? >
