lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-484] Fix NPE when reading IncrementalPull.sqltemplate in HiveIncrementalPuller (#1167)

Browse Source
This commit is contained in:
lamber-ken
2020-01-05 15:53:47 +08:00
committed by vinoth chandar
parent 7031445eb3
commit 28ccf8c521
2 changed files with 28 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
hudi-utilities/src/main/java/org/apache/hudi/utilities/HiveIncrementalPuller.java
View File

@@ -112,7 +112,7 @@ public class HiveIncrementalPuller {
this.config = config;
validateConfig(config);
String templateContent =
FileIOUtils.readAsUTFString(this.getClass().getResourceAsStream("IncrementalPull.sqltemplate"));
FileIOUtils.readAsUTFString(this.getClass().getResourceAsStream("/IncrementalPull.sqltemplate"));
incrementalPullSQLtemplate = new ST(templateContent);
}

27
hudi-utilities/src/test/java/org/apache/hudi/utilities/TestHiveIncrementalPuller.java Normal file
View File

@@ -0,0 +1,27 @@
package org.apache.hudi.utilities;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
public class TestHiveIncrementalPuller {
private HiveIncrementalPuller.Config config;
@Before
public void setup() {
config = new HiveIncrementalPuller.Config();
}
@Test
public void testInitHiveIncrementalPuller() {
try {
new HiveIncrementalPuller(config);
} catch (Exception e) {
Assert.fail("Unexpected exception while initing HiveIncrementalPuller, msg: " + e.getMessage());
}
}
}