Skip to content
Permalink
Browse files
Fix split point code for bulk ingest
  • Loading branch information
ctubbsii committed Jun 25, 2019
1 parent 0dd88ca commit 4336dfb8e9a617d16322e5c6e57de901ddde6e10
Showing 1 changed file with 1 addition and 1 deletion.
@@ -97,7 +97,7 @@ public int run(String[] args) throws Exception {
}

job.setPartitionerClass(KeyRangePartitioner.class);
KeyRangePartitioner.setSplitFile(job, splitsFile);
KeyRangePartitioner.setSplitFile(job, fs.getUri() + splitsFile);

job.waitForCompletion(true);
boolean success = job.isSuccessful();

0 comments on commit 4336dfb

Please sign in to comment.