You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2015/08/04 08:21:27 UTC
[08/10] storm git commit: fix indent
fix indent
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/c5203ece
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/c5203ece
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/c5203ece
Branch: refs/heads/0.10.x-branch
Commit: c5203ece9a884453daa1b47ba0037bb2981256df
Parents: 17c74ce
Author: Derek Dagit <de...@yahoo-inc.com>
Authored: Wed Jul 22 12:17:59 2015 -0500
Committer: Jungtaek Lim <ka...@gmail.com>
Committed: Tue Aug 4 13:07:52 2015 +0900
----------------------------------------------------------------------
.../test/clj/backtype/storm/grouping_test.clj | 34 ++++++++++----------
1 file changed, 17 insertions(+), 17 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/c5203ece/storm-core/test/clj/backtype/storm/grouping_test.clj
----------------------------------------------------------------------
diff --git a/storm-core/test/clj/backtype/storm/grouping_test.clj b/storm-core/test/clj/backtype/storm/grouping_test.clj
index 9402842..2bfa066 100644
--- a/storm-core/test/clj/backtype/storm/grouping_test.clj
+++ b/storm-core/test/clj/backtype/storm/grouping_test.clj
@@ -21,23 +21,23 @@
(:use [backtype.storm.daemon common])
(:require [backtype.storm [thrift :as thrift]]))
- (deftest test-shuffle
- (with-simulated-time-local-cluster [cluster :supervisors 4]
- (let [topology (thrift/mk-topology
- {"1" (thrift/mk-spout-spec (TestWordSpout. true) :parallelism-hint 4)}
- {"2" (thrift/mk-bolt-spec {"1" :shuffle} (TestGlobalCount.)
- :parallelism-hint 6)
- })
- results (complete-topology cluster
- topology
- ;; important for test that
- ;; #tuples = multiple of 4 and 6
- :mock-sources {"1" (->> [["a"] ["b"]]
- (repeat 12)
- (apply concat))})]
- (is (ms= (apply concat (repeat 6 [[1] [2] [3] [4]]))
- (read-tuples results "2")))
- )))
+(deftest test-shuffle
+ (with-simulated-time-local-cluster [cluster :supervisors 4]
+ (let [topology (thrift/mk-topology
+ {"1" (thrift/mk-spout-spec (TestWordSpout. true) :parallelism-hint 4)}
+ {"2" (thrift/mk-bolt-spec {"1" :shuffle} (TestGlobalCount.)
+ :parallelism-hint 6)
+ })
+ results (complete-topology cluster
+ topology
+ ;; important for test that
+ ;; #tuples = multiple of 4 and 6
+ :mock-sources {"1" (->> [["a"] ["b"]]
+ (repeat 12)
+ (apply concat))})]
+ (is (ms= (apply concat (repeat 6 [[1] [2] [3] [4]]))
+ (read-tuples results "2")))
+ )))
(deftest test-field
(with-simulated-time-local-cluster [cluster :supervisors 4]