lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-1547] CI intermittent failure: TestJsonStringToHoodieRecordMapF… (#2521)

Browse Source
This commit is contained in:
wangxianghu
2021-02-04 11:20:01 +08:00
committed by GitHub
parent 17802569fd
commit 647e9faf25
1 changed files with 1 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
hudi-flink/src/test/java/org/apache/hudi/source/TestJsonStringToHoodieRecordMapFunction.java
View File

@@ -32,7 +32,6 @@ import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.Assertions; import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import java.util.List; import java.util.List;
@@ -58,7 +57,6 @@ public class TestJsonStringToHoodieRecordMapFunction extends HoodieFlinkClientTe
} }
@Test @Test
@Disabled
public void testMapFunction() throws Exception { public void testMapFunction() throws Exception {
final String newCommitTime = "001"; final String newCommitTime = "001";
final int numRecords = 10; 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.RECORDKEY_FIELD_OPT_KEY, "_row_key");
props.put(KeyGeneratorOptions.PARTITIONPATH_FIELD_OPT_KEY, "current_date"); props.put(KeyGeneratorOptions.PARTITIONPATH_FIELD_OPT_KEY, "current_date");
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.setParallelism(2); env.setParallelism(1);
SimpleTestSinkFunction.valuesList.clear(); SimpleTestSinkFunction.valuesList.clear();
env.fromCollection(recordStr) env.fromCollection(recordStr)