kudu-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From granthe...@apache.org
Subject kudu git commit: [java] Fix kudu-spark build failure
Date Wed, 26 Sep 2018 20:33:02 GMT
Repository: kudu
Updated Branches:
  refs/heads/master 8020cbf27 -> 801d00536


[java] Fix kudu-spark build failure

Fixes a build break due to 2 patches comming in at
similar times without a rebase.

Change-Id: Id362bec3e6629c519ec908a2c29b5438b6bddee8
Reviewed-on: http://gerrit.cloudera.org:8080/11526
Reviewed-by: Adar Dembo <adar@cloudera.com>
Tested-by: Kudu Jenkins


Project: http://git-wip-us.apache.org/repos/asf/kudu/repo
Commit: http://git-wip-us.apache.org/repos/asf/kudu/commit/801d0053
Tree: http://git-wip-us.apache.org/repos/asf/kudu/tree/801d0053
Diff: http://git-wip-us.apache.org/repos/asf/kudu/diff/801d0053

Branch: refs/heads/master
Commit: 801d00536acacf922241544df1590968b88eb8b1
Parents: 8020cbf
Author: Grant Henke <granthenke@apache.org>
Authored: Wed Sep 26 12:03:05 2018 -0700
Committer: Grant Henke <granthenke@apache.org>
Committed: Wed Sep 26 20:32:39 2018 +0000

----------------------------------------------------------------------
 .../test/scala/org/apache/kudu/spark/kudu/StreamingTest.scala    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kudu/blob/801d0053/java/kudu-spark/src/test/scala/org/apache/kudu/spark/kudu/StreamingTest.scala
----------------------------------------------------------------------
diff --git a/java/kudu-spark/src/test/scala/org/apache/kudu/spark/kudu/StreamingTest.scala
b/java/kudu-spark/src/test/scala/org/apache/kudu/spark/kudu/StreamingTest.scala
index 246d00e..ff7adec 100644
--- a/java/kudu-spark/src/test/scala/org/apache/kudu/spark/kudu/StreamingTest.scala
+++ b/java/kudu-spark/src/test/scala/org/apache/kudu/spark/kudu/StreamingTest.scala
@@ -34,7 +34,7 @@ class StreamingTest extends KuduTestSuite {
   def setUp(): Unit = {
     sqlContext = ss.sqlContext
     kuduOptions =
-      Map("kudu.table" -> simpleTableName, "kudu.master" -> miniCluster.getMasterAddresses)
+      Map("kudu.table" -> simpleTableName, "kudu.master" -> miniCluster.getMasterAddressesAsString)
   }
 
   @Test
@@ -49,7 +49,7 @@ class StreamingTest extends KuduTestSuite {
       .toDF("key", "val")
       .writeStream
       .format(classOf[KuduSinkProvider].getCanonicalName)
-      .option("kudu.master", miniCluster.getMasterAddresses)
+      .option("kudu.master", miniCluster.getMasterAddressesAsString)
       .option("kudu.table", simpleTableName)
       .option("checkpointLocation", checkpointDir.toFile.getCanonicalPath)
       .outputMode(OutputMode.Update)


Mime
View raw message