We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 83bcafb commit 9750b38Copy full SHA for 9750b38
spark/src/main/scala/org/apache/comet/serde/operator/CometDataWritingCommand.scala
@@ -50,11 +50,6 @@ object CometDataWritingCommand extends CometOperatorSerde[DataWritingCommandExec
50
override def getSupportLevel(op: DataWritingCommandExec): SupportLevel = {
51
op.cmd match {
52
case cmd: InsertIntoHadoopFsRelationCommand =>
53
- // Skip INSERT OVERWRITE DIRECTORY operations (catalogTable is None for directory writes)
54
- if (cmd.catalogTable.isEmpty) {
55
- return Unsupported(Some("INSERT OVERWRITE DIRECTORY is not supported"))
56
- }
57
-
58
cmd.fileFormat match {
59
case _: ParquetFileFormat =>
60
if (!cmd.outputPath.toString.startsWith("file:")) {
0 commit comments