andygrove commented on issue #744:
URL:
https://github.com/apache/datafusion-comet/issues/744#issuecomment-2260958918
When running a cluster, I cannot reproduce this issue
```
scala> spark.time(spark.sql("select l_shipmode, sum(1) from lineitem group
by 1").collect)
24/07/31 16:53:59 WARN CometSparkSessionExtensions$CometExecRule: Comet
cannot execute some parts of this plan natively (set
spark.comet.explainFallback.enabled=false to disable this logging):
CometHashAggregate
+- AQEShuffleRead [COMET: AQEShuffleRead is not supported]
+- CometSinkPlaceHolder
+- CometExchange
+- CometHashAggregate
+- CometScan parquet
Time taken: 1572 ms
res3: Array[org.apache.spark.sql.Row] = Array([AIR,85729153],
[MAIL,85714788], [RAIL,85734456], [SHIP,85718196], [TRUCK,85719689], [REG
AIR,85710420], [FOB,85711200])
scala> spark.time(spark.sql("select l_shipmode, count(1) from lineitem group
by 1").collect)
24/07/31 16:54:06 WARN CometSparkSessionExtensions$CometExecRule: Comet
cannot execute some parts of this plan natively (set
spark.comet.explainFallback.enabled=false to disable this logging):
CometHashAggregate
+- AQEShuffleRead [COMET: AQEShuffleRead is not supported]
+- CometSinkPlaceHolder
+- CometExchange
+- CometHashAggregate
+- CometScan parquet
Time taken: 1633 ms
res4: Array[org.apache.spark.sql.Row] = Array([AIR,85729153],
[MAIL,85714788], [RAIL,85734456], [SHIP,85718196], [TRUCK,85719689], [REG
AIR,85710420], [FOB,85711200])
```
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
