[drill] 01/04: DRILL-6733: Unit tests from KafkaFilterPushdownTest are failing in some environments.

[so...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

sorabh pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/drill.git

commit 2bb0294026960d0cec3bb78516b168ff231d2096
Author: Anton Gozhiy <an...@gmail.com>
AuthorDate: Tue Sep 11 12:31:41 2018 +0300

    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.
---
 .../test/java/org/apache/drill/exec/store/kafka/KafkaTestBase.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

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 24e6f6d..9f06606 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();
+    }
   }
 
 }