Skip to content

Commit 1f0170b

Browse files
committed
feat: Avoid duplicated write nodes for AQE execution
1 parent 940dd9d commit 1f0170b

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

spark/src/test/scala/org/apache/comet/parquet/CometParquetWriterSuite.scala

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -221,9 +221,7 @@ class CometParquetWriterSuite extends CometTestBase {
221221
classOf[DataWritingCommandExec]) -> "true",
222222
CometConf.COMET_EXEC_ENABLED.key -> "true") {
223223

224-
val plan = writeWithCometNativeWriteExec(inputPath, outputPath, Some(10))
225-
println(plan)
226-
224+
writeWithCometNativeWriteExec(inputPath, outputPath, Some(10))
227225
verifyWrittenFile(outputPath)
228226
}
229227
})

0 commit comments

Comments
 (0)