You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2016/01/04 22:35:39 UTC
[2/4] storm git commit: Fixing missing includes.
Fixing missing includes.
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/6c958879
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/6c958879
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/6c958879
Branch: refs/heads/master
Commit: 6c95887945bd7fe845b9d399b5969d52cf7295da
Parents: 96939d4
Author: Kyle Nusbaum <Ky...@gmail.com>
Authored: Wed Dec 16 17:00:51 2015 -0600
Committer: Kyle Nusbaum <Ky...@gmail.com>
Committed: Wed Dec 16 17:00:51 2015 -0600
----------------------------------------------------------------------
storm-core/src/clj/backtype/storm/daemon/executor.clj | 1 +
storm-core/src/clj/backtype/storm/daemon/nimbus.clj | 1 +
storm-core/src/clj/backtype/storm/daemon/supervisor.clj | 1 +
storm-core/src/clj/backtype/storm/daemon/worker.clj | 1 +
4 files changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/6c958879/storm-core/src/clj/backtype/storm/daemon/executor.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/backtype/storm/daemon/executor.clj b/storm-core/src/clj/backtype/storm/daemon/executor.clj
index 7a079fe..84c64aa 100644
--- a/storm-core/src/clj/backtype/storm/daemon/executor.clj
+++ b/storm-core/src/clj/backtype/storm/daemon/executor.clj
@@ -34,6 +34,7 @@
(:import [backtype.storm.daemon Shutdownable])
(:import [backtype.storm.metric.api IMetric IMetricsConsumer$TaskInfo IMetricsConsumer$DataPoint StateMetric])
(:import [backtype.storm Config Constants])
+ (:import [backtype.storm.cluster ClusterStateContext DaemonType])
(:import [backtype.storm.grouping LoadAwareCustomStreamGrouping LoadAwareShuffleGrouping LoadMapping ShuffleGrouping])
(:import [java.util.concurrent ConcurrentLinkedQueue])
(:require [backtype.storm [tuple :as tuple] [thrift :as thrift]
http://git-wip-us.apache.org/repos/asf/storm/blob/6c958879/storm-core/src/clj/backtype/storm/daemon/nimbus.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/backtype/storm/daemon/nimbus.clj b/storm-core/src/clj/backtype/storm/daemon/nimbus.clj
index 6978547..287de02 100644
--- a/storm-core/src/clj/backtype/storm/daemon/nimbus.clj
+++ b/storm-core/src/clj/backtype/storm/daemon/nimbus.clj
@@ -47,6 +47,7 @@
BeginDownloadResult ListBlobsResult ComponentPageInfo TopologyPageInfo LogConfig LogLevel LogLevelAction
ProfileRequest ProfileAction NodeInfo])
(:import [backtype.storm.daemon Shutdownable])
+ (:import [backtype.storm.cluster ClusterStateContext DaemonType])
(:use [backtype.storm util config log timer zookeeper local-state])
(:require [backtype.storm [cluster :as cluster]
[converter :as converter]
http://git-wip-us.apache.org/repos/asf/storm/blob/6c958879/storm-core/src/clj/backtype/storm/daemon/supervisor.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/backtype/storm/daemon/supervisor.clj b/storm-core/src/clj/backtype/storm/daemon/supervisor.clj
index 310b1c5..2568861 100644
--- a/storm-core/src/clj/backtype/storm/daemon/supervisor.clj
+++ b/storm-core/src/clj/backtype/storm/daemon/supervisor.clj
@@ -19,6 +19,7 @@
[backtype.storm.utils LocalState Time Utils]
[backtype.storm.daemon Shutdownable]
[backtype.storm Constants]
+ [backtype.storm.cluster ClusterStateContext DaemonType]
[java.net JarURLConnection]
[java.net URI]
[org.apache.commons.io FileUtils])
http://git-wip-us.apache.org/repos/asf/storm/blob/6c958879/storm-core/src/clj/backtype/storm/daemon/worker.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/backtype/storm/daemon/worker.clj b/storm-core/src/clj/backtype/storm/daemon/worker.clj
index 09fe3a1..f265bb2 100644
--- a/storm-core/src/clj/backtype/storm/daemon/worker.clj
+++ b/storm-core/src/clj/backtype/storm/daemon/worker.clj
@@ -36,6 +36,7 @@
(:import [backtype.storm.task WorkerTopologyContext])
(:import [backtype.storm Constants])
(:import [backtype.storm.security.auth AuthUtils])
+ (:import [backtype.storm.cluster ClusterStateContext DaemonType])
(:import [javax.security.auth Subject])
(:import [java.security PrivilegedExceptionAction])
(:import [org.apache.logging.log4j LogManager])