You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pa...@apache.org on 2015/11/12 22:06:58 UTC

[6/8] storm git commit: Fixing a typo.

Fixing a typo.


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/9e6a3d1e
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/9e6a3d1e
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/9e6a3d1e

Branch: refs/heads/master
Commit: 9e6a3d1e5b9a175fe2a97958e050b6160819e977
Parents: 8fd0116
Author: Parth Brahmbhatt <br...@gmail.com>
Authored: Thu Nov 12 12:36:39 2015 -0800
Committer: Parth Brahmbhatt <br...@gmail.com>
Committed: Thu Nov 12 12:37:07 2015 -0800

----------------------------------------------------------------------
 storm-core/test/clj/backtype/storm/nimbus_test.clj | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/9e6a3d1e/storm-core/test/clj/backtype/storm/nimbus_test.clj
----------------------------------------------------------------------
diff --git a/storm-core/test/clj/backtype/storm/nimbus_test.clj b/storm-core/test/clj/backtype/storm/nimbus_test.clj
index 329308b..8f20064 100644
--- a/storm-core/test/clj/backtype/storm/nimbus_test.clj
+++ b/storm-core/test/clj/backtype/storm/nimbus_test.clj
@@ -20,7 +20,7 @@
   (:require [backtype.storm [converter :as converter]])
   (:import [backtype.storm.testing TestWordCounter TestWordSpout TestGlobalCount
             TestAggregatesCounter TestPlannerSpout TestPlannerBolt]
-           [backtype.storm.nimbus InMemoryTopologyAcitonNotifier])
+           [backtype.storm.nimbus InMemoryTopologyActionNotifier])
   (:import [backtype.storm.scheduler INimbus])
   (:import [backtype.storm.nimbus ILeaderElector NimbusInfo])
   (:import [backtype.storm.generated Credentials NotAliveException SubmitOptions
@@ -1341,10 +1341,10 @@
                         STORM-CLUSTER-MODE "local"
                         STORM-ZOOKEEPER-PORT zk-port
                         STORM-LOCAL-DIR nimbus-dir
-                        NIMBUS-TOPOLOGY-ACTION-NOTIFIER-PLUGIN (.getName InMemoryTopologyAcitonNotifier)}))
+                        NIMBUS-TOPOLOGY-ACTION-NOTIFIER-PLUGIN (.getName InMemoryTopologyActionNotifier)}))
           (bind cluster-state (cluster/mk-storm-cluster-state conf))
           (bind nimbus (nimbus/service-handler conf (nimbus/standalone-nimbus)))
-          (bind notifier (InMemoryTopologyAcitonNotifier.))
+          (bind notifier (InMemoryTopologyActionNotifier.))
           (sleep-secs 1)
           (bind topology (thrift/mk-topology
                            {"1" (thrift/mk-spout-spec (TestPlannerSpout. true) :parallelism-hint 3)}