Change DEFAULT-TIMEOUT-MS to read JVM Property
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/d92e974a Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/d92e974a Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/d92e974a Branch: refs/heads/security Commit: d92e974a113bcaba656dd777985c520c8c9a4dd8 Parents: 62f4f44 Author: Jungtaek Lim <[email protected]> Authored: Wed Oct 22 08:31:27 2014 +0900 Committer: Jungtaek Lim <[email protected]> Committed: Wed Oct 22 08:31:27 2014 +0900 ---------------------------------------------------------------------- storm-core/src/clj/backtype/storm/testing.clj | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/d92e974a/storm-core/src/clj/backtype/storm/testing.clj ---------------------------------------------------------------------- diff --git a/storm-core/src/clj/backtype/storm/testing.clj b/storm-core/src/clj/backtype/storm/testing.clj index 1ea1227..79d3277 100644 --- a/storm-core/src/clj/backtype/storm/testing.clj +++ b/storm-core/src/clj/backtype/storm/testing.clj @@ -188,7 +188,7 @@ (catch Exception e (log-message (.getMessage e)))) )) (def TEST-TIMEOUT-MS - (let [timeout (System/getenv "STORM_TEST_TIMEOUT_MS")] + (let [timeout (System/getProperty "STORM_TEST_TIMEOUT_MS")] (parse-int (if timeout timeout "5000")))) (defmacro while-timeout [timeout-ms condition & body]
