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);

Reply via email to