lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] Disable Flink compactor IT test (#6189)

Browse Source
This commit is contained in:
Sagar Sumit
2022-07-22 22:46:55 +05:30
committed by GitHub
parent eea4a692c0
commit 716dd3512b
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/compact/ITTestHoodieFlinkCompactor.java
View File

@@ -42,6 +42,7 @@ import org.apache.flink.table.api.EnvironmentSettings;
import org.apache.flink.table.api.TableEnvironment; import org.apache.flink.table.api.TableEnvironment;
import org.apache.flink.table.api.config.ExecutionConfigOptions; import org.apache.flink.table.api.config.ExecutionConfigOptions;
import org.apache.flink.table.api.internal.TableEnvironmentImpl; import org.apache.flink.table.api.internal.TableEnvironmentImpl;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.io.TempDir; import org.junit.jupiter.api.io.TempDir;
import org.junit.jupiter.params.ParameterizedTest; import org.junit.jupiter.params.ParameterizedTest;
import org.junit.jupiter.params.provider.ValueSource; import org.junit.jupiter.params.provider.ValueSource;
@@ -165,6 +166,7 @@ public class ITTestHoodieFlinkCompactor {
TestData.checkWrittenDataCOW(tempFile, EXPECTED1); TestData.checkWrittenDataCOW(tempFile, EXPECTED1);
} }
@Disabled
@ParameterizedTest @ParameterizedTest
@ValueSource(booleans = {true, false}) @ValueSource(booleans = {true, false})
public void testHoodieFlinkCompactorService(boolean enableChangelog) throws Exception { public void testHoodieFlinkCompactorService(boolean enableChangelog) throws Exception {
@@ -206,6 +208,7 @@ public class ITTestHoodieFlinkCompactor {
TestData.checkWrittenDataCOW(tempFile, EXPECTED2); TestData.checkWrittenDataCOW(tempFile, EXPECTED2);
} }
@Disabled
@ParameterizedTest @ParameterizedTest
@ValueSource(booleans = {true, false}) @ValueSource(booleans = {true, false})
public void testHoodieFlinkCompactorWithPlanSelectStrategy(boolean enableChangelog) throws Exception { public void testHoodieFlinkCompactorWithPlanSelectStrategy(boolean enableChangelog) throws Exception {