fix indent
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/e4cd21a6 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/e4cd21a6 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/e4cd21a6 Branch: refs/heads/master Commit: e4cd21a6628c376da411b5cc4076226789e75baa Parents: 639f6a7 Author: Derek Dagit <der...@yahoo-inc.com> Authored: Wed Jul 22 12:17:59 2015 -0500 Committer: Derek Dagit <der...@yahoo-inc.com> Committed: Wed Jul 22 12:17:59 2015 -0500 ---------------------------------------------------------------------- .../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/e4cd21a6/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]
