File tree Expand file tree Collapse file tree 1 file changed +9
-0
lines changed
streaming/src/test/scala/org/apache/spark/streaming Expand file tree Collapse file tree 1 file changed +9
-0
lines changed Original file line number Diff line number Diff line change @@ -112,6 +112,15 @@ class StreamingContextSuite extends SparkFunSuite with BeforeAndAfter with Timeo
112112 assert(ssc.conf.getTimeAsSeconds(" spark.cleaner.ttl" , " -1" ) === 10 )
113113 }
114114
115+ test(" checkPoint from conf" ) {
116+ val checkpointDirectory = Utils .createTempDir().getAbsolutePath()
117+
118+ val myConf = SparkContext .updatedConf(new SparkConf (false ), master, appName)
119+ myConf.set(" spark.streaming.checkpointDir" , checkpointDirectory)
120+ val ssc = new StreamingContext (myConf, batchDuration)
121+ assert(ssc.checkpointDir != null )
122+ }
123+
115124 test(" state matching" ) {
116125 import StreamingContextState ._
117126 assert(INITIALIZED === INITIALIZED )
You can’t perform that action at this time.
0 commit comments