You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by sr...@apache.org on 2015/02/11 09:14:01 UTC
spark git commit: SPARK-5728 [STREAMING] MQTTStreamSuite leaves
behind ActiveMQ database files
Repository: spark
Updated Branches:
refs/heads/master 658687b25 -> da89720bf
SPARK-5728 [STREAMING] MQTTStreamSuite leaves behind ActiveMQ database files
Use temp dir for ActiveMQ database
Author: Sean Owen <so...@cloudera.com>
Closes #4517 from srowen/SPARK-5728 and squashes the following commits:
1d3aeb8 [Sean Owen] Use temp dir for ActiveMQ database
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/da89720b
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/da89720b
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/da89720b
Branch: refs/heads/master
Commit: da89720bf4023392436e75b6ed5e10ed8588a132
Parents: 658687b
Author: Sean Owen <so...@cloudera.com>
Authored: Wed Feb 11 08:13:51 2015 +0000
Committer: Sean Owen <so...@cloudera.com>
Committed: Wed Feb 11 08:13:51 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/da89720b/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 e84adc0..19c9271 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))
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org