diff options
| author | Anton Gozhiy <anton5813@gmail.com> | 2018-09-11 12:31:41 +0300 |
|---|---|---|
| committer | Sorabh Hamirwasia <sorabh@apache.org> | 2018-09-14 08:46:35 -0700 |
| commit | 2bb0294026960d0cec3bb78516b168ff231d2096 (patch) | |
| tree | afcf33d59d178470428678ea2b92f2783666bd53 /contrib | |
| parent | f88a73c9e7a75f2d08cc54188816f591b003eff4 (diff) | |
DRILL-6733: Unit tests from KafkaFilterPushdownTest are failing in some environments.
Added a check that prevents the cluster tear down if TestKafkaSuit is not running.
Diffstat (limited to 'contrib')
| -rw-r--r-- | contrib/storage-kafka/src/test/java/org/apache/drill/exec/store/kafka/KafkaTestBase.java | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/contrib/storage-kafka/src/test/java/org/apache/drill/exec/store/kafka/KafkaTestBase.java b/contrib/storage-kafka/src/test/java/org/apache/drill/exec/store/kafka/KafkaTestBase.java index 24e6f6d68..9f0660621 100644 --- a/contrib/storage-kafka/src/test/java/org/apache/drill/exec/store/kafka/KafkaTestBase.java +++ b/contrib/storage-kafka/src/test/java/org/apache/drill/exec/store/kafka/KafkaTestBase.java @@ -86,7 +86,9 @@ public class KafkaTestBase extends PlanTestBase { @AfterClass public static void tearDownKafkaTestBase() throws Exception { - TestKafkaSuit.tearDownCluster(); + if (TestKafkaSuit.isRunningSuite()) { + TestKafkaSuit.tearDownCluster(); + } } } |