lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] Fix partition typo (#1209)

Browse Source
This commit is contained in:
lamber-ken
2020-01-12 09:35:55 +08:00
committed by leesf
parent e103165083
commit 017ee8e661
4 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -910,7 +910,7 @@ public class TestCleaner extends TestHoodieClientBase {
* Test CLeaner Stat when there are no partition paths. * Test CLeaner Stat when there are no partition paths.
*/ */
@Test @Test
public void testCleaningWithZeroPartitonPaths() throws IOException { public void testCleaningWithZeroPartitionPaths() throws IOException {
HoodieWriteConfig config = HoodieWriteConfig.newBuilder().withPath(basePath).withAssumeDatePartitioning(true) HoodieWriteConfig config = HoodieWriteConfig.newBuilder().withPath(basePath).withAssumeDatePartitioning(true)
.withCompactionConfig(HoodieCompactionConfig.newBuilder() .withCompactionConfig(HoodieCompactionConfig.newBuilder()
.withCleanerPolicy(HoodieCleaningPolicy.KEEP_LATEST_COMMITS).retainCommits(2).build()) .withCleanerPolicy(HoodieCleaningPolicy.KEEP_LATEST_COMMITS).retainCommits(2).build())

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

@@ -416,7 +416,7 @@ public class TestCopyOnWriteTable extends HoodieClientTestHarness {
WorkloadProfile profile = new WorkloadProfile(jsc.parallelize(records)); WorkloadProfile profile = new WorkloadProfile(jsc.parallelize(records));
HoodieCopyOnWriteTable.UpsertPartitioner partitioner = HoodieCopyOnWriteTable.UpsertPartitioner partitioner =
(HoodieCopyOnWriteTable.UpsertPartitioner) table.getUpsertPartitioner(profile); (HoodieCopyOnWriteTable.UpsertPartitioner) table.getUpsertPartitioner(profile);
assertEquals("Update record should have gone to the 1 update partiton", 0, partitioner.getPartition( assertEquals("Update record should have gone to the 1 update partition", 0, partitioner.getPartition(
new Tuple2<>(updateRecords.get(0).getKey(), Option.ofNullable(updateRecords.get(0).getCurrentLocation())))); new Tuple2<>(updateRecords.get(0).getKey(), Option.ofNullable(updateRecords.get(0).getCurrentLocation()))));
return partitioner; return partitioner;
} }

2
hudi-common/src/test/java/org/apache/hudi/common/table/view/TestIncrementalFSViewSync.java
View File

@@ -329,7 +329,7 @@ public class TestIncrementalFSViewSync extends HoodieCommonTestHarness {
Assert.assertEquals(State.COMPLETED, view.getLastInstant().get().getState()); Assert.assertEquals(State.COMPLETED, view.getLastInstant().get().getState());
Assert.assertEquals(HoodieTimeline.CLEAN_ACTION, view.getLastInstant().get().getAction()); Assert.assertEquals(HoodieTimeline.CLEAN_ACTION, view.getLastInstant().get().getAction());
partitions.forEach(p -> { partitions.forEach(p -> {
LOG.info("PARTTITION : " + p); LOG.info("PARTITION : " + p);
LOG.info("\tFileSlices :" + view.getAllFileSlices(p).collect(Collectors.toList())); LOG.info("\tFileSlices :" + view.getAllFileSlices(p).collect(Collectors.toList()));
}); });

2
hudi-hive/src/main/java/org/apache/hudi/hive/HoodieHiveClient.java
View File

@@ -133,7 +133,7 @@ public class HoodieHiveClient {
} }
/** /**
* Add the (NEW) partitons to the table. * Add the (NEW) partitions to the table.
*/ */
void addPartitionsToTable(List<String> partitionsToAdd) { void addPartitionsToTable(List<String> partitionsToAdd) {
if (partitionsToAdd.isEmpty()) { if (partitionsToAdd.isEmpty()) {