code: private static LocalEnvironment createLocalEnvironment(Configuration configuration, int defaultParallelism) {
  		final LocalEnvironment localEnvironment = new LocalEnvironment(configuration);
  
  		if (defaultParallelism > 0) {
  			localEnvironment.setParallelism(defaultParallelism);
  		}
  
  		return localEnvironment;
  	}
docs: Creates a {@link LocalEnvironment} which is used for executing Flink jobs.
  
  @param configuration to start the {@link LocalEnvironment} with
  @param defaultParallelism to initialize the {@link LocalEnvironment} with
  @return {@link LocalEnvironment}