You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by kt...@apache.org on 2018/10/30 19:40:35 UTC
[accumulo] branch master updated (398c596 -> 2468f0b)
This is an automated email from the ASF dual-hosted git repository.
kturner pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/accumulo.git.
from 398c596 Merge branch '1.9'
add 2468f0b Made AccumuloClient Closeable (#718)
No new revisions were added by this update.
Summary of changes:
.../org/apache/accumulo/core/client/Accumulo.java | 11 +-
.../accumulo/core/client/AccumuloClient.java | 32 +-
.../org/apache/accumulo/core/client/Connector.java | 4 +-
.../accumulo/core/client/ZooKeeperInstance.java | 9 +-
.../core/client/impl/AccumuloClientImpl.java | 48 +-
.../accumulo/core/client/impl/ClientContext.java | 36 +-
.../core/client/impl/ClientInfoFactory.java | 12 -
.../accumulo/core/client/impl/ConnectorImpl.java | 3 +
.../apache/accumulo/core/client/impl/Tables.java | 29 +
.../accumulo/core/client/impl/TabletLocator.java | 41 +
.../core/client/impl/ThriftTransportPool.java | 111 +-
.../accumulo/core/singletons/SingletonManager.java | 194 ++
.../core/singletons/SingletonReservation.java | 67 +
.../SingletonService.java} | 16 +-
.../org/apache/accumulo/core/util/CleanUp.java | 24 +-
.../apache/accumulo/fate/zookeeper/ZooCache.java | 14 +-
.../accumulo/fate/zookeeper/ZooCacheFactory.java | 54 +-
.../apache/accumulo/fate/zookeeper/ZooSession.java | 43 +-
.../core/singletons/SingletonManagerTest.java | 254 +++
.../org/apache/accumulo/server/ServerContext.java | 3 +-
.../org/apache/accumulo/server/ServerInfo.java | 4 +
.../accumulo/test/ArbitraryTablePropertiesIT.java | 241 +--
.../org/apache/accumulo/test/AuditMessageIT.java | 7 +-
.../accumulo/test/BadDeleteMarkersCreatedIT.java | 151 +-
.../org/apache/accumulo/test/BalanceFasterIT.java | 77 +-
.../java/org/apache/accumulo/test/BalanceIT.java | 21 +-
.../accumulo/test/BalanceWithOfflineTableIT.java | 61 +-
.../org/apache/accumulo/test/BatchWriterIT.java | 19 +-
.../accumulo/test/BatchWriterInTabletServerIT.java | 22 +-
.../accumulo/test/BulkImportMonitoringIT.java | 145 +-
.../accumulo/test/BulkImportSequentialRowsIT.java | 63 +-
.../apache/accumulo/test/BulkImportVolumeIT.java | 47 +-
.../java/org/apache/accumulo/test/CleanWalIT.java | 91 +-
.../apache/accumulo/test/ClientSideIteratorIT.java | 62 +-
.../java/org/apache/accumulo/test/CloneIT.java | 435 ++---
.../apache/accumulo/test/ConditionalWriterIT.java | 1943 +++++++++----------
.../test/ConfigurableMajorCompactionIT.java | 35 +-
.../accumulo/test/CountNameNodeOpsBulkIT.java | 154 +-
.../accumulo/test/DetectDeadTabletServersIT.java | 53 +-
.../org/apache/accumulo/test/ExistingMacIT.java | 63 +-
.../java/org/apache/accumulo/test/FindMaxIT.java | 107 +-
.../apache/accumulo/test/GarbageCollectWALIT.java | 23 +-
.../org/apache/accumulo/test/ImportExportIT.java | 189 +-
.../accumulo/test/InterruptibleScannersIT.java | 89 +-
.../accumulo/test/IsolationAndDeepCopyIT.java | 48 +-
.../apache/accumulo/test/KeyValueEqualityIT.java | 57 +-
.../org/apache/accumulo/test/LargeSplitRowIT.java | 264 +--
.../java/org/apache/accumulo/test/LocatorIT.java | 80 +-
.../java/org/apache/accumulo/test/ManySplitIT.java | 77 +-
.../test/MasterRepairsDualAssignmentIT.java | 140 +-
.../accumulo/test/MetaConstraintRetryIT.java | 30 +-
.../apache/accumulo/test/MetaGetsReadersIT.java | 65 +-
.../org/apache/accumulo/test/MetaRecoveryIT.java | 63 +-
.../java/org/apache/accumulo/test/MetaSplitIT.java | 82 +-
.../test/MissingWalHeaderCompletesRecoveryIT.java | 192 +-
.../accumulo/test/MultiTableBatchWriterIT.java | 12 +-
.../apache/accumulo/test/MultiTableRecoveryIT.java | 101 +-
.../org/apache/accumulo/test/NamespacesIT.java | 322 ++--
.../accumulo/test/NewTableConfigurationIT.java | 705 +++----
.../org/apache/accumulo/test/OrIteratorIT.java | 454 ++---
.../test/RecoveryCompactionsAreFlushesIT.java | 60 +-
.../accumulo/test/RewriteTabletDirectoriesIT.java | 165 +-
.../java/org/apache/accumulo/test/SampleIT.java | 361 ++--
.../apache/accumulo/test/ScanFlushWithTimeIT.java | 73 +-
.../org/apache/accumulo/test/ShellConfigIT.java | 26 +-
.../org/apache/accumulo/test/ShellServerIT.java | 320 ++--
.../apache/accumulo/test/SplitCancelsMajCIT.java | 72 +-
.../org/apache/accumulo/test/SplitRecoveryIT.java | 127 +-
.../accumulo/test/TableConfigurationUpdateIT.java | 73 +-
.../apache/accumulo/test/TableOperationsIT.java | 1 +
.../accumulo/test/TabletServerGivesUpIT.java | 47 +-
.../accumulo/test/TabletServerHdfsRestartIT.java | 35 +-
.../apache/accumulo/test/TestRandomDeletes.java | 3 +-
.../ThriftServerBindsBeforeZooKeeperLockIT.java | 189 +-
.../org/apache/accumulo/test/TotalQueuedIT.java | 126 +-
.../test/TracerRecoversAfterOfflineTableIT.java | 111 +-
.../java/org/apache/accumulo/test/UnusedWALIT.java | 65 +-
.../accumulo/test/UserCompactionStrategyIT.java | 258 +--
.../java/org/apache/accumulo/test/UsersIT.java | 41 +-
.../accumulo/test/VerifySerialRecoveryIT.java | 88 +-
.../accumulo/test/VolumeChooserFailureIT.java | 62 +-
.../org/apache/accumulo/test/VolumeChooserIT.java | 182 +-
.../java/org/apache/accumulo/test/VolumeIT.java | 432 ++---
.../org/apache/accumulo/test/WaitForBalanceIT.java | 34 +-
.../org/apache/accumulo/test/YieldScannersIT.java | 185 +-
.../accumulo/test/ZooKeeperPropertiesIT.java | 7 +-
.../accumulo/test/functional/AccumuloClientIT.java | 104 +-
.../accumulo/test/functional/AddSplitIT.java | 64 +-
.../accumulo/test/functional/BackupMasterIT.java | 7 +-
.../test/functional/BadIteratorMincIT.java | 84 +-
.../functional/BalanceAfterCommsFailureIT.java | 65 +-
.../BalanceInPresenceOfOfflineTableIT.java | 14 +-
.../accumulo/test/functional/BatchScanSplitIT.java | 96 +-
.../test/functional/BatchWriterFlushIT.java | 162 +-
.../accumulo/test/functional/BigRootTabletIT.java | 25 +-
.../apache/accumulo/test/functional/BinaryIT.java | 24 +-
.../accumulo/test/functional/BinaryStressIT.java | 53 +-
.../accumulo/test/functional/BloomFilterIT.java | 180 +-
.../accumulo/test/functional/BulkFileIT.java | 59 +-
.../apache/accumulo/test/functional/BulkIT.java | 16 +-
.../accumulo/test/functional/BulkLoadIT.java | 270 +--
.../test/functional/BulkSplitOptimizationIT.java | 106 +-
.../test/functional/ChaoticBalancerIT.java | 39 +-
.../accumulo/test/functional/ClassLoaderIT.java | 49 +-
.../accumulo/test/functional/CleanTmpIT.java | 81 +-
.../apache/accumulo/test/functional/CleanUpIT.java | 20 +-
.../accumulo/test/functional/CloneTestIT.java | 204 +-
.../accumulo/test/functional/CombinerIT.java | 31 +-
.../accumulo/test/functional/CompactionIT.java | 147 +-
.../accumulo/test/functional/ConcurrencyIT.java | 5 +-
.../test/functional/ConcurrentDeleteTableIT.java | 276 +--
.../test/functional/ConfigurableCompactionIT.java | 62 +-
.../accumulo/test/functional/ConstraintIT.java | 79 +-
.../accumulo/test/functional/CreateAndUseIT.java | 97 +-
.../test/functional/CreateInitialSplitsIT.java | 6 +
.../test/functional/CreateManyScannersIT.java | 12 +-
.../accumulo/test/functional/CredentialsIT.java | 68 +-
.../test/functional/DeleteEverythingIT.java | 74 +-
.../accumulo/test/functional/DeleteFailIT.java | 35 +-
.../apache/accumulo/test/functional/DeleteIT.java | 23 +-
.../accumulo/test/functional/DeleteRowsIT.java | 80 +-
.../test/functional/DeleteRowsSplitIT.java | 93 +-
.../test/functional/DeleteTableDuringSplitIT.java | 113 +-
.../test/functional/DeletedTablesDontFlushIT.java | 33 +-
.../accumulo/test/functional/DurabilityIT.java | 174 +-
.../test/functional/DynamicThreadPoolsIT.java | 97 +-
.../accumulo/test/functional/FateStarvationIT.java | 46 +-
.../test/functional/GarbageCollectorIT.java | 255 +--
.../test/functional/HalfDeadTServerIT.java | 155 +-
.../accumulo/test/functional/LargeRowIT.java | 33 +-
.../accumulo/test/functional/LogicalTimeIT.java | 82 +-
.../accumulo/test/functional/MapReduceIT.java | 4 +-
.../test/functional/MasterAssignmentIT.java | 73 +-
.../accumulo/test/functional/MasterFailoverIT.java | 35 +-
.../apache/accumulo/test/functional/MaxOpenIT.java | 98 +-
.../apache/accumulo/test/functional/MergeIT.java | 129 +-
.../accumulo/test/functional/MetadataIT.java | 127 +-
.../test/functional/MetadataMaxFilesIT.java | 101 +-
.../accumulo/test/functional/MetadataSplitIT.java | 19 +-
.../accumulo/test/functional/PermissionsIT.java | 127 +-
.../accumulo/test/functional/ReadWriteIT.java | 264 +--
.../test/functional/RecoveryWithEmptyRFileIT.java | 65 +-
.../test/functional/RegexGroupBalanceIT.java | 145 +-
.../apache/accumulo/test/functional/RenameIT.java | 27 +-
.../apache/accumulo/test/functional/RestartIT.java | 397 ++--
.../accumulo/test/functional/RestartStressIT.java | 73 +-
.../accumulo/test/functional/RowDeleteIT.java | 75 +-
.../apache/accumulo/test/functional/ScanIdIT.java | 101 +-
.../accumulo/test/functional/ScanIteratorIT.java | 87 +-
.../accumulo/test/functional/ScanRangeIT.java | 35 +-
.../test/functional/ScanSessionTimeOutIT.java | 57 +-
.../accumulo/test/functional/ScannerContextIT.java | 12 +-
.../apache/accumulo/test/functional/ScannerIT.java | 111 +-
.../test/functional/ServerSideErrorIT.java | 113 +-
.../test/functional/SessionBlockVerifyIT.java | 149 +-
.../test/functional/SessionDurabilityIT.java | 123 +-
.../accumulo/test/functional/ShutdownIT.java | 45 +-
.../test/functional/SimpleBalancerFairnessIT.java | 106 +-
.../test/functional/SparseColumnFamilyIT.java | 63 +-
.../apache/accumulo/test/functional/SplitIT.java | 232 +--
.../org/apache/accumulo/test/functional/SslIT.java | 29 +-
.../apache/accumulo/test/functional/SummaryIT.java | 843 ++++-----
.../test/functional/TableChangeStateIT.java | 6 +
.../apache/accumulo/test/functional/TableIT.java | 63 +-
.../apache/accumulo/test/functional/TabletIT.java | 14 +-
.../functional/TabletStateChangeIteratorIT.java | 165 +-
.../apache/accumulo/test/functional/TimeoutIT.java | 16 +-
.../accumulo/test/functional/TooManyDeletesIT.java | 123 +-
.../accumulo/test/functional/VisibilityIT.java | 55 +-
.../accumulo/test/functional/WALSunnyDayIT.java | 109 +-
.../test/functional/WatchTheWatchCountIT.java | 55 +-
.../test/functional/WriteAheadLogEncryptedIT.java | 31 +-
.../accumulo/test/functional/WriteAheadLogIT.java | 31 +-
.../accumulo/test/functional/WriteLotsIT.java | 75 +-
.../accumulo/test/functional/ZooCacheIT.java | 7 +-
.../test/functional/ZookeeperRestartIT.java | 45 +-
.../test/mapred/AccumuloFileOutputFormatIT.java | 54 +-
.../test/mapred/AccumuloInputFormatIT.java | 114 +-
.../mapred/AccumuloMultiTableInputFormatIT.java | 37 +-
.../test/mapred/AccumuloOutputFormatIT.java | 122 +-
.../test/mapred/AccumuloRowInputFormatIT.java | 31 +-
.../apache/accumulo/test/mapred/TokenFileIT.java | 45 +-
.../test/mapreduce/AccumuloFileOutputFormatIT.java | 33 +-
.../test/mapreduce/AccumuloInputFormatIT.java | 381 ++--
.../mapreduce/AccumuloMultiTableInputFormatIT.java | 37 +-
.../test/mapreduce/AccumuloOutputFormatIT.java | 37 +-
.../test/mapreduce/AccumuloRowInputFormatIT.java | 31 +-
.../accumulo/test/mapreduce/TokenFileIT.java | 45 +-
.../apache/accumulo/test/master/MergeStateIT.java | 190 +-
.../test/performance/RollWALPerformanceIT.java | 36 +-
.../accumulo/test/proxy/ProxyDurabilityIT.java | 107 +-
.../accumulo/test/proxy/SimpleProxyBase.java | 103 +-
.../test/replication/KerberosReplicationIT.java | 155 +-
.../replication/MultiInstanceReplicationIT.java | 195 +-
.../accumulo/test/replication/ReplicationIT.java | 1964 ++++++++++----------
.../test/replication/StatusCombinerMacIT.java | 103 +-
.../UnorderedWorkAssignerReplicationIT.java | 197 +-
197 files changed, 12428 insertions(+), 10989 deletions(-)
create mode 100644 core/src/main/java/org/apache/accumulo/core/singletons/SingletonManager.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/singletons/SingletonReservation.java
copy core/src/main/java/org/apache/accumulo/core/{spi/common/IteratorConfiguration.java => singletons/SingletonService.java} (72%)
create mode 100644 core/src/test/java/org/apache/accumulo/core/singletons/SingletonManagerTest.java