diff options
| author | Reynold Xin <rxin@apache.org> | 2014-07-16 11:15:07 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@apache.org> | 2014-07-16 11:15:07 -0700 |
| commit | ef48222c10be3d29a83dfc2329f455eba203cd38 (patch) | |
| tree | 8dbcf566a3d424c92b69685d3918e4756290b1c6 /streaming | |
| parent | cc965eea510397642830acb21f61127b68c098d6 (diff) | |
| download | spark-ef48222c10be3d29a83dfc2329f455eba203cd38.tar.gz spark-ef48222c10be3d29a83dfc2329f455eba203cd38.tar.bz2 spark-ef48222c10be3d29a83dfc2329f455eba203cd38.zip | |
[SPARK-2517] Remove some compiler warnings.
Author: Reynold Xin <rxin@apache.org>
Closes #1433 from rxin/compile-warning and squashes the following commits:
8d0b890 [Reynold Xin] Remove some compiler warnings.
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/test/scala/org/apache/spark/streaming/InputStreamsSuite.scala | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/streaming/src/test/scala/org/apache/spark/streaming/InputStreamsSuite.scala b/streaming/src/test/scala/org/apache/spark/streaming/InputStreamsSuite.scala index cc4a65011d..952a74fd5f 100644 --- a/streaming/src/test/scala/org/apache/spark/streaming/InputStreamsSuite.scala +++ b/streaming/src/test/scala/org/apache/spark/streaming/InputStreamsSuite.scala @@ -383,7 +383,10 @@ class TestActor(port: Int) extends Actor with ActorHelper { def bytesToString(byteString: ByteString) = byteString.utf8String - override def preStart = IOManager(context.system).connect(new InetSocketAddress(port)) + override def preStart(): Unit = { + @deprecated("suppress compile time deprecation warning", "1.0.0") + val unit = IOManager(context.system).connect(new InetSocketAddress(port)) + } def receive = { case IO.Read(socket, bytes) => |