Skip to content

Commit 61be271

Browse files
committed
Fix file name filter
1 parent 6b783bd commit 61be271

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

core/src/main/scala/org/apache/spark/rdd/PipedRDD.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -65,9 +65,9 @@ class PipedRDD[T: ClassTag](
6565
* A FilenameFilter that accepts anything that isn't equal to the name passed in.
6666
* @param name of file or directory to leave out
6767
*/
68-
class NotEqualsFileNameFilter(name: String) extends FilenameFilter {
68+
class NotEqualsFileNameFilter(filterName: String) extends FilenameFilter {
6969
def accept(dir: File, name: String): Boolean = {
70-
!name.equals(name)
70+
!name.equals(filterName)
7171
}
7272
}
7373

@@ -92,7 +92,7 @@ class PipedRDD[T: ClassTag](
9292
logDebug("taskDirectory = " + taskDirectory)
9393
if (separateWorkingDir == true) {
9494
val currentDir = new File(".")
95-
logDebug("currentDir = " + currentDir)
95+
logDebug("currentDir = " + currentDir.getAbsolutePath())
9696
val taskDirFile = new File(taskDirectory)
9797
taskDirFile.mkdirs()
9898

0 commit comments

Comments
 (0)