fix checkstyle

walterddr · May 10, 2019 · c32f086 · c32f086
1 parent a93df6d
commit c32f086
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 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
@@ -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
@@ -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/...k-flux-core/src/main/java/com/uber/athena/flux/flink/runtime/FluxTopologyBuilderImpl.java b/...k-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;