Repository: bahir Updated Branches: refs/heads/master 9373fa4e7 -> 1ce2ab64c
[MINOR] Fix compilation/build warnings Disable zinc to avoid build Replace deprecated Timeouts with TimeLimits Add imports for scala postfix function support Project: http://git-wip-us.apache.org/repos/asf/bahir/repo Commit: http://git-wip-us.apache.org/repos/asf/bahir/commit/1ce2ab64 Tree: http://git-wip-us.apache.org/repos/asf/bahir/tree/1ce2ab64 Diff: http://git-wip-us.apache.org/repos/asf/bahir/diff/1ce2ab64 Branch: refs/heads/master Commit: 1ce2ab64ca25916b2fe8f54861783a8f953889b6 Parents: 9373fa4 Author: Luciano Resende <[email protected]> Authored: Fri Nov 30 13:26:57 2018 +0100 Committer: Luciano Resende <[email protected]> Committed: Fri Nov 30 14:16:25 2018 +0100 ---------------------------------------------------------------------- pom.xml | 2 +- .../org/apache/spark/streaming/pubsub/PubsubStreamSuite.scala | 4 ++-- .../spark/streaming/pubsub/SparkGCPCredentialsBuilderSuite.scala | 4 ++-- .../org/apache/spark/streaming/zeromq/ZeroMQStreamSuite.scala | 1 + 4 files changed, 6 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/bahir/blob/1ce2ab64/pom.xml ---------------------------------------------------------------------- diff --git a/pom.xml b/pom.xml index ec419fa..f33b1c7 100644 --- a/pom.xml +++ b/pom.xml @@ -518,7 +518,7 @@ <configuration> <scalaVersion>${scala.version}</scalaVersion> <recompileMode>incremental</recompileMode> - <useZincServer>true</useZincServer> + <!--useZincServer>true</useZincServer--> <args> <arg>-unchecked</arg> <arg>-deprecation</arg> http://git-wip-us.apache.org/repos/asf/bahir/blob/1ce2ab64/streaming-pubsub/src/test/scala/org/apache/spark/streaming/pubsub/PubsubStreamSuite.scala ---------------------------------------------------------------------- diff --git a/streaming-pubsub/src/test/scala/org/apache/spark/streaming/pubsub/PubsubStreamSuite.scala b/streaming-pubsub/src/test/scala/org/apache/spark/streaming/pubsub/PubsubStreamSuite.scala index 284950c..d91c7e6 100644 --- a/streaming-pubsub/src/test/scala/org/apache/spark/streaming/pubsub/PubsubStreamSuite.scala +++ b/streaming-pubsub/src/test/scala/org/apache/spark/streaming/pubsub/PubsubStreamSuite.scala @@ -20,14 +20,14 @@ package org.apache.spark.streaming.pubsub import java.util.UUID import scala.concurrent.duration._ +import scala.language.postfixOps import org.scalatest.BeforeAndAfter import org.scalatest.concurrent.Eventually -import org.apache.spark.streaming.StreamingContext -import org.apache.spark.SparkFunSuite import org.apache.spark.storage.StorageLevel import org.apache.spark.streaming.Seconds +import org.apache.spark.streaming.StreamingContext class PubsubStreamSuite extends PubsubFunSuite with Eventually with BeforeAndAfter { http://git-wip-us.apache.org/repos/asf/bahir/blob/1ce2ab64/streaming-pubsub/src/test/scala/org/apache/spark/streaming/pubsub/SparkGCPCredentialsBuilderSuite.scala ---------------------------------------------------------------------- diff --git a/streaming-pubsub/src/test/scala/org/apache/spark/streaming/pubsub/SparkGCPCredentialsBuilderSuite.scala b/streaming-pubsub/src/test/scala/org/apache/spark/streaming/pubsub/SparkGCPCredentialsBuilderSuite.scala index bf68a07..be47e18 100644 --- a/streaming-pubsub/src/test/scala/org/apache/spark/streaming/pubsub/SparkGCPCredentialsBuilderSuite.scala +++ b/streaming-pubsub/src/test/scala/org/apache/spark/streaming/pubsub/SparkGCPCredentialsBuilderSuite.scala @@ -19,14 +19,14 @@ package org.apache.spark.streaming.pubsub import java.nio.file.{Files, Paths} -import org.scalatest.concurrent.Timeouts +import org.scalatest.concurrent.TimeLimits import org.scalatest.BeforeAndAfter import org.apache.spark.util.Utils import org.apache.spark.SparkFunSuite class SparkGCPCredentialsBuilderSuite - extends SparkFunSuite with Timeouts with BeforeAndAfter{ + extends SparkFunSuite with TimeLimits with BeforeAndAfter{ private def builder = SparkGCPCredentials.builder private val jsonFilePath = sys.env.get(PubsubTestUtils.envVarNameForJsonKeyPath) http://git-wip-us.apache.org/repos/asf/bahir/blob/1ce2ab64/streaming-zeromq/src/test/scala/org/apache/spark/streaming/zeromq/ZeroMQStreamSuite.scala ---------------------------------------------------------------------- diff --git a/streaming-zeromq/src/test/scala/org/apache/spark/streaming/zeromq/ZeroMQStreamSuite.scala b/streaming-zeromq/src/test/scala/org/apache/spark/streaming/zeromq/ZeroMQStreamSuite.scala index 547c948..ddc2dae 100644 --- a/streaming-zeromq/src/test/scala/org/apache/spark/streaming/zeromq/ZeroMQStreamSuite.scala +++ b/streaming-zeromq/src/test/scala/org/apache/spark/streaming/zeromq/ZeroMQStreamSuite.scala @@ -18,6 +18,7 @@ package org.apache.spark.streaming.zeromq import scala.collection.mutable +import scala.language.postfixOps import org.scalatest.BeforeAndAfter import org.scalatest.concurrent.Eventually
