iyupeng commented on a change in pull request #17344:
URL: https://github.com/apache/flink/pull/17344#discussion_r738899089
##########
File path:
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/utils/TableTestBase.scala
##########
@@ -1002,6 +1001,12 @@ abstract class TableTestUtil(
.getConfiguration
.set(ExecutionOptions.BATCH_SHUFFLE_MODE,
BatchShuffleMode.ALL_EXCHANGES_PIPELINED)
+ // Disable push down aggregates to avoid conflicts with existing test cases
that verify plans.
+ tableEnv.getConfig
+ .getConfiguration
+ .setBoolean(
+
OptimizerConfigOptions.TABLE_OPTIMIZER_SOURCE_AGGREGATE_PUSHDOWN_ENABLED, false)
Review comment:
pushed a new commit
https://github.com/apache/flink/pull/17344/commits/2ee07dc6ac1911d32636e5156c04820fb24d8b88
to solve this.
--
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
