diff --git a/runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaRunner.java b/runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaRunner.java index 910f1aab4e85..669c0c1c5749 100644 --- a/runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaRunner.java +++ b/runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaRunner.java @@ -86,13 +86,9 @@ public PortablePipelineResult runPortablePipeline(RunnerApi.Pipeline pipeline, J final String dotGraph = PipelineDotRenderer.toDotString(pipeline); LOG.info("Portable pipeline to run DOT graph:\n{}", dotGraph); - final String jsonGraph = PipelineJsonRenderer.toJsonString(pipeline); - LOG.info("Portable pipeline to run JSON graph:\n{}", jsonGraph); - final ConfigBuilder configBuilder = new ConfigBuilder(options); SamzaPortablePipelineTranslator.createConfig(pipeline, configBuilder, options); configBuilder.put(BEAM_DOT_GRAPH, dotGraph); - configBuilder.put(BEAM_JSON_GRAPH, jsonGraph); final Config config = configBuilder.build(); options.setConfigOverride(config);