aboutsummaryrefslogtreecommitdiff
path: root/streaming
diff options
context:
space:
mode:
authorzsxwing <zsxwing@gmail.com>2014-05-19 16:41:31 -0700
committerTathagata Das <tathagata.das1565@gmail.com>2014-05-19 16:41:31 -0700
commit1811ba8ccb580979aa2e12019e6a82805f09ab53 (patch)
tree0ece4de15b78d150813b857f08ab266c7822282a /streaming
parent7b70a7071894dd90ea1d0091542b3e13e7ef8d3a (diff)
downloadspark-1811ba8ccb580979aa2e12019e6a82805f09ab53.tar.gz
spark-1811ba8ccb580979aa2e12019e6a82805f09ab53.tar.bz2
spark-1811ba8ccb580979aa2e12019e6a82805f09ab53.zip
SPARK-1878: Fix the incorrect initialization order
JIRA: https://issues.apache.org/jira/browse/SPARK-1878 Author: zsxwing <zsxwing@gmail.com> Closes #822 from zsxwing/SPARK-1878 and squashes the following commits: 4a47e27 [zsxwing] SPARK-1878: Fix the incorrect initialization order
Diffstat (limited to 'streaming')
-rw-r--r--streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaStreamingContext.scala6
-rw-r--r--streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java4
2 files changed, 7 insertions, 3 deletions
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaStreamingContext.scala b/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaStreamingContext.scala
index 75a3e9334e..18605cac70 100644
--- a/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaStreamingContext.scala
+++ b/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaStreamingContext.scala
@@ -142,12 +142,12 @@ class JavaStreamingContext(val ssc: StreamingContext) {
*/
def this(path: String, hadoopConf: Configuration) = this(new StreamingContext(path, hadoopConf))
- @deprecated("use sparkContext", "0.9.0")
- val sc: JavaSparkContext = sparkContext
-
/** The underlying SparkContext */
val sparkContext = new JavaSparkContext(ssc.sc)
+ @deprecated("use sparkContext", "0.9.0")
+ val sc: JavaSparkContext = sparkContext
+
/**
* Create an input stream from network source hostname:port. Data is received using
* a TCP socket and the receive bytes is interpreted as UTF8 encoded \n delimited
diff --git a/streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java b/streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java
index ce58cb12a4..4efeb8dfbe 100644
--- a/streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java
+++ b/streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java
@@ -55,6 +55,10 @@ public class JavaAPISuite extends LocalJavaStreamingContext implements Serializa
equalIterator(a.iterator(), b.iterator());
}
+ @Test
+ public void testInitialization() {
+ Assert.assertNotNull(ssc.sc());
+ }
@SuppressWarnings("unchecked")
@Test