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 <[email protected]> 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 <[email protected]> Authored: Wed Sep 26 12:03:05 2018 -0700 Committer: Grant Henke <[email protected]> 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)
