<p>我试图通过形成键值对来读取日志行,但是我得到了一个错误。
这是我的代码:</p>
<pre><code>logLine=sc.textFile("C:\TestLogs\testing.log").cache()
lines = logLine.flatMap(lambda x: x.split('\n'))
rx = "(\\S+)=(\\S+)"
line_collect = lines.collect()
for line in line_collect :
d = dict([(x,y) for x,y in re.findall(rx,line)])
d = str(d)
print d
</code></pre>
<p>错误:</p>
<blockquote>
<p>line_collect = lines.collect()......InvalidInputException: Input path
does not exist: file:/C:/TestLogs esting.log</p>
</blockquote>
<p>我不知道怎么改正。我是python和spark的新手。在</p>