OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
verticesToDeploy = deploymentOptionsByVertex.keySet()verticesToDeploy = executionVertexDeploymentOptions.stream().map(ExecutionVertexDeploymentOption::getExecutionVertexId).collect(Collectors.toList())deploymentOptionsByVertex.keySet()executionVertexDeploymentOptions.stream().map(ExecutionVertexDeploymentOption::getExecutionVertexId).collect(Collectors.toList())flink24b77dbdfe072ab6087284b34f95e44b50e2610forg.apache.flink.runtime.scheduler.DefaultScheduler
_1267
_2267
_1verticesToDeploy
_2verticesToDeploy
xyzdeploymentOptionsByVertex.keySet()
  • java.util.stream.Collectors
xyzexecutionVertexDeploymentOptions.stream().map(ExecutionVertexDeploymentOption::getExecutionVertexId).collect(Collectors.toList())
AssignedToFalse