From c32f086927f215091d3cf9fcdc3bafaf234df750 Mon Sep 17 00:00:00 2001
From: Rong Rong <walter_ddr@hotmail.com>
Date: Thu, 9 May 2019 17:39:21 -0700
Subject: [PATCH] fix checkstyle

---
 .../com/uber/athena/flux/flink/compiler/CompilationGraph.java  | 3 +--
 .../com/uber/athena/flux/flink/compiler/FluxCompilerSuite.java | 3 +--
 .../athena/flux/flink/runtime/FluxTopologyBuilderImpl.java     | 1 -
 3 files changed, 2 insertions(+), 5 deletions(-)

diff --git a/flink-flux-core/src/main/java/com/uber/athena/flux/flink/compiler/CompilationGraph.java b/flink-flux-core/src/main/java/com/uber/athena/flux/flink/compiler/CompilationGraph.java
index 61df0ee..19a7271 100644
--- a/flink-flux-core/src/main/java/com/uber/athena/flux/flink/compiler/CompilationGraph.java
+++ b/flink-flux-core/src/main/java/com/uber/athena/flux/flink/compiler/CompilationGraph.java
@@ -18,7 +18,6 @@
 
 package com.uber.athena.flux.flink.compiler;
 
-import com.uber.athena.flux.api.topology.FluxTopology;
 import com.uber.athena.flux.flink.runtime.FluxTopologyImpl;
 import com.uber.athena.flux.model.EdgeDef;
 import com.uber.athena.flux.model.OperatorDef;
@@ -48,7 +47,7 @@ public CompilationGraph(StreamExecutionEnvironment senv, FluxContext fluxContext
   }
 
   /**
-   * Compile current graph into a {@link FluxTopology}.
+   * Compile current graph into a {@code FluxTopology}.
    *
    * @return the topology
    */
diff --git a/flink-flux-core/src/main/java/com/uber/athena/flux/flink/compiler/FluxCompilerSuite.java b/flink-flux-core/src/main/java/com/uber/athena/flux/flink/compiler/FluxCompilerSuite.java
index 41244f8..a77e9e0 100644
--- a/flink-flux-core/src/main/java/com/uber/athena/flux/flink/compiler/FluxCompilerSuite.java
+++ b/flink-flux-core/src/main/java/com/uber/athena/flux/flink/compiler/FluxCompilerSuite.java
@@ -18,7 +18,6 @@
 
 package com.uber.athena.flux.flink.compiler;
 
-import com.uber.athena.flux.api.topology.FluxTopology;
 import com.uber.athena.flux.flink.runtime.FluxTopologyImpl;
 import com.uber.athena.flux.model.TopologyDef;
 import org.apache.flink.configuration.Configuration;
@@ -51,7 +50,7 @@ public FluxCompilerSuite(
   }
 
   /**
-   * compile topology definition to {@link FluxTopology}.
+   * compile topology definition to {@@code FluxTopology}.
    *
    * @return flux topology.
    */
diff --git a/flink-flux-core/src/main/java/com/uber/athena/flux/flink/runtime/FluxTopologyBuilderImpl.java b/flink-flux-core/src/main/java/com/uber/athena/flux/flink/runtime/FluxTopologyBuilderImpl.java
index fbd46c0..c18d8e8 100644
--- a/flink-flux-core/src/main/java/com/uber/athena/flux/flink/runtime/FluxTopologyBuilderImpl.java
+++ b/flink-flux-core/src/main/java/com/uber/athena/flux/flink/runtime/FluxTopologyBuilderImpl.java
@@ -20,7 +20,6 @@
 
 import com.uber.athena.flux.api.topology.FluxTopology;
 import com.uber.athena.flux.api.topology.FluxTopologyBuilder;
-import com.uber.athena.flux.api.topology.FluxTopologyExecutionResult;
 import com.uber.athena.flux.flink.compiler.FluxCompilerSuite;
 import com.uber.athena.flux.model.TopologyDef;
 import org.apache.flink.configuration.Configuration;