lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-257] Fix Bloom Index unit-test failures

Browse Source
This commit is contained in:
Balaji Varadarajan
2019-09-16 23:42:14 -07:00
committed by Balaji Varadarajan
parent 96a46d8701
commit 2c6da09d9d
2 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
hudi-client/src/test/java/org/apache/hudi/index/bloom/TestHoodieBloomIndex.java
View File

@@ -91,6 +91,7 @@ public class TestHoodieBloomIndex extends HoodieClientTestHarness {
public void setUp() throws Exception { public void setUp() throws Exception {
initSparkContexts("TestHoodieBloomIndex"); initSparkContexts("TestHoodieBloomIndex");
initTempFolderAndPath(); initTempFolderAndPath();
initFileSystem();
HoodieTestUtils.init(jsc.hadoopConfiguration(), basePath); HoodieTestUtils.init(jsc.hadoopConfiguration(), basePath);
// We have some records to be tagged (two different partitions) // We have some records to be tagged (two different partitions)
schemaStr = FileIOUtils.readAsUTFString(getClass().getResourceAsStream("/exampleSchema.txt")); schemaStr = FileIOUtils.readAsUTFString(getClass().getResourceAsStream("/exampleSchema.txt"));
@@ -100,6 +101,7 @@ public class TestHoodieBloomIndex extends HoodieClientTestHarness {
@After @After
public void tearDown() throws Exception { public void tearDown() throws Exception {
cleanupSparkContexts(); cleanupSparkContexts();
cleanupFileSystem();
cleanupTempFolderAndPath(); cleanupTempFolderAndPath();
} }

2
hudi-client/src/test/java/org/apache/hudi/table/TestCopyOnWriteTable.java
View File

@@ -75,6 +75,7 @@ public class TestCopyOnWriteTable extends HoodieClientTestHarness {
initTempFolderAndPath(); initTempFolderAndPath();
initTableType(); initTableType();
initTestDataGenerator(); initTestDataGenerator();
initFileSystem();
} }
@After @After
@@ -82,6 +83,7 @@ public class TestCopyOnWriteTable extends HoodieClientTestHarness {
cleanupSparkContexts(); cleanupSparkContexts();
cleanupTempFolderAndPath(); cleanupTempFolderAndPath();
cleanupTableType(); cleanupTableType();
cleanupFileSystem();
cleanupTestDataGenerator(); cleanupTestDataGenerator();
} }