Skip to content
Snippets Groups Projects
Commit 1233b3de authored by Tathagata Das's avatar Tathagata Das
Browse files

Merge remote-tracking branch 'apache/master' into filestream-fix

parents c0bb38e8 01c0d72b
No related branches found
No related tags found
No related merge requests found
...@@ -132,7 +132,7 @@ class JavaStreamingContext(val ssc: StreamingContext) { ...@@ -132,7 +132,7 @@ class JavaStreamingContext(val ssc: StreamingContext) {
* Re-creates a StreamingContext from a checkpoint file. * Re-creates a StreamingContext from a checkpoint file.
* @param path Path to the directory that was specified as the checkpoint directory * @param path Path to the directory that was specified as the checkpoint directory
*/ */
def this(path: String) = this(new StreamingContext(path)) def this(path: String) = this(new StreamingContext(path, new Configuration))
/** /**
* Re-creates a StreamingContext from a checkpoint file. * Re-creates a StreamingContext from a checkpoint file.
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment