This is an automated email from the ASF dual-hosted git repository.
mmiller 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 8d87c67 Drop Replication concurrent RW test and IT (#205)
8d87c67 is described below
commit 8d87c676c558ffe8fe38062a95c49d2e501942c3
Author: Mike Miller
AuthorDate: Mon May 9 14:00:03 2022 -0400
Drop Replication concurrent RW test and IT (#205)
* Closes #171
---
.../testing/randomwalk/concurrent/Replication.java | 204 -
.../randomwalk/ReplicationRandomWalkIT.java| 58 --
2 files changed, 262 deletions(-)
diff --git
a/src/main/java/org/apache/accumulo/testing/randomwalk/concurrent/Replication.java
b/src/main/java/org/apache/accumulo/testing/randomwalk/concurrent/Replication.java
deleted file mode 100644
index 444d000..000
---
a/src/main/java/org/apache/accumulo/testing/randomwalk/concurrent/Replication.java
+++ /dev/null
@@ -1,204 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.accumulo.testing.randomwalk.concurrent;
-
-import static
com.google.common.util.concurrent.Uninterruptibles.sleepUninterruptibly;
-import static
org.apache.accumulo.core.conf.Property.MANAGER_REPLICATION_SCAN_INTERVAL;
-import static org.apache.accumulo.core.conf.Property.REPLICATION_NAME;
-import static org.apache.accumulo.core.conf.Property.REPLICATION_PEERS;
-import static org.apache.accumulo.core.conf.Property.REPLICATION_PEER_PASSWORD;
-import static org.apache.accumulo.core.conf.Property.REPLICATION_PEER_USER;
-import static
org.apache.accumulo.core.conf.Property.REPLICATION_WORK_ASSIGNMENT_SLEEP;
-import static
org.apache.accumulo.core.conf.Property.REPLICATION_WORK_PROCESSOR_DELAY;
-import static
org.apache.accumulo.core.conf.Property.REPLICATION_WORK_PROCESSOR_PERIOD;
-import static org.apache.accumulo.core.conf.Property.TABLE_REPLICATION;
-import static org.apache.accumulo.core.conf.Property.TABLE_REPLICATION_TARGET;
-
-import java.util.Map.Entry;
-import java.util.Properties;
-import java.util.Random;
-import java.util.Set;
-import java.util.SortedSet;
-import java.util.TreeSet;
-import java.util.UUID;
-import java.util.concurrent.TimeUnit;
-
-import org.apache.accumulo.core.client.AccumuloClient;
-import org.apache.accumulo.core.client.BatchWriter;
-import org.apache.accumulo.core.client.Scanner;
-import org.apache.accumulo.core.client.admin.InstanceOperations;
-import org.apache.accumulo.core.client.admin.TableOperations;
-import org.apache.accumulo.core.conf.ClientProperty;
-import org.apache.accumulo.core.data.Key;
-import org.apache.accumulo.core.data.Mutation;
-import org.apache.accumulo.core.data.Value;
-import org.apache.accumulo.core.security.Authorizations;
-import org.apache.accumulo.testing.TestProps;
-import org.apache.accumulo.testing.randomwalk.RandWalkEnv;
-import org.apache.accumulo.testing.randomwalk.State;
-import org.apache.accumulo.testing.randomwalk.Test;
-import org.apache.hadoop.io.Text;
-
-@Deprecated
-public class Replication extends Test {
-
- final int ROWS = 1000;
- final int COLS = 50;
-
- @Override
- public void visit(State state, RandWalkEnv env, Properties props) throws
Exception {
-final AccumuloClient c = env.getAccumuloClient();
-final String instName =
ClientProperty.INSTANCE_NAME.getValue(c.properties());
-final String zookeepers =
ClientProperty.INSTANCE_ZOOKEEPERS.getValue(c.properties());
-final InstanceOperations iOps = c.instanceOperations();
-final TableOperations tOps = c.tableOperations();
-
-// Replicate to ourselves
-iOps.setProperty(REPLICATION_NAME.getKey(), instName);
-iOps.setProperty(REPLICATION_PEERS.getKey() + instName,
-"org.apache.accumulo.tserver.replication.AccumuloReplicaSystem," +
instName + ","
-+ zookeepers);
-iOps.setProperty(REPLICATION_PEER_USER.getKey() + instName,
env.getAccumuloUserName());
-iOps.setProperty(REPLICATION_PEER_PASSWORD.getKey() + instName,
env.getAccumuloPassword());
-// Tweak some replication parameters to make the replication go faster
-