@VisibleForTesting
  ApplicationMode getAppMode() {
    return new ApplicationConfig(config).getAppMode();
  }
Sets partition counts of intermediate streams which have not been assigned partition counts.
samza-core/src/main/java/org/apache/samza/execution/IntermediateStreamManager.java