From 1811ba8ccb580979aa2e12019e6a82805f09ab53 Mon Sep 17 00:00:00 2001
From: zsxwing <zsxwing@gmail.com>
Date: Mon, 19 May 2014 16:41:31 -0700
Subject: [PATCH] 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
---
.../spark/streaming/api/java/JavaStreamingContext.scala | 6 +++---
.../test/java/org/apache/spark/streaming/JavaAPISuite.java | 4 ++++
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
--
GitLab