[flink] branch release-1.17 updated: [FLINK-30971][table-planner] Modify the default value of parameter 'table.exec.local-hash-agg.adaptive.sampling-threshold'

[go...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

godfrey pushed a commit to branch release-1.17
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.17 by this push:
     new 74743d04bf1 [FLINK-30971][table-planner] Modify the default value of parameter 'table.exec.local-hash-agg.adaptive.sampling-threshold'
74743d04bf1 is described below

commit 74743d04bf100fc1202a320db02a7d6964266858
Author: yunhong <33...@qq.com>
AuthorDate: Fri Feb 17 15:10:45 2023 +0800

    [FLINK-30971][table-planner] Modify the default value of parameter 'table.exec.local-hash-agg.adaptive.sampling-threshold'
    
    This closes #21900
    
    (cherry picked from commit 55b927b0e6eb2d5d71487b9bb2c4dab80017a7e5)
---
 .../flink/table/planner/codegen/agg/batch/HashAggCodeGenerator.scala  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/agg/batch/HashAggCodeGenerator.scala b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/agg/batch/HashAggCodeGenerator.scala
index e98ca5dd266..d13fd831522 100644
--- a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/agg/batch/HashAggCodeGenerator.scala
+++ b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/agg/batch/HashAggCodeGenerator.scala
@@ -67,7 +67,7 @@ object HashAggCodeGenerator {
   val TABLE_EXEC_LOCAL_HASH_AGG_ADAPTIVE_SAMPLING_THRESHOLD: ConfigOption[JLong] =
     key("table.exec.local-hash-agg.adaptive.sampling-threshold")
       .longType()
-      .defaultValue(Long.box(5000000L))
+      .defaultValue(Long.box(500000L))
       .withDescription(
         s"""
            |If adaptive local hash aggregation is enabled, this value defines how 
@@ -76,7 +76,7 @@ object HashAggCodeGenerator {
            |for the local aggregate. The higher the sampling threshold, the more accurate 
            |the distinct value rate is. But as the sampling threshold increases, local 
            |aggregation is meaningless when the distinct values rate is low. 
-           |The default value is 5000000.
+           |The default value is 500000.
            |""".stripMargin)
 
   @Experimental