File tree Expand file tree Collapse file tree 2 files changed +1
-2
lines changed
main/scala/org/apache/spark/rdd
test/scala/org/apache/spark Expand file tree Collapse file tree 2 files changed +1
-2
lines changed Original file line number Diff line number Diff line change @@ -163,7 +163,7 @@ class PipedRDD[T: ClassTag](
163163 }
164164
165165 // cleanup task working directory if used
166- if (workInTaskDirectory == true ) {
166+ if (workInTaskDirectory == true ) {
167167 FileUtils .deleteQuietly(new File (taskDirectory))
168168 logDebug(" Removed task working directory " + taskDirectory)
169169 }
Original file line number Diff line number Diff line change @@ -139,7 +139,6 @@ class PipedRDDSuite extends FunSuite with SharedSparkContext {
139139 val collectPwd = pipedPwd.collect()
140140 println(" collect pwd is: " + collectPwd(0 ))
141141 assert(collectPwd(0 ).contains(" tasks/" ))
142- assert(collectPwd(0 ).matches(" tasks/" ))
143142 } else {
144143 assert(true )
145144 }
You can’t perform that action at this time.
0 commit comments