diff options
| author | Sean Owen <sowen@cloudera.com> | 2015-02-11 08:13:51 +0000 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2015-02-11 08:13:51 +0000 |
| commit | da89720bf4023392436e75b6ed5e10ed8588a132 (patch) | |
| tree | 2a27185d5eb1e6e70ce795c997801ac2af86e4b0 | |
| parent | 658687b25491047f30ee8558733d11e5a0572070 (diff) | |
| download | spark-da89720bf4023392436e75b6ed5e10ed8588a132.tar.gz spark-da89720bf4023392436e75b6ed5e10ed8588a132.tar.bz2 spark-da89720bf4023392436e75b6ed5e10ed8588a132.zip | |
SPARK-5728 [STREAMING] MQTTStreamSuite leaves behind ActiveMQ database files
Use temp dir for ActiveMQ database
Author: Sean Owen <sowen@cloudera.com>
Closes #4517 from srowen/SPARK-5728 and squashes the following commits:
1d3aeb8 [Sean Owen] Use temp dir for ActiveMQ database
| -rw-r--r-- | external/mqtt/src/test/scala/org/apache/spark/streaming/mqtt/MQTTStreamSuite.scala | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/external/mqtt/src/test/scala/org/apache/spark/streaming/mqtt/MQTTStreamSuite.scala b/external/mqtt/src/test/scala/org/apache/spark/streaming/mqtt/MQTTStreamSuite.scala index e84adc088a..19c9271af7 100644 --- a/external/mqtt/src/test/scala/org/apache/spark/streaming/mqtt/MQTTStreamSuite.scala +++ b/external/mqtt/src/test/scala/org/apache/spark/streaming/mqtt/MQTTStreamSuite.scala @@ -93,6 +93,7 @@ class MQTTStreamSuite extends FunSuite with Eventually with BeforeAndAfter { private def setupMQTT() { broker = new BrokerService() + broker.setDataDirectoryFile(Utils.createTempDir()) connector = new TransportConnector() connector.setName("mqtt") connector.setUri(new URI("mqtt:" + brokerUri)) |