You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ct...@apache.org on 2022/12/01 21:52:58 UTC
[accumulo] branch 2.1 updated (b793a1f97e -> 0928f740f9)
This is an automated email from the ASF dual-hosted git repository.
ctubbsii pushed a change to branch 2.1
in repository https://gitbox.apache.org/repos/asf/accumulo.git
omit b793a1f97e Merge branch 'main' into 2.1
omit 9e8964aeaa Fix flaky AuthenticationTokenSecretManagerTest (#3099)
omit 6328bf3b16 Merge branch '2.1'
omit b570142333 Merge branch '2.1'
omit 5c870af501 Merge branch '2.1'
omit 9bbde86a68 Remove deprecated replication (#3080)
omit abcf8663bc Merge branch '2.1'
omit f8b7b03694 Use constants for tables instead of string literals (#3089)
omit f3d9903f80 Merge branch '2.1'
omit 10234edfb3 Merge branch '2.1'
omit b7d00d068f Merge branch '2.1'
omit f389518b6b Merge branch '2.1'
omit a7c0575e01 Remove legacy ClientConfiguration code (#3074)
omit 7448970bc2 Remove Connector and Instance legacy client APIs (#3073)
omit b546b514cc Drop old Map Reduce code (#2443)
omit 78e0319e87 Remove FileSystemMonitor (#1328)
omit 48398b0573 Merge branch '2.1'
This update removed existing revisions from the reference, leaving the
reference pointing at a previous point in the repository history.
* -- * -- N refs/heads/2.1 (0928f740f9)
\
O -- O -- O (b793a1f97e)
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
assemble/pom.xml | 7 +-
core/pom.xml | 12 +-
.../java/org/apache/accumulo/core/Constants.java | 1 +
.../accumulo/core/client/AccumuloClient.java | 18 +-
.../apache/accumulo/core/client/BatchWriter.java | 2 +-
.../accumulo/core/client/BatchWriterConfig.java | 2 +
.../accumulo/core/client/ClientConfiguration.java | 547 ++++
.../org/apache/accumulo/core/client/Connector.java | 283 +++
.../org/apache/accumulo/core/client/Instance.java | 139 ++
.../core/client/MutationsRejectedException.java | 25 +
.../core/client/TableOfflineException.java | 8 +
.../accumulo/core/client/ZooKeeperInstance.java | 203 ++
.../core/client/admin/ReplicationOperations.java | 84 +
.../core/client/mapred/AbstractInputFormat.java | 751 ++++++
.../client/mapred/AccumuloFileOutputFormat.java | 176 ++
.../core/client/mapred/AccumuloInputFormat.java | 107 +
.../mapred/AccumuloMultiTableInputFormat.java | 108 +
.../core/client/mapred/AccumuloOutputFormat.java | 577 +++++
.../core/client/mapred/AccumuloRowInputFormat.java | 99 +
.../core/client/mapred/InputFormatBase.java | 387 +++
.../core/client/mapred/RangeInputSplit.java | 49 +
.../core/client/mapreduce/AbstractInputFormat.java | 781 ++++++
.../client/mapreduce/AccumuloFileOutputFormat.java | 172 ++
.../core/client/mapreduce/AccumuloInputFormat.java | 92 +
.../mapreduce/AccumuloMultiTableInputFormat.java | 100 +
.../client/mapreduce/AccumuloOutputFormat.java | 581 +++++
.../client/mapreduce/AccumuloRowInputFormat.java | 88 +
.../core/client/mapreduce/InputFormatBase.java | 386 +++
.../core/client/mapreduce/InputTableConfig.java | 394 +++
.../core/client/mapreduce/RangeInputSplit.java | 524 ++++
.../lib/partition/KeyRangePartitioner.java | 67 +
.../mapreduce/lib}/partition/RangePartitioner.java | 8 +-
.../PeerExistsException.java} | 37 +-
.../PeerNotFoundException.java} | 40 +-
.../core/clientImpl/ClientConfConverter.java | 246 +-
.../accumulo/core/clientImpl/ClientContext.java | 64 +-
.../accumulo/core/clientImpl/ConnectorImpl.java | 212 ++
.../core/clientImpl/ReplicationOperationsImpl.java | 150 ++
.../core/clientImpl/mapred/BatchInputSplit.java | 52 +
.../core/clientImpl/mapreduce/BatchInputSplit.java | 200 ++
.../clientImpl/mapreduce/DelegationTokenStub.java | 83 +
.../core/clientImpl/mapreduce/SplitUtils.java | 90 +
.../clientImpl/mapreduce/lib/ConfiguratorBase.java | 520 ++++
.../mapreduce/lib/DistributedCacheHelper.java | 2 +-
.../mapreduce/lib/FileOutputConfigurator.java | 242 ++
.../mapreduce/lib/InputConfigurator.java | 924 +++++++
.../mapreduce/lib/OutputConfigurator.java | 203 ++
.../apache/accumulo/core/conf/ClientProperty.java | 12 +-
.../org/apache/accumulo/core/conf/Property.java | 125 +-
.../accumulo/core/data/ConditionalMutation.java | 7 +
.../org/apache/accumulo/core/data/Mutation.java | 90 +-
.../core/fate/zookeeper/ZooCacheFactory.java | 10 +-
.../org/apache/accumulo/core/file/rfile/RFile.java | 2 +-
.../core/metadata/schema/MetadataSchema.java | 55 +
.../accumulo/core/metrics/MetricsProducer.java | 42 +
.../apache/accumulo/core/metrics/MetricsUtil.java | 18 +
.../ProtobufUtil.java} | 39 +-
.../AccumuloReplicationReplayer.java} | 39 +-
.../replication/ReplicationConfigurationUtil.java | 34 +-
.../ReplicationConstants.java} | 36 +-
.../core/replication/ReplicationSchema.java | 281 +++
.../core/replication/ReplicationTable.java | 106 +
.../ReplicationTableOfflineException.java} | 31 +-
.../core/replication/ReplicationTarget.java | 198 ++
.../ReplicationCoordinatorThriftClient.java | 150 ++
.../clients/ReplicationServicerThriftClient.java} | 32 +-
.../core/rpc/clients/ThriftClientTypes.java | 6 +
.../accumulo/core/singletons/SingletonManager.java | 27 +-
.../org/apache/accumulo/core/util/CleanUp.java | 86 +
.../org/apache/accumulo/core/util/Validators.java | 4 +-
.../accumulo/core/util/threads/ThreadPools.java | 37 +-
core/src/main/scripts/generate-thrift.sh | 2 +-
core/src/main/spotbugs/exclude-filter.xml | 1 +
.../core/manager/thrift/ManagerClientService.java | 1421 +++++++++++
.../core/replication/thrift/KeyValues.java | 461 ++++
.../thrift/RemoteReplicationErrorCode.java | 70 +
.../thrift/RemoteReplicationException.java | 527 ++++
.../replication/thrift/ReplicationCoordinator.java | 1263 ++++++++++
.../thrift/ReplicationCoordinatorErrorCode.java | 64 +
.../thrift/ReplicationCoordinatorException.java | 527 ++++
.../replication/thrift/ReplicationServicer.java | 2638 ++++++++++++++++++++
.../accumulo/core/replication/thrift/WalEdits.java | 456 ++++
core/src/main/thrift/manager.thrift | 10 +
core/src/main/thrift/replication.thrift | 86 +
.../core/client/ClientConfigurationTest.java | 98 +
.../core/client/ZooKeeperInstanceTest.java | 197 ++
.../mapred/AccumuloFileOutputFormatTest.java | 95 +
.../client/mapred/AccumuloInputFormatTest.java | 182 ++
.../mapred/AccumuloMultiTableInputFormatTest.java | 71 +
.../client/mapred/AccumuloOutputFormatTest.java | 75 +
.../core/client/mapred/RangeInputSplitTest.java | 115 +
.../mapreduce/AccumuloFileOutputFormatTest.java | 97 +
.../client/mapreduce/AccumuloInputFormatTest.java | 202 ++
.../AccumuloMultiTableInputFormatTest.java | 63 +
.../client/mapreduce/AccumuloOutputFormatTest.java | 75 +
.../client/mapreduce/InputTableConfigTest.java | 130 +
.../core/client/mapreduce/RangeInputSplitTest.java | 119 +
.../lib/partition/RangePartitionerTest.java | 88 +
.../core/clientImpl/ClientConfConverterTest.java | 27 +-
.../clientImpl/mapreduce/BatchInputSplitTest.java | 117 +
.../mapreduce/lib/ConfiguratorBaseTest.java | 131 +
.../org/apache/accumulo/core/data/TableIdTest.java | 10 +-
.../core/metadata/MetadataServicerTest.java | 20 +
.../ReplicationConfigurationUtilTest.java | 93 +
.../core/replication/ReplicationSchemaTest.java | 138 +
.../core/replication/ReplicationTargetTest.java | 101 +
.../core/singletons/SingletonManagerTest.java | 43 +-
.../apache/accumulo/core/util/ValidatorsTest.java | 18 +-
hadoop-mapreduce/pom.xml | 4 +-
.../mapreduce/partition/RangePartitioner.java | 2 +-
.../hadoopImpl/mapreduce/lib/ConfiguratorBase.java | 1 +
iterator-test-harness/pom.xml | 2 +-
minicluster/pom.xml | 2 +-
.../apache/accumulo/cluster/AccumuloCluster.java | 8 +
.../standalone/StandaloneAccumuloCluster.java | 7 +
.../accumulo/minicluster/MiniAccumuloCluster.java | 25 +
.../accumulo/minicluster/MiniAccumuloInstance.java | 53 +
.../miniclusterImpl/MiniAccumuloClusterImpl.java | 18 +
.../miniclusterImpl/MiniAccumuloConfigImpl.java | 16 +
.../MiniAccumuloClusterClasspathTest.java | 55 +-
.../MiniAccumuloClusterExistingZooKeepersTest.java | 31 +-
.../MiniAccumuloClusterStartStopTest.java | 9 +-
.../minicluster/MiniAccumuloClusterTest.java | 127 +-
pom.xml | 13 +-
server/base/pom.xml | 29 +-
.../org/apache/accumulo/server/fs/VolumeUtil.java | 15 +-
.../server/init/FileSystemInitializer.java | 25 +-
.../accumulo/server/init/InitialConfiguration.java | 74 +
.../apache/accumulo/server/init/Initialize.java | 3 +
.../accumulo/server/init/ZooKeeperInitializer.java | 14 +
.../accumulo/server/log/WalStateManager.java | 10 +-
.../DistributedWorkQueueWorkAssignerHelper.java | 81 +
.../accumulo/server/replication/ReplicaSystem.java | 50 +
.../server/replication/ReplicaSystemFactory.java | 98 +
.../server/replication/ReplicaSystemHelper.java | 64 +
.../server/replication/ReplicationUtil.java | 212 ++
.../server/replication/StatusCombiner.java | 181 ++
.../server/replication/StatusFormatter.java | 165 ++
.../accumulo/server/replication/StatusUtil.java | 224 ++
.../accumulo/server/replication/WorkAssigner.java | 35 +-
.../replication/ZooKeeperInitialization.java | 44 +
.../server/replication/proto/Replication.java | 1154 +++++++++
.../server/rpc/SaslServerConnectionParams.java | 20 +-
.../rpc/SaslServerDigestCallbackHandler.java | 2 +-
.../accumulo/server/rpc/ThriftProcessorTypes.java | 26 +
.../server/security/SecurityOperation.java | 7 +-
.../apache/accumulo/server/tablets/TabletTime.java | 1 +
.../accumulo/server/util/FileSystemMonitor.java | 158 ++
.../accumulo/server/util/ReplicationTableUtil.java | 195 ++
.../base/src/main/protobuf/replication.proto | 40 +-
server/base/src/main/scripts/generate-protobuf.sh | 104 +
.../apache/accumulo/server/ServerContextTest.java | 5 +-
.../constraints/MetadataConstraintsTest.java | 3 +-
.../server/replication/ReplicationUtilTest.java | 115 +
.../server/replication/StatusCombinerTest.java | 295 +++
.../server/replication/StatusUtilTest.java | 64 +
.../server/replication/proto/StatusTest.java | 38 +-
.../server/rpc/SaslServerConnectionParamsTest.java | 2 +-
.../accumulo/server/rpc/TServerUtilsTest.java | 12 +-
.../server/security/SystemCredentialsTest.java | 16 +
.../AuthenticationTokenSecretManagerTest.java | 2 -
.../server/util/FileSystemMonitorTest.java | 101 +
.../server/util/ReplicationTableUtilTest.java | 164 ++
server/compaction-coordinator/pom.xml | 2 +-
server/compactor/pom.xml | 2 +-
server/gc/pom.xml | 6 +-
.../main/java/org/apache/accumulo/gc/GCRun.java | 30 +
.../accumulo/gc/GarbageCollectWriteAheadLogs.java | 56 +
.../accumulo/gc/GarbageCollectionAlgorithm.java | 43 +
.../accumulo/gc/GarbageCollectionEnvironment.java | 8 +
.../apache/accumulo/gc/SimpleGarbageCollector.java | 18 +
.../replication/CloseWriteAheadLogReferences.java | 206 ++
.../gc/GarbageCollectWriteAheadLogsTest.java | 115 +-
.../apache/accumulo/gc/GarbageCollectionTest.java | 91 +-
server/manager/pom.xml | 6 +-
.../java/org/apache/accumulo/manager/Manager.java | 79 +-
.../manager/ManagerClientServiceHandler.java | 113 +
.../accumulo/manager/metrics/ManagerMetrics.java | 4 +
.../manager/metrics/ReplicationMetrics.java | 174 ++
.../DistributedWorkQueueWorkAssigner.java | 267 ++
.../manager/replication/FinishedWorkUpdater.java | 190 ++
.../replication/ManagerReplicationCoordinator.java | 110 +
.../RemoveCompleteReplicationRecords.java | 225 ++
.../manager/replication/ReplicationDriver.java | 130 +
.../replication/SequentialWorkAssigner.java | 229 ++
.../accumulo/manager/replication/StatusMaker.java | 304 +++
.../manager/replication/UnorderedWorkAssigner.java | 185 ++
.../accumulo/manager/replication/WorkDriver.java | 98 +
.../accumulo/manager/replication/WorkMaker.java | 225 ++
.../manager/tableOps/bulkVer1/BulkImport.java | 3 +-
.../replication/UnorderedWorkAssigner.java} | 31 +-
.../manager/metrics/ReplicationMetricsTest.java | 112 +
...DistributedWorkQueueWorkAssignerHelperTest.java | 59 +
.../ManagerReplicationCoordinatorTest.java | 112 +
.../replication/SequentialWorkAssignerTest.java | 109 +
.../replication/UnorderedWorkAssignerTest.java | 138 +
.../manager/replication/WorkMakerTest.java | 41 +
server/master/pom.xml | 2 +-
server/monitor/pom.xml | 2 +-
.../rest/replication/ReplicationInformation.java | 56 +
.../rest/replication/ReplicationResource.java | 221 ++
.../org/apache/accumulo/monitor/view/WebViews.java | 19 +
.../accumulo/monitor/resources/js/functions.js | 8 +
.../accumulo/monitor/resources/js/replication.js | 79 +
.../apache/accumulo/monitor/templates/navbar.ftl | 3 +-
.../accumulo/monitor/templates/replication.ftl | 42 +
server/native/pom.xml | 2 +-
server/tserver/pom.xml | 6 +-
.../org/apache/accumulo/tserver/TabletServer.java | 98 +
.../accumulo/tserver/log/TabletServerLogger.java | 154 +-
.../tserver/replication/AccumuloReplicaSystem.java | 754 ++++++
.../BatchWriterReplicationReplayer.java | 174 ++
.../tserver/replication/ReplicationProcessor.java | 182 ++
.../replication/ReplicationServicerHandler.java | 125 +
.../tserver/replication/ReplicationStats.java | 64 +
.../tserver/replication/ReplicationWorker.java | 78 +
.../tserver/replication/WalClientExecReturn.java | 98 +
.../tserver/replication/WalReplication.java | 63 +
.../accumulo/tserver/tablet/DatafileManager.java | 39 +
.../org/apache/accumulo/tserver/tablet/Tablet.java | 22 +-
.../replication/AccumuloReplicaSystemTest.java | 545 ++++
.../BatchWriterReplicationReplayerTest.java | 204 ++
.../replication/ReplicationProcessorTest.java | 102 +
.../src/test/resources/log4j2-test.properties | 9 +-
shell/pom.xml | 2 +-
.../main/java/org/apache/accumulo/shell/Shell.java | 4 +-
.../accumulo/shell/commands/ScriptCommand.java | 317 +++
start/pom.xml | 2 +-
test/pom.xml | 6 +-
.../test/ManagerRepairsDualAssignmentIT.java | 8 +
.../org/apache/accumulo/test/NamespacesIT.java | 2 +-
.../accumulo/test/ScanServerMetadataEntriesIT.java | 3 +-
.../apache/accumulo/test/TableOperationsIT.java | 9 +-
.../accumulo/test/VerifySerialRecoveryIT.java | 5 +-
.../org/apache/accumulo/test/WaitForBalanceIT.java | 3 +-
.../test/compaction/CompactionExecutorIT.java | 5 +-
.../test/compaction/ExternalCompaction_1_IT.java | 3 +-
.../accumulo/test/functional/AccumuloClientIT.java | 36 +
.../apache/accumulo/test/functional/CleanUpIT.java | 172 ++
.../org/apache/accumulo/test/functional/SslIT.java | 12 +
.../test/functional/SslWithClientAuthIT.java | 6 +
.../functional/TabletStateChangeIteratorIT.java | 4 +-
.../CloseWriteAheadLogReferencesIT.java | 189 ++
.../test/mapred/AccumuloFileOutputFormatIT.java | 234 ++
.../test/mapred/AccumuloInputFormatIT.java | 265 ++
.../mapred/AccumuloMultiTableInputFormatIT.java | 176 ++
.../test/mapred/AccumuloOutputFormatIT.java | 243 ++
.../test/mapred/AccumuloRowInputFormatIT.java | 208 ++
.../apache/accumulo/test/mapred/TokenFileIT.java | 208 ++
.../test/mapreduce/AccumuloFileOutputFormatIT.java | 249 ++
.../test/mapreduce/AccumuloInputFormatIT.java | 556 +++++
.../mapreduce/AccumuloMultiTableInputFormatIT.java | 178 ++
.../test/mapreduce/AccumuloOutputFormatIT.java | 172 ++
.../test/mapreduce/AccumuloRowInputFormatIT.java | 205 ++
.../accumulo/test}/mapreduce/MapReduceIT.java | 14 +-
.../apache/accumulo/test/mapreduce/RowHash.java | 128 +
.../accumulo/test/mapreduce/TokenFileIT.java | 212 ++
.../apache/accumulo/test/metrics/MetricsIT.java | 2 +-
.../test/replication/CyclicReplicationIT.java | 378 +++
.../test/replication/FinishedWorkUpdaterIT.java | 193 ++
...GarbageCollectorCommunicatesWithTServersIT.java | 431 ++++
.../test/replication/KerberosReplicationIT.java | 275 ++
.../test/replication/MockReplicaSystem.java | 103 +
.../replication/MultiInstanceReplicationIT.java | 814 ++++++
.../replication/MultiTserverReplicationIT.java | 131 +
.../RemoveCompleteReplicationRecordsIT.java | 364 +++
.../accumulo/test/replication/ReplicationIT.java | 1514 +++++++++++
.../replication/ReplicationOperationsImplIT.java | 455 ++++
.../test/replication/SequentialWorkAssignerIT.java | 401 +++
.../test/replication/StatusCombinerMacIT.java | 144 ++
.../accumulo/test/replication/StatusMakerIT.java | 378 +++
.../test/replication/UnorderedWorkAssignerIT.java | 256 ++
.../UnorderedWorkAssignerReplicationIT.java | 810 ++++++
.../UnusedWalDoesntCloseReplicationStatusIT.java | 244 ++
.../accumulo/test/replication/WorkMakerIT.java | 236 ++
test/src/main/resources/log4j2-test.properties | 17 +-
276 files changed, 42280 insertions(+), 736 deletions(-)
create mode 100644 core/src/main/java/org/apache/accumulo/core/client/ClientConfiguration.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/client/Connector.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/client/Instance.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/client/ZooKeeperInstance.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/client/admin/ReplicationOperations.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/client/mapred/AbstractInputFormat.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/client/mapred/AccumuloFileOutputFormat.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/client/mapred/AccumuloInputFormat.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/client/mapred/AccumuloMultiTableInputFormat.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/client/mapred/AccumuloOutputFormat.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/client/mapred/AccumuloRowInputFormat.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/client/mapred/InputFormatBase.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/client/mapred/RangeInputSplit.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/client/mapreduce/AbstractInputFormat.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/client/mapreduce/AccumuloFileOutputFormat.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/client/mapreduce/AccumuloInputFormat.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/client/mapreduce/AccumuloMultiTableInputFormat.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/client/mapreduce/AccumuloOutputFormat.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/client/mapreduce/AccumuloRowInputFormat.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/client/mapreduce/InputFormatBase.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/client/mapreduce/InputTableConfig.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/client/mapreduce/RangeInputSplit.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/client/mapreduce/lib/partition/KeyRangePartitioner.java
copy {hadoop-mapreduce/src/main/java/org/apache/accumulo/hadoop/mapreduce => core/src/main/java/org/apache/accumulo/core/client/mapreduce/lib}/partition/RangePartitioner.java (92%)
copy core/src/main/java/org/apache/accumulo/core/client/{TableOfflineException.java => replication/PeerExistsException.java} (57%)
copy core/src/main/java/org/apache/accumulo/core/client/{TableOfflineException.java => replication/PeerNotFoundException.java} (57%)
create mode 100644 core/src/main/java/org/apache/accumulo/core/clientImpl/ConnectorImpl.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/clientImpl/ReplicationOperationsImpl.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/clientImpl/mapred/BatchInputSplit.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/clientImpl/mapreduce/BatchInputSplit.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/clientImpl/mapreduce/DelegationTokenStub.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/clientImpl/mapreduce/SplitUtils.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/clientImpl/mapreduce/lib/ConfiguratorBase.java
rename {hadoop-mapreduce/src/main/java/org/apache/accumulo/hadoopImpl => core/src/main/java/org/apache/accumulo/core/clientImpl}/mapreduce/lib/DistributedCacheHelper.java (98%)
create mode 100644 core/src/main/java/org/apache/accumulo/core/clientImpl/mapreduce/lib/FileOutputConfigurator.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/clientImpl/mapreduce/lib/InputConfigurator.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/clientImpl/mapreduce/lib/OutputConfigurator.java
copy core/src/main/java/org/apache/accumulo/core/{client/TableOfflineException.java => protobuf/ProtobufUtil.java} (54%)
copy core/src/main/java/org/apache/accumulo/core/{client/TableOfflineException.java => replication/AccumuloReplicationReplayer.java} (53%)
copy server/manager/src/main/java/org/apache/accumulo/manager/metrics/ManagerMetrics.java => core/src/main/java/org/apache/accumulo/core/replication/ReplicationConfigurationUtil.java (54%)
copy core/src/main/java/org/apache/accumulo/core/{client/TableOfflineException.java => replication/ReplicationConstants.java} (53%)
create mode 100644 core/src/main/java/org/apache/accumulo/core/replication/ReplicationSchema.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/replication/ReplicationTable.java
copy core/src/main/java/org/apache/accumulo/core/{client/TableOfflineException.java => replication/ReplicationTableOfflineException.java} (57%)
create mode 100644 core/src/main/java/org/apache/accumulo/core/replication/ReplicationTarget.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/rpc/clients/ReplicationCoordinatorThriftClient.java
copy core/src/main/java/org/apache/accumulo/core/{client/TableOfflineException.java => rpc/clients/ReplicationServicerThriftClient.java} (53%)
create mode 100644 core/src/main/java/org/apache/accumulo/core/util/CleanUp.java
create mode 100644 core/src/main/thrift-gen-java/org/apache/accumulo/core/replication/thrift/KeyValues.java
create mode 100644 core/src/main/thrift-gen-java/org/apache/accumulo/core/replication/thrift/RemoteReplicationErrorCode.java
create mode 100644 core/src/main/thrift-gen-java/org/apache/accumulo/core/replication/thrift/RemoteReplicationException.java
create mode 100644 core/src/main/thrift-gen-java/org/apache/accumulo/core/replication/thrift/ReplicationCoordinator.java
create mode 100644 core/src/main/thrift-gen-java/org/apache/accumulo/core/replication/thrift/ReplicationCoordinatorErrorCode.java
create mode 100644 core/src/main/thrift-gen-java/org/apache/accumulo/core/replication/thrift/ReplicationCoordinatorException.java
create mode 100644 core/src/main/thrift-gen-java/org/apache/accumulo/core/replication/thrift/ReplicationServicer.java
create mode 100644 core/src/main/thrift-gen-java/org/apache/accumulo/core/replication/thrift/WalEdits.java
create mode 100644 core/src/main/thrift/replication.thrift
create mode 100644 core/src/test/java/org/apache/accumulo/core/client/ClientConfigurationTest.java
create mode 100644 core/src/test/java/org/apache/accumulo/core/client/ZooKeeperInstanceTest.java
create mode 100644 core/src/test/java/org/apache/accumulo/core/client/mapred/AccumuloFileOutputFormatTest.java
create mode 100644 core/src/test/java/org/apache/accumulo/core/client/mapred/AccumuloInputFormatTest.java
create mode 100644 core/src/test/java/org/apache/accumulo/core/client/mapred/AccumuloMultiTableInputFormatTest.java
create mode 100644 core/src/test/java/org/apache/accumulo/core/client/mapred/AccumuloOutputFormatTest.java
create mode 100644 core/src/test/java/org/apache/accumulo/core/client/mapred/RangeInputSplitTest.java
create mode 100644 core/src/test/java/org/apache/accumulo/core/client/mapreduce/AccumuloFileOutputFormatTest.java
create mode 100644 core/src/test/java/org/apache/accumulo/core/client/mapreduce/AccumuloInputFormatTest.java
create mode 100644 core/src/test/java/org/apache/accumulo/core/client/mapreduce/AccumuloMultiTableInputFormatTest.java
create mode 100644 core/src/test/java/org/apache/accumulo/core/client/mapreduce/AccumuloOutputFormatTest.java
create mode 100644 core/src/test/java/org/apache/accumulo/core/client/mapreduce/InputTableConfigTest.java
create mode 100644 core/src/test/java/org/apache/accumulo/core/client/mapreduce/RangeInputSplitTest.java
create mode 100644 core/src/test/java/org/apache/accumulo/core/client/mapreduce/lib/partition/RangePartitionerTest.java
create mode 100644 core/src/test/java/org/apache/accumulo/core/clientImpl/mapreduce/BatchInputSplitTest.java
create mode 100644 core/src/test/java/org/apache/accumulo/core/clientImpl/mapreduce/lib/ConfiguratorBaseTest.java
create mode 100644 core/src/test/java/org/apache/accumulo/core/replication/ReplicationConfigurationUtilTest.java
create mode 100644 core/src/test/java/org/apache/accumulo/core/replication/ReplicationSchemaTest.java
create mode 100644 core/src/test/java/org/apache/accumulo/core/replication/ReplicationTargetTest.java
create mode 100644 minicluster/src/main/java/org/apache/accumulo/minicluster/MiniAccumuloInstance.java
create mode 100644 server/base/src/main/java/org/apache/accumulo/server/replication/DistributedWorkQueueWorkAssignerHelper.java
create mode 100644 server/base/src/main/java/org/apache/accumulo/server/replication/ReplicaSystem.java
create mode 100644 server/base/src/main/java/org/apache/accumulo/server/replication/ReplicaSystemFactory.java
create mode 100644 server/base/src/main/java/org/apache/accumulo/server/replication/ReplicaSystemHelper.java
create mode 100644 server/base/src/main/java/org/apache/accumulo/server/replication/ReplicationUtil.java
create mode 100644 server/base/src/main/java/org/apache/accumulo/server/replication/StatusCombiner.java
create mode 100644 server/base/src/main/java/org/apache/accumulo/server/replication/StatusFormatter.java
create mode 100644 server/base/src/main/java/org/apache/accumulo/server/replication/StatusUtil.java
copy core/src/main/java/org/apache/accumulo/core/client/TableOfflineException.java => server/base/src/main/java/org/apache/accumulo/server/replication/WorkAssigner.java (55%)
create mode 100644 server/base/src/main/java/org/apache/accumulo/server/replication/ZooKeeperInitialization.java
create mode 100644 server/base/src/main/java/org/apache/accumulo/server/replication/proto/Replication.java
create mode 100644 server/base/src/main/java/org/apache/accumulo/server/util/FileSystemMonitor.java
create mode 100644 server/base/src/main/java/org/apache/accumulo/server/util/ReplicationTableUtil.java
copy core/src/main/java/org/apache/accumulo/core/client/TableOfflineException.java => server/base/src/main/protobuf/replication.proto (53%)
create mode 100755 server/base/src/main/scripts/generate-protobuf.sh
create mode 100644 server/base/src/test/java/org/apache/accumulo/server/replication/ReplicationUtilTest.java
create mode 100644 server/base/src/test/java/org/apache/accumulo/server/replication/StatusCombinerTest.java
create mode 100644 server/base/src/test/java/org/apache/accumulo/server/replication/StatusUtilTest.java
copy core/src/main/java/org/apache/accumulo/core/client/TableOfflineException.java => server/base/src/test/java/org/apache/accumulo/server/replication/proto/StatusTest.java (53%)
create mode 100644 server/base/src/test/java/org/apache/accumulo/server/util/FileSystemMonitorTest.java
create mode 100644 server/base/src/test/java/org/apache/accumulo/server/util/ReplicationTableUtilTest.java
create mode 100644 server/gc/src/main/java/org/apache/accumulo/gc/replication/CloseWriteAheadLogReferences.java
create mode 100644 server/manager/src/main/java/org/apache/accumulo/manager/metrics/ReplicationMetrics.java
create mode 100644 server/manager/src/main/java/org/apache/accumulo/manager/replication/DistributedWorkQueueWorkAssigner.java
create mode 100644 server/manager/src/main/java/org/apache/accumulo/manager/replication/FinishedWorkUpdater.java
create mode 100644 server/manager/src/main/java/org/apache/accumulo/manager/replication/ManagerReplicationCoordinator.java
create mode 100644 server/manager/src/main/java/org/apache/accumulo/manager/replication/RemoveCompleteReplicationRecords.java
create mode 100644 server/manager/src/main/java/org/apache/accumulo/manager/replication/ReplicationDriver.java
create mode 100644 server/manager/src/main/java/org/apache/accumulo/manager/replication/SequentialWorkAssigner.java
create mode 100644 server/manager/src/main/java/org/apache/accumulo/manager/replication/StatusMaker.java
create mode 100644 server/manager/src/main/java/org/apache/accumulo/manager/replication/UnorderedWorkAssigner.java
create mode 100644 server/manager/src/main/java/org/apache/accumulo/manager/replication/WorkDriver.java
create mode 100644 server/manager/src/main/java/org/apache/accumulo/manager/replication/WorkMaker.java
copy server/manager/src/main/java/org/apache/accumulo/{manager/metrics/ManagerMetrics.java => master/replication/UnorderedWorkAssigner.java} (50%)
create mode 100644 server/manager/src/test/java/org/apache/accumulo/manager/metrics/ReplicationMetricsTest.java
create mode 100644 server/manager/src/test/java/org/apache/accumulo/manager/replication/DistributedWorkQueueWorkAssignerHelperTest.java
create mode 100644 server/manager/src/test/java/org/apache/accumulo/manager/replication/ManagerReplicationCoordinatorTest.java
create mode 100644 server/manager/src/test/java/org/apache/accumulo/manager/replication/SequentialWorkAssignerTest.java
create mode 100644 server/manager/src/test/java/org/apache/accumulo/manager/replication/UnorderedWorkAssignerTest.java
create mode 100644 server/manager/src/test/java/org/apache/accumulo/manager/replication/WorkMakerTest.java
create mode 100644 server/monitor/src/main/java/org/apache/accumulo/monitor/rest/replication/ReplicationInformation.java
create mode 100644 server/monitor/src/main/java/org/apache/accumulo/monitor/rest/replication/ReplicationResource.java
create mode 100644 server/monitor/src/main/resources/org/apache/accumulo/monitor/resources/js/replication.js
create mode 100644 server/monitor/src/main/resources/org/apache/accumulo/monitor/templates/replication.ftl
create mode 100644 server/tserver/src/main/java/org/apache/accumulo/tserver/replication/AccumuloReplicaSystem.java
create mode 100644 server/tserver/src/main/java/org/apache/accumulo/tserver/replication/BatchWriterReplicationReplayer.java
create mode 100644 server/tserver/src/main/java/org/apache/accumulo/tserver/replication/ReplicationProcessor.java
create mode 100644 server/tserver/src/main/java/org/apache/accumulo/tserver/replication/ReplicationServicerHandler.java
create mode 100644 server/tserver/src/main/java/org/apache/accumulo/tserver/replication/ReplicationStats.java
create mode 100644 server/tserver/src/main/java/org/apache/accumulo/tserver/replication/ReplicationWorker.java
create mode 100644 server/tserver/src/main/java/org/apache/accumulo/tserver/replication/WalClientExecReturn.java
create mode 100644 server/tserver/src/main/java/org/apache/accumulo/tserver/replication/WalReplication.java
create mode 100644 server/tserver/src/test/java/org/apache/accumulo/tserver/replication/AccumuloReplicaSystemTest.java
create mode 100644 server/tserver/src/test/java/org/apache/accumulo/tserver/replication/BatchWriterReplicationReplayerTest.java
create mode 100644 server/tserver/src/test/java/org/apache/accumulo/tserver/replication/ReplicationProcessorTest.java
create mode 100644 shell/src/main/java/org/apache/accumulo/shell/commands/ScriptCommand.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/functional/CleanUpIT.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/gc/replication/CloseWriteAheadLogReferencesIT.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/mapred/AccumuloFileOutputFormatIT.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/mapred/AccumuloInputFormatIT.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/mapred/AccumuloMultiTableInputFormatIT.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/mapred/AccumuloOutputFormatIT.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/mapred/AccumuloRowInputFormatIT.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/mapred/TokenFileIT.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloFileOutputFormatIT.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloInputFormatIT.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloMultiTableInputFormatIT.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloOutputFormatIT.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloRowInputFormatIT.java
rename {hadoop-mapreduce/src/test/java/org/apache/accumulo/hadoop/its => test/src/main/java/org/apache/accumulo/test}/mapreduce/MapReduceIT.java (88%)
create mode 100644 test/src/main/java/org/apache/accumulo/test/mapreduce/RowHash.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/mapreduce/TokenFileIT.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/replication/CyclicReplicationIT.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/replication/FinishedWorkUpdaterIT.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/replication/GarbageCollectorCommunicatesWithTServersIT.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/replication/KerberosReplicationIT.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/replication/MockReplicaSystem.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/replication/MultiInstanceReplicationIT.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/replication/MultiTserverReplicationIT.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/replication/RemoveCompleteReplicationRecordsIT.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/replication/ReplicationIT.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/replication/ReplicationOperationsImplIT.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/replication/SequentialWorkAssignerIT.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/replication/StatusCombinerMacIT.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/replication/StatusMakerIT.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/replication/UnorderedWorkAssignerIT.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/replication/UnorderedWorkAssignerReplicationIT.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/replication/UnusedWalDoesntCloseReplicationStatusIT.java
create mode 100644 test/src/main/java/org/apache/accumulo/test/replication/WorkMakerIT.java