private String streamSpecToJson(StreamSpec streamSpec) {
    return String.format(STREAM_SPEC_JSON_FORMAT, streamSpec.getId(), streamSpec.getId(), streamSpec.getSystemName(),
        streamSpec.getPhysicalName());
  }
A test case to verify plan results in different hash in case of different intermediate stream.
Note: the overall JOB PLAN remains the same outside the scope of intermediate streams the sake of these test cases.
samza-core/src/test/java/org/apache/samza/execution/TestLocalJobPlanner.java