[flink] branch master updated: [hotfix][runtime] Remove useless code in JSONGenerator

[pn...@apache.org]

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 <lz...@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());