This is an automated email from the ASF dual-hosted git repository. pnowojski pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push: new 3c79338 [hotfix][runtime] Remove useless code in JSONGenerator 3c79338 is described below commit 3c7933810e2c21ee7dd69ea095fb54fdf7baaedc Author: JingsongLi <lzljs3620...@aliyun.com> AuthorDate: Sun May 5 10:47:13 2019 +0800 [hotfix][runtime] Remove useless code in JSONGenerator --- .../main/java/org/apache/flink/streaming/api/graph/JSONGenerator.java | 3 --- 1 file changed, 3 deletions(-) diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/JSONGenerator.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/JSONGenerator.java index 3f82cf3..b4dee36 100644 --- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/JSONGenerator.java +++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/JSONGenerator.java @@ -18,7 +18,6 @@ package org.apache.flink.streaming.api.graph; import org.apache.flink.annotation.Internal; -import org.apache.flink.streaming.api.operators.StreamOperator; import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper; import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.node.ArrayNode; @@ -187,8 +186,6 @@ public class JSONGenerator { node.put(PACT, "Operator"); } - StreamOperator<?> operator = streamGraph.getStreamNode(vertexID).getOperator(); - node.put(CONTENTS, vertex.getOperatorName()); node.put(PARALLELISM, streamGraph.getStreamNode(vertexID).getParallelism());