You need to set your HADOOP_HOME and make sure the winutils.exe is
available in the PATH.
Here's a discussion around the same issue
http://stackoverflow.com/questions/19620642/failed-to-locate-the-winutils-binary-in-the-hadoop-binary-path
Also this JIRA
ff...@gmail.com>
Cc: "user" <user@spark.apache.org>
Subject: Re: Problems with Local Checkpoints
You need to set your HADOOP_HOME and make sure the winutils.exe is available in
the PATH.
Here's a discussion around the same issue
http://stackoverflow.com/questions/1962064
Hello.
I have some basic code that counts numbers using updateStateByKey. I setup
a streaming context with checkpointing as follows:
def createStreamingContext(masterName : String, checkpointDirectory :
String, timeWindow : Int) : StreamingContext = {
val sparkConf = new