Skip to content

Commit

Permalink
Update RecoverableNetworkWordCount.scala
Browse files Browse the repository at this point in the history
Trying this example, I missed the moment when the checkpoint was iniciated
  • Loading branch information
comcmipi committed Oct 9, 2014
1 parent 14f222f commit 96fe274
Showing 1 changed file with 1 addition and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -116,6 +116,7 @@ object RecoverableNetworkWordCount {
() => {
createContext(ip, port, outputPath)
})
ssc.checkpoint(checkpointDirectory)
ssc.start()
ssc.awaitTermination()
}
Expand Down

0 comments on commit 96fe274

Please sign in to comment.