We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 31a4cf2 commit 2b7802aCopy full SHA for 2b7802a
1 file changed
spark/src/main/scala/org/apache/comet/serde/operator/CometDataWritingCommand.scala
@@ -161,7 +161,6 @@ object CometDataWritingCommand extends CometOperatorSerde[DataWritingCommandExec
161
162
// SaveMode.Overwrite - delete existing output in the driver itself
163
if (cmd.mode == SaveMode.Overwrite) {
164
-// Delete the end directory if exists in overwrite mode
165
val outputPathObj = new Path(outputPath)
166
val fs = outputPathObj.getFileSystem(new Configuration())
167
0 commit comments