accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ktur...@apache.org
Subject [accumulo] branch master updated (398c596 -> 2468f0b)
Date Tue, 30 Oct 2018 19:40:35 GMT
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


Mime
View raw message