From 37099d8ee68cd8c440bae34ed2aa0c7f30a4d3c2 Mon Sep 17 00:00:00 2001 From: Derek Dagit Date: Tue, 22 Dec 2015 14:46:37 -0600 Subject: [PATCH] removes multilang-test --- .../clj/backtype/storm/multilang_test.clj | 66 ------------------- 1 file changed, 66 deletions(-) delete mode 100644 storm-core/test/clj/backtype/storm/multilang_test.clj diff --git a/storm-core/test/clj/backtype/storm/multilang_test.clj b/storm-core/test/clj/backtype/storm/multilang_test.clj deleted file mode 100644 index b42a56f2b7d..00000000000 --- a/storm-core/test/clj/backtype/storm/multilang_test.clj +++ /dev/null @@ -1,66 +0,0 @@ -;; Licensed to the Apache Software Foundation (ASF) under one -;; or more contributor license agreements. See the NOTICE file -;; distributed with this work for additional information -;; regarding copyright ownership. The ASF licenses this file -;; to you under the Apache License, Version 2.0 (the -;; "License"); you may not use this file except in compliance -;; with the License. You may obtain a copy of the License at -;; -;; http://www.apache.org/licenses/LICENSE-2.0 -;; -;; Unless required by applicable law or agreed to in writing, software -;; distributed under the License is distributed on an "AS IS" BASIS, -;; WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -;; See the License for the specific language governing permissions and -;; limitations under the License. -(ns backtype.storm.multilang-test - (:use [clojure test]) - (:use [backtype.storm testing config]) - (:use [backtype.storm.daemon common]) - (:require [backtype.storm [thrift :as thrift]])) - -;; (deftest test-multilang-fy -;; (with-local-cluster [cluster :supervisors 4] -;; (let [nimbus (:nimbus cluster) -;; topology (thrift/mk-topology -;; {"1" (thrift/mk-spout-spec (TestWordSpout. false))} -;; {"2" (thrift/mk-shell-bolt-spec {"1" :shuffle} "fancy" "tester.fy" ["word"] :parallelism-hint 1)} -;; )] -;; (submit-local-topology nimbus -;; "test" -;; {TOPOLOGY-WORKERS 20 TOPOLOGY-MESSAGE-TIMEOUT-SECS 3 TOPOLOGY-DEBUG true} -;; topology) -;; (Thread/sleep 10000) -;; (.killTopology nimbus "test") -;; (Thread/sleep 10000) -;; ))) - - - (defn test-multilang - [executor file-extension] - (with-local-cluster [cluster :supervisors 4] - (let [nimbus (:nimbus cluster) - topology (thrift/mk-topology - {"1" (thrift/mk-shell-spout-spec [executor (str "tester_spout." file-extension)] ["word"])} - {"2" (thrift/mk-shell-bolt-spec {"1" :shuffle} [executor (str "tester_bolt." file-extension)] ["word"] :parallelism-hint 1)})] - (submit-local-topology nimbus - "test" - {TOPOLOGY-WORKERS 20 TOPOLOGY-MESSAGE-TIMEOUT-SECS 3 TOPOLOGY-DEBUG true} - topology) - (Thread/sleep 31000) - (.killTopology nimbus "test") - (Thread/sleep 11000) - ))) - - -(deftest test-python -(test-multilang "python" "py") -) - -(deftest test-ruby -(test-multilang "ruby" "rb") -) - -(deftest test-node -(test-multilang "node" "js") -)