This is an automated email from the ASF dual-hosted git repository. jmanno pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/accumulo-testing.git
The following commit(s) were added to refs/heads/main by this push: new dc42aee Update pom to use accumulo 3.0.0-SNAPSHOT instead of 2.1.0 (#256) dc42aee is described below commit dc42aeec4b4bbe141a641c8fcc01af4c6ef42991 Author: Jeffrey Manno <jeffreymann...@gmail.com> AuthorDate: Sun Nov 20 12:04:00 2022 -0500 Update pom to use accumulo 3.0.0-SNAPSHOT instead of 2.1.0 (#256) --- pom.xml | 2 +- .../apache/accumulo/testing/randomwalk/shard/SortTool.java | 11 ++++------- 2 files changed, 5 insertions(+), 8 deletions(-) diff --git a/pom.xml b/pom.xml index fcc758c..2e4d6dc 100644 --- a/pom.xml +++ b/pom.xml @@ -32,7 +32,7 @@ <name>Apache Accumulo Testing</name> <description>Testing tools for Apache Accumulo</description> <properties> - <accumulo.version>2.1.0-SNAPSHOT</accumulo.version> + <accumulo.version>3.0.0-SNAPSHOT</accumulo.version> <eclipseFormatterStyle>${project.basedir}/contrib/Eclipse-Accumulo-Codestyle.xml</eclipseFormatterStyle> <maven.compiler.release>11</maven.compiler.release> <maven.compiler.source>11</maven.compiler.source> diff --git a/src/main/java/org/apache/accumulo/testing/randomwalk/shard/SortTool.java b/src/main/java/org/apache/accumulo/testing/randomwalk/shard/SortTool.java index d329f51..5e57e5d 100644 --- a/src/main/java/org/apache/accumulo/testing/randomwalk/shard/SortTool.java +++ b/src/main/java/org/apache/accumulo/testing/randomwalk/shard/SortTool.java @@ -45,7 +45,6 @@ public class SortTool extends Configured implements Tool { this.splits = splits; } - @SuppressWarnings("deprecation") @Override public int run(String[] args) throws Exception { Job job = Job.getInstance(getConf(), this.getClass().getSimpleName()); @@ -60,18 +59,16 @@ public class SortTool extends Configured implements Tool { SequenceFileInputFormat.setInputPaths(job, seqFile); job.setPartitionerClass( - org.apache.accumulo.core.client.mapreduce.lib.partition.KeyRangePartitioner.class); - org.apache.accumulo.core.client.mapreduce.lib.partition.KeyRangePartitioner.setSplitFile(job, - splitFile); + org.apache.accumulo.hadoop.mapreduce.partition.KeyRangePartitioner.class); + org.apache.accumulo.hadoop.mapreduce.partition.KeyRangePartitioner.setSplitFile(job, splitFile); job.setMapOutputKeyClass(Key.class); job.setMapOutputValueClass(Value.class); job.setNumReduceTasks(splits.size() + 1); - job.setOutputFormatClass( - org.apache.accumulo.core.client.mapreduce.AccumuloFileOutputFormat.class); - org.apache.accumulo.core.client.mapreduce.AccumuloFileOutputFormat.setOutputPath(job, + job.setOutputFormatClass(org.apache.accumulo.hadoop.mapreduce.AccumuloFileOutputFormat.class); + org.apache.accumulo.hadoop.mapreduce.AccumuloFileOutputFormat.setOutputPath(job, new Path(outputDir)); job.waitForCompletion(true);