You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by jm...@apache.org on 2021/03/24 18:08:34 UTC
[accumulo-examples] branch main updated: Update BulkIngestExample
This is an automated email from the ASF dual-hosted git repository.
jmark99 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/accumulo-examples.git
The following commit(s) were added to refs/heads/main by this push:
new be2545d Update BulkIngestExample
be2545d is described below
commit be2545d4c864477ee1fa9e58ee5ba5861ea857b5
Author: Mark Owens <jm...@apache.org>
AuthorDate: Wed Mar 24 14:08:28 2021 -0400
Update BulkIngestExample
Correct invalid return type from main method in BulkIngestExample.
---
.../apache/accumulo/examples/mapreduce/bulk/BulkIngestExample.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/src/main/java/org/apache/accumulo/examples/mapreduce/bulk/BulkIngestExample.java b/src/main/java/org/apache/accumulo/examples/mapreduce/bulk/BulkIngestExample.java
index d5b3aa1..6b27309 100644
--- a/src/main/java/org/apache/accumulo/examples/mapreduce/bulk/BulkIngestExample.java
+++ b/src/main/java/org/apache/accumulo/examples/mapreduce/bulk/BulkIngestExample.java
@@ -102,13 +102,13 @@ public final class BulkIngestExample {
}
}
- public static int main(String[] args) throws Exception {
+ public static void main(String[] args) throws Exception {
ClientOpts opts = new ClientOpts();
opts.parseArgs(BulkIngestExample.class.getName(), args);
FileSystem fs = FileSystem.get(opts.getHadoopConfig());
generateTestData(fs);
- return ingestTestData(fs, opts);
+ ingestTestData(fs, opts);
}
private static void generateTestData(FileSystem fs) throws IOException {