This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit a2c5f482907fcc9074fa9d1a431fe18805604416 Author: Roman Khachatryan <[email protected]> AuthorDate: Sun Feb 13 13:58:56 2022 +0100 [hotfix][tests] Disable changelog in JsonAggregationFunctionsITCase --- .../table/planner/functions/BuiltInAggregateFunctionTestBase.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/BuiltInAggregateFunctionTestBase.java b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/BuiltInAggregateFunctionTestBase.java index ded7c74..352ed83 100644 --- a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/BuiltInAggregateFunctionTestBase.java +++ b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/BuiltInAggregateFunctionTestBase.java @@ -18,6 +18,8 @@ package org.apache.flink.table.planner.functions; +import org.apache.flink.configuration.Configuration; +import org.apache.flink.configuration.StateChangelogOptions; import org.apache.flink.runtime.testutils.MiniClusterResourceConfiguration; import org.apache.flink.streaming.api.functions.source.SourceFunction; import org.apache.flink.table.api.EnvironmentSettings; @@ -77,6 +79,9 @@ public class BuiltInAggregateFunctionTestBase { public void testFunction() throws Exception { final TableEnvironment tEnv = TableEnvironment.create(EnvironmentSettings.inStreamingMode()); + Configuration configuration = tEnv.getConfig().getConfiguration(); + // see https://issues.apache.org/jira/browse/FLINK-26092 + configuration.set(StateChangelogOptions.ENABLE_STATE_CHANGE_LOG, false); final Table sourceTable = asTable(tEnv, testSpec.sourceRowType, testSpec.sourceRows); for (final TestItem testItem : testSpec.testItems) {
