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

   ### Describe the bug
   
   While working on https://github.com/apache/datafusion-comet/issues/2172, I 
discovered a potential issue:
   
   ```
   - array_intersect *** FAILED *** (653 milliseconds)
     Results do not match for query:
     Timezone: 
sun.util.calendar.ZoneInfo[id="America/Los_Angeles",offset=-28800000,dstSavings=3600000,useDaylight=true,transitions=185,lastRule=java.util.SimpleTimeZone[id=America/Los_Angeles,offset=-28800000,dstSavings=3600000,useDaylight=true,startYear=0,startMode=3,startMonth=2,startDay=8,startDayOfWeek=1,startTime=7200000,startTimeMode=0,endMode=3,endMonth=10,endDay=1,endDayOfWeek=1,endTime=7200000,endTimeMode=0]]
     Timezone Env:
   
     == Parsed Logical Plan ==
     Project [array_intersect(array((cast(_2#433299 as int) * -1)), 
array(cast(_9#433306 as int), _10#433307)) AS array_intersect(array((_2 * -1)), 
array(_9, _10))#433366]
     +- SubqueryAlias t1
        +- View (`t1`, 
[_1#433298,_2#433299,_3#433300,_4#433301,_5#433302L,_6#433303,_7#433304,_8#433305,_9#433306,_10#433307,_11#433308L,_12#433309,_13#433310,_14#433311,_15#433312,_16#433313,_17#433314,_18#433315,_19#433316,_20#433317,_21#433318,_id#433319])
           +- Relation 
[_1#433298,_2#433299,_3#433300,_4#433301,_5#433302L,_6#433303,_7#433304,_8#433305,_9#433306,_10#433307,_11#433308L,_12#433309,_13#433310,_14#433311,_15#433312,_16#433313,_17#433314,_18#433315,_19#433316,_20#433317,_21#433318,_id#433319]
 parquet
   
     == Analyzed Logical Plan ==
     array_intersect(array((_2 * -1)), array(_9, _10)): array<int>
     Project [array_intersect(array((cast(_2#433299 as int) * -1)), 
array(cast(_9#433306 as int), _10#433307)) AS array_intersect(array((_2 * -1)), 
array(_9, _10))#433366]
     +- SubqueryAlias t1
        +- View (`t1`, 
[_1#433298,_2#433299,_3#433300,_4#433301,_5#433302L,_6#433303,_7#433304,_8#433305,_9#433306,_10#433307,_11#433308L,_12#433309,_13#433310,_14#433311,_15#433312,_16#433313,_17#433314,_18#433315,_19#433316,_20#433317,_21#433318,_id#433319])
           +- Relation 
[_1#433298,_2#433299,_3#433300,_4#433301,_5#433302L,_6#433303,_7#433304,_8#433305,_9#433306,_10#433307,_11#433308L,_12#433309,_13#433310,_14#433311,_15#433312,_16#433313,_17#433314,_18#433315,_19#433316,_20#433317,_21#433318,_id#433319]
 parquet
   
     == Optimized Logical Plan ==
     Project [array_intersect(array((cast(_2#433299 as int) * -1)), 
array(cast(_9#433306 as int), _10#433307)) AS array_intersect(array((_2 * -1)), 
array(_9, _10))#433366]
     +- Relation 
[_1#433298,_2#433299,_3#433300,_4#433301,_5#433302L,_6#433303,_7#433304,_8#433305,_9#433306,_10#433307,_11#433308L,_12#433309,_13#433310,_14#433311,_15#433312,_16#433313,_17#433314,_18#433315,_19#433316,_20#433317,_21#433318,_id#433319]
 parquet
   
     == Physical Plan ==
     *(1) CometColumnarToRow
     +- CometProject [array_intersect(array((_2 * -1)), array(_9, 
_10))#433366], [array_intersect(array((cast(_2#433299 as int) * -1)), 
array(cast(_9#433306 as int), _10#433307)) AS array_intersect(array((_2 * -1)), 
array(_9, _10))#433366]
        +- CometScan [native_iceberg_compat] parquet 
[_2#433299,_9#433306,_10#433307] Batched: true, DataFilters: [], Format: 
CometParquet, Location: InMemoryFileIndex(1 
paths)[file:/home/andy/git/apache/datafusion-comet/spark/target/tmp/spark-0ed...,
 PartitionFilters: [], PushedFilters: [], ReadSchema: 
struct<_2:tinyint,_9:smallint,_10:int>
   
     == Results ==
   
     == Results ==
     !== Correct Answer - 10000 ==                                           == 
Spark Answer - 10000 ==
      struct<array_intersect(array((_2 * -1)), array(_9, _10)):array<int>>   
struct<array_intersect(array((_2 * -1)), array(_9, _10)):array<int>>
     ![ArrayBuffer(-1)]                                                      
[ArrayBuffer()]
     ![ArrayBuffer(-1)]                                                      
[ArrayBuffer()]
     ![ArrayBuffer(-1)]                                                      
[ArrayBuffer()]
     ![ArrayBuffer(-1)]                                                      
[ArrayBuffer()]
     ![ArrayBuffer(-1)]                                                      
[ArrayBuffer()]
   ```
   
   ### Steps to reproduce
   
   Update `CometTestBase` to remove the config setting the scan impl to 
`native_comet`
   
   ### 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