From 647e9faf255b9ae5796f513d13c769a8c87788d4 Mon Sep 17 00:00:00 2001 From: wangxianghu Date: Thu, 4 Feb 2021 11:20:01 +0800 Subject: [PATCH] =?UTF-8?q?[HUDI-1547]=20CI=20intermittent=20failure:=20Te?= =?UTF-8?q?stJsonStringToHoodieRecordMapF=E2=80=A6=20(#2521)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../hudi/source/TestJsonStringToHoodieRecordMapFunction.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/hudi-flink/src/test/java/org/apache/hudi/source/TestJsonStringToHoodieRecordMapFunction.java b/hudi-flink/src/test/java/org/apache/hudi/source/TestJsonStringToHoodieRecordMapFunction.java index a24f1531d..58eefc994 100644 --- a/hudi-flink/src/test/java/org/apache/hudi/source/TestJsonStringToHoodieRecordMapFunction.java +++ b/hudi-flink/src/test/java/org/apache/hudi/source/TestJsonStringToHoodieRecordMapFunction.java @@ -32,7 +32,6 @@ import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.Assertions; import org.junit.jupiter.api.BeforeEach; -import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; import java.util.List; @@ -58,7 +57,6 @@ public class TestJsonStringToHoodieRecordMapFunction extends HoodieFlinkClientTe } @Test - @Disabled public void testMapFunction() throws Exception { final String newCommitTime = "001"; final int numRecords = 10; @@ -72,7 +70,7 @@ public class TestJsonStringToHoodieRecordMapFunction extends HoodieFlinkClientTe props.put(KeyGeneratorOptions.RECORDKEY_FIELD_OPT_KEY, "_row_key"); props.put(KeyGeneratorOptions.PARTITIONPATH_FIELD_OPT_KEY, "current_date"); StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); - env.setParallelism(2); + env.setParallelism(1); SimpleTestSinkFunction.valuesList.clear(); env.fromCollection(recordStr)