You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by zh...@apache.org on 2016/02/26 00:14:00 UTC
[5/7] storm git commit: Delete test for RuntimeException
Delete test for RuntimeException
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/46488044
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/46488044
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/46488044
Branch: refs/heads/master
Commit: 46488044b92567bd4ff21ba0299e575d8251f5ba
Parents: 26453a3
Author: zhuol <zh...@yahoo-inc.com>
Authored: Thu Feb 25 13:23:51 2016 -0600
Committer: zhuol <zh...@yahoo-inc.com>
Committed: Thu Feb 25 13:23:51 2016 -0600
----------------------------------------------------------------------
.../utils/WorkerBackpressureThreadTest.java | 19 -------------------
1 file changed, 19 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/46488044/storm-core/test/jvm/org/apache/storm/utils/WorkerBackpressureThreadTest.java
----------------------------------------------------------------------
diff --git a/storm-core/test/jvm/org/apache/storm/utils/WorkerBackpressureThreadTest.java b/storm-core/test/jvm/org/apache/storm/utils/WorkerBackpressureThreadTest.java
index dd42ac4..1b74f4b 100644
--- a/storm-core/test/jvm/org/apache/storm/utils/WorkerBackpressureThreadTest.java
+++ b/storm-core/test/jvm/org/apache/storm/utils/WorkerBackpressureThreadTest.java
@@ -46,23 +46,4 @@ public class WorkerBackpressureThreadTest extends TestCase {
Assert.assertNotEquals("Check the calling times of backpressure events, should not be 0. ",
workerData.get(), 0);
}
-
- @Test
- public void testThrowRuntimeExceptionEvent() throws Exception {
- Object trigger = new Object();
- Object workerData = new Object();
- WorkerBackpressureCallback callback = new WorkerBackpressureCallback() {
- @Override
- public void onEvent(Object obj) {
- throw new RuntimeException();
- }
- };
- WorkerBackpressureThread workerBackpressureThread = new WorkerBackpressureThread(trigger, workerData, callback);
- workerBackpressureThread.start();
- Thread.sleep(100);
- WorkerBackpressureThread.notifyBackpressureChecker(trigger);
- Thread.sleep(100);
- Assert.assertFalse("Check the aliveness of workerBackpressureThread after RuntimeException. ",
- workerBackpressureThread.isAlive());
- }
}