spark-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sro...@apache.org
Subject spark git commit: SPARK-5728 [STREAMING] MQTTStreamSuite leaves behind ActiveMQ database files
Date Fri, 13 Feb 2015 10:41:41 GMT
Repository: spark
Updated Branches:
  refs/heads/branch-1.2 a5d72fd50 -> 222ce9ffd


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

(cherry picked from commit da89720bf4023392436e75b6ed5e10ed8588a132)
Signed-off-by: Sean Owen <sowen@cloudera.com>


Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/222ce9ff
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/222ce9ff
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/222ce9ff

Branch: refs/heads/branch-1.2
Commit: 222ce9ffd8272badb61d1a0358c554fb90c54e62
Parents: a5d72fd
Author: Sean Owen <sowen@cloudera.com>
Authored: Wed Feb 11 08:13:51 2015 +0000
Committer: Sean Owen <sowen@cloudera.com>
Committed: Fri Feb 13 10:41:33 2015 +0000

----------------------------------------------------------------------
 .../scala/org/apache/spark/streaming/mqtt/MQTTStreamSuite.scala     | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/spark/blob/222ce9ff/external/mqtt/src/test/scala/org/apache/spark/streaming/mqtt/MQTTStreamSuite.scala
----------------------------------------------------------------------
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 33605d5..6b5497f 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
@@ -92,6 +92,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))


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org


Mime
View raw message