Index: system_test/utils/kafka_system_test_utils.py
===================================================================
--- system_test/utils/kafka_system_test_utils.py	(revision 1389508)
+++ system_test/utils/kafka_system_test_utils.py	(working copy)
@@ -824,7 +824,7 @@
             logger.info("skipping role [" + role + "] on host : [" + hostname + "]", extra=d)
             continue
 
-        cmdStr  = "ssh " + hostname + " 'rm -r " + dataDir + "/*'"
+        cmdStr  = "ssh " + hostname + " 'rm -r " + dataDir + "'"
 
         if not dataDir.startswith("/tmp"):
             logger.warn("possible destructive command [" + cmdStr + "]", extra=d)