Skip to content

Commit ca61aa8

Browse files
techaddictpdeyhim
authored andcommitted
[HOTFIX] SPARK-1637: There are some Streaming examples added after the PR apache#571 was last updated.
This resulted in Compilation Errors. cc @mateiz project not compiling currently. Author: Sandeep <[email protected]> Closes apache#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 apache#571 was last updated. This resulted in Compilation Errors.
1 parent 54c9118 commit ca61aa8

File tree

2 files changed

+4
-6
lines changed

2 files changed

+4
-6
lines changed

examples/src/main/java/org/apache/spark/streaming/examples/JavaCustomReceiver.java renamed to examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
* limitations under the License.
1616
*/
1717

18-
package org.apache.spark.streaming.examples;
18+
package org.apache.spark.examples.streaming;
1919

2020
import com.google.common.collect.Lists;
2121

@@ -48,7 +48,7 @@
4848
* To run this on your local machine, you need to first run a Netcat server
4949
* `$ nc -lk 9999`
5050
* and then run the example
51-
* `$ ./run org.apache.spark.streaming.examples.JavaCustomReceiver local[2] localhost 9999`
51+
* `$ ./run org.apache.spark.examples.streaming.JavaCustomReceiver local[2] localhost 9999`
5252
*/
5353

5454
public class JavaCustomReceiver extends Receiver<String> {
@@ -149,5 +149,3 @@ private void receive() {
149149
}
150150
}
151151
}
152-
153-

examples/src/main/scala/org/apache/spark/streaming/examples/CustomReceiver.scala renamed to examples/src/main/scala/org/apache/spark/examples/streaming/CustomReceiver.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
* limitations under the License.
1616
*/
1717

18-
package org.apache.spark.streaming.examples
18+
package org.apache.spark.examples.streaming
1919

2020
import java.io.{InputStreamReader, BufferedReader, InputStream}
2121
import java.net.Socket
@@ -37,7 +37,7 @@ import org.apache.spark.streaming.receiver.Receiver
3737
* To run this on your local machine, you need to first run a Netcat server
3838
* `$ nc -lk 9999`
3939
* and then run the example
40-
* `$ ./run org.apache.spark.streaming.examples.CustomReceiver local[2] localhost 9999`
40+
* `$ ./run org.apache.spark.examples.streaming.CustomReceiver local[2] localhost 9999`
4141
*/
4242
object CustomReceiver {
4343
def main(args: Array[String]) {

0 commit comments

Comments
 (0)