diff options
author | Sandeep <sandeep@techaddict.me> | 2014-05-06 21:55:05 -0700 |
---|---|---|
committer | Patrick Wendell <pwendell@gmail.com> | 2014-05-06 21:55:05 -0700 |
commit | fdae095de2daa1fc3b343c05e515235756d856a4 (patch) | |
tree | 5d44a53dcee5aba25a38f4567f715b22c759520c /examples/src/main/scala | |
parent | 48ba3b8cdc3bdc7c67bc465d1f047fa3f44d7085 (diff) | |
download | spark-fdae095de2daa1fc3b343c05e515235756d856a4.tar.gz spark-fdae095de2daa1fc3b343c05e515235756d856a4.tar.bz2 spark-fdae095de2daa1fc3b343c05e515235756d856a4.zip |
[HOTFIX] SPARK-1637: There are some Streaming examples added after the PR #571 was last updated.
This resulted in Compilation Errors.
cc @mateiz project not compiling currently.
Author: Sandeep <sandeep@techaddict.me>
Closes #673 from techaddict/SPARK-1637-HOTFIX and squashes the following commits:
b512f4f [Sandeep] [SPARK-1637][HOTFIX] There are some Streaming examples added after the PR #571 was last updated. This resulted in Compilation Errors.
Diffstat (limited to 'examples/src/main/scala')
-rw-r--r-- | examples/src/main/scala/org/apache/spark/examples/streaming/CustomReceiver.scala (renamed from examples/src/main/scala/org/apache/spark/streaming/examples/CustomReceiver.scala) | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/examples/src/main/scala/org/apache/spark/streaming/examples/CustomReceiver.scala b/examples/src/main/scala/org/apache/spark/examples/streaming/CustomReceiver.scala index eebffd8249..e317e2d36a 100644 --- a/examples/src/main/scala/org/apache/spark/streaming/examples/CustomReceiver.scala +++ b/examples/src/main/scala/org/apache/spark/examples/streaming/CustomReceiver.scala @@ -15,7 +15,7 @@ * limitations under the License. */ -package org.apache.spark.streaming.examples +package org.apache.spark.examples.streaming import java.io.{InputStreamReader, BufferedReader, InputStream} import java.net.Socket @@ -37,7 +37,7 @@ import org.apache.spark.streaming.receiver.Receiver * To run this on your local machine, you need to first run a Netcat server * `$ nc -lk 9999` * and then run the example - * `$ ./run org.apache.spark.streaming.examples.CustomReceiver local[2] localhost 9999` + * `$ ./run org.apache.spark.examples.streaming.CustomReceiver local[2] localhost 9999` */ object CustomReceiver { def main(args: Array[String]) { |