Remove redundant dependencies

chakra-coder · Nov 25, 2018 · 9bf1a5b · 9bf1a5b
1 parent ca63756
commit 9bf1a5b
Show file tree

Hide file tree

Showing 5 changed files with 0 additions and 5 deletions.
diff --git a/sylph-docs/src/main/docs/themes/docs/source/images/sylph/strteam_sql.png b/sylph-docs/src/main/docs/themes/docs/source/images/sylph/strteam_sql.png
diff --git a/sylph-runners/flink/src/main/java/ideal/sylph/runner/flink/FlinkRunner.java b/sylph-runners/flink/src/main/java/ideal/sylph/runner/flink/FlinkRunner.java
@@ -68,7 +68,6 @@ public Set<JobActuatorHandle> create(RunnerContext context)
             }
             Bootstrap app = new Bootstrap(
                     new FlinkRunnerModule(),
-                    new YarnModule(),
                     binder -> {
                         //----------------------------------
                         binder.bind(PipelinePluginManager.class)

diff --git a/sylph-runners/spark/src/main/java/ideal/sylph/runner/spark/SparkRunner.java b/sylph-runners/spark/src/main/java/ideal/sylph/runner/spark/SparkRunner.java
@@ -56,7 +56,6 @@ public Set<JobActuatorHandle> create(RunnerContext context)
 
             Bootstrap app = new Bootstrap(
                     new SparkRunnerModule(),
-                    new YarnModule(),
                     binder -> {
                         //------------------------
                         binder.bind(PipelinePluginManager.class)

diff --git a/sylph-runners/spark/src/main/java/ideal/sylph/runner/spark/SparkRunnerModule.java b/sylph-runners/spark/src/main/java/ideal/sylph/runner/spark/SparkRunnerModule.java
@@ -18,7 +18,6 @@
 import com.google.inject.Binder;
 import com.google.inject.Module;
 import com.google.inject.Scopes;
-import ideal.sylph.runner.spark.yarn.SparkAppLauncher;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -33,6 +32,5 @@ public void configure(Binder binder)
         binder.bind(StreamEtlActuator.class).in(Scopes.SINGLETON);
         binder.bind(Stream2EtlActuator.class).in(Scopes.SINGLETON);
         binder.bind(SparkSubmitActuator.class).in(Scopes.SINGLETON);
-        binder.bind(SparkAppLauncher.class).in(Scopes.SINGLETON);
     }
 }
diff --git a/sylph-runners/spark/src/main/java/ideal/sylph/runner/spark/Stream2EtlActuator.java b/sylph-runners/spark/src/main/java/ideal/sylph/runner/spark/Stream2EtlActuator.java
@@ -37,7 +37,6 @@
 public class Stream2EtlActuator
         extends EtlJobActuatorHandle
 {
-    @Inject private YarnClient yarnClient;
     @Inject private PipelinePluginManager pluginManager;
 
     @NotNull