[flink] branch master updated: [FLINK-18453][tests] Fix overflow of AggregateITCase#testAggregationCodeSplit

[li...@apache.org]

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

libenchao pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new e162bd7  [FLINK-18453][tests] Fix overflow of AggregateITCase#testAggregationCodeSplit
e162bd7 is described below

commit e162bd7e9064032c0fd5f2035e1a23249f3ca5c2
Author: Benchao Li <li...@gmail.com>
AuthorDate: Thu Jul 9 22:39:14 2020 +0800

    [FLINK-18453][tests] Fix overflow of AggregateITCase#testAggregationCodeSplit
    
    This closes #12861
---
 .../flink/table/planner/runtime/stream/sql/AggregateITCase.scala     | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/AggregateITCase.scala b/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/AggregateITCase.scala
index d3c6b77..c920bdc 100644
--- a/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/AggregateITCase.scala
+++ b/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/AggregateITCase.scala
@@ -1262,7 +1262,10 @@ class AggregateITCase(
       .toTable(tEnv, 'a, 'b, 'c)
     tEnv.createTemporaryView("MyTable", t)
 
-    val columnNumber = 500
+    tEnv.getConfig.setMaxGeneratedCodeLength(2048)
+
+    // 50 can make sure all generated methods of [Namespace]AggsHandleFunction is longer than 2048
+    val columnNumber = 50
 
     val selectList = Stream.range(3, columnNumber)
       .map(i => s"SUM(CASE WHEN a IS NOT NULL AND a > $i THEN 0 WHEN a < 0 THEN 0 ELSE $i END)")