andygrove opened a new issue, #1875:
URL: https://github.com/apache/datafusion-comet/issues/1875

   ### Describe the bug
   
   
   ```
   2025-06-12T03:28:33.2846280Z [info] - INSERT INTO TABLE - complex type but 
different names *** FAILED *** (223 milliseconds)
   2025-06-12T03:28:33.3248391Z [info]   org.apache.spark.SparkException: Job 
aborted due to stage failure: Task 0 in stage 36.0 failed 1 times, most recent 
failure: Lost task 0.0 in stage 36.0 (TID 95) (bea295fb60a7 executor driver): 
org.apache.spark.SparkException: [TASK_WRITE_FAILED] Task failed while writing 
rows to 
file:/__w/datafusion-comet/datafusion-comet/apache-spark/sql/core/spark-warehouse/org.apache.spark.sql.sources.InsertSuite/tab2.
   2025-06-12T03:28:33.3251807Z [info]  at 
org.apache.spark.sql.errors.QueryExecutionErrors$.taskFailedWhileWritingRowsError(QueryExecutionErrors.scala:788)
   2025-06-12T03:28:33.3253244Z [info]  at 
org.apache.spark.sql.execution.datasources.FileFormatWriter$.executeTask(FileFormatWriter.scala:420)
   2025-06-12T03:28:33.3254592Z [info]  at 
org.apache.spark.sql.execution.datasources.WriteFilesExec.$anonfun$doExecuteWrite$1(WriteFiles.scala:100)
   2025-06-12T03:28:33.3255714Z [info]  at 
org.apache.spark.rdd.RDD.$anonfun$mapPartitionsInternal$2(RDD.scala:891)
   2025-06-12T03:28:33.3256639Z [info]  at 
org.apache.spark.rdd.RDD.$anonfun$mapPartitionsInternal$2$adapted(RDD.scala:891)
   2025-06-12T03:28:33.3257588Z [info]  at 
org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52)
   2025-06-12T03:28:33.3258471Z [info]  at 
org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:367)
   2025-06-12T03:28:33.3259205Z [info]  at 
org.apache.spark.rdd.RDD.iterator(RDD.scala:331)
   2025-06-12T03:28:33.3260106Z [info]  at 
org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:92)
   2025-06-12T03:28:33.3261164Z [info]  at 
org.apache.spark.TaskContext.runTaskWithListeners(TaskContext.scala:161)
   2025-06-12T03:28:33.3261985Z [info]  at 
org.apache.spark.scheduler.Task.run(Task.scala:139)
   2025-06-12T03:28:33.3262806Z [info]  at 
org.apache.spark.executor.Executor$TaskRunner.$anonfun$run$3(Executor.scala:554)
   2025-06-12T03:28:33.3263706Z [info]  at 
org.apache.spark.util.Utils$.tryWithSafeFinally(Utils.scala:1529)
   2025-06-12T03:28:33.3264526Z [info]  at 
org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:557)
   2025-06-12T03:28:33.3265549Z [info]  at 
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
   2025-06-12T03:28:33.3266717Z [info]  at 
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
   2025-06-12T03:28:33.3267590Z [info]  at 
java.base/java.lang.Thread.run(Thread.java:829)
   2025-06-12T03:28:33.3268318Z [info] Caused by: 
org.apache.comet.CometNativeException: no entry found for key
   2025-06-12T03:28:33.3285928Z [info]         at 
comet::errors::init::{{closure}}(__internal__:0)
   2025-06-12T03:28:33.3286609Z [info]         at 
std::panicking::rust_panic_with_hook(__internal__:0)
   2025-06-12T03:28:33.3287332Z [info]         at 
std::panicking::begin_panic_handler::{{closure}}(__internal__:0)
   2025-06-12T03:28:33.3288089Z [info]         at 
std::sys::backtrace::__rust_end_short_backtrace(__internal__:0)
   2025-06-12T03:28:33.3288741Z [info]         at 
__rustc::rust_begin_unwind(__internal__:0)
   2025-06-12T03:28:33.3289304Z [info]         at 
core::panicking::panic_fmt(__internal__:0)
   2025-06-12T03:28:33.3289871Z [info]         at 
core::option::expect_failed(__internal__:0)
   2025-06-12T03:28:33.3290838Z [info]         at 
datafusion_comet_spark_expr::conversion_funcs::cast::cast_struct_to_struct(__internal__:0)
   2025-06-12T03:28:33.3291866Z [info]         at 
datafusion_comet_spark_expr::conversion_funcs::cast::cast_array(__internal__:0)
   2025-06-12T03:28:33.3292837Z [info]         at 
datafusion_comet_spark_expr::conversion_funcs::cast::spark_cast(__internal__:0)
   2025-06-12T03:28:33.3294327Z [info]         at 
<datafusion_comet_spark_expr::conversion_funcs::cast::Cast as 
datafusion_physical_expr_common::physical_expr::PhysicalExpr>::evaluate(__internal__:0)
   ```
   
   ### Steps to reproduce
   
   _No response_
   
   ### Expected behavior
   
   _No response_
   
   ### Additional context
   
   _No response_


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: github-unsubscr...@datafusion.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


---------------------------------------------------------------------
To unsubscribe, e-mail: github-unsubscr...@datafusion.apache.org
For additional commands, e-mail: github-h...@datafusion.apache.org

Reply via email to