Skip to content

Commit

Permalink
[HUDI-3087] Fix DedupeSparkJob typo
Browse files Browse the repository at this point in the history
  • Loading branch information
Aimiyoo committed Dec 21, 2021
1 parent 9a2030a commit a721e57
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -233,7 +233,7 @@ class DedupeSparkJob(basePath: String,
}

println("No duplicates found & counts are in check!!!! ")
// 4. Prepare to copy the fixed files back.
// 5. Prepare to copy the fixed files back.
fileNameToPathMap.foreach { case (_, filePath) =>
val srcPath = new Path(s"$repairOutputPath/${filePath.getName}")
val dstPath = new Path(s"$basePath/$duplicatedPartitionPath/${filePath.getName}")
Expand Down

0 comments on commit a721e57

Please sign in to comment.