[
https://issues.apache.org/jira/browse/DL-4?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15800643#comment-15800643
]
Hudson commented on DL-4:
-------------------------
UNSTABLE: Integrated in Jenkins build distributedlog-nightly-build #179 (See
[https://builds.apache.org/job/distributedlog-nightly-build/179/])
DL-4: Add repackaging script (sijieg: rev
7fab246d96a20c6ae3f7086e2890a42eb7eaf6fb)
* (add) scripts/dev/repackage.sh
* (edit)
distributedlog-build-tools/src/main/resources/distributedlog/checkstyle.xml
DL-4: Repackage the source under apache namespace (sijieg: rev
b44820b50eea9ef2447ec7e136e182ba39e2c269)
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/util/MonitoredFuturePool.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/injector/RandomDelayFailureInjector.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/ZooKeeperClientBuilder.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/service/package-info.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/EntryBuffer.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/stream/StreamFactoryImpl.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/ReadCancelledException.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/BKLogReadHandler.java
* (edit) distributedlog-core/pom.xml
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/io/AsyncCloseable.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/BKLogWriteHandler.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/injector/package-info.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/stats/ClientStats.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/LedgerReadPosition.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/BKDistributedLogNamespace.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/ZKLogMetadataStore.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/WriteCancelledException.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/stream/TruncateOp.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/logsegment/BKLogSegmentAllocator.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/placement/PlacementStateManager.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/IdleReaderException.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestEntry.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/resolver/RegionResolver.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/net/TestDNSResolver.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/util/SafeQueueingFuturePool.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/speculative/DefaultSpeculativeRequestExecutionPolicy.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/LocalDLMEmulator.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/impl/logsegment/BKUtils.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/util/DLUtils.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/logsegment/BKLogSegmentEntryWriter.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/BKDistributedLogManager.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/namespace/package-info.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/util/PermitLimiter.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/util/PermitManager.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/io/Abortable.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/subscription/SubscriptionsStore.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/config/TestConcurrentBaseConfiguration.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/impl/metadata/ZkMetadataResolver.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/io/CompressionUtils.java
* (add)
distributedlog-service/src/main/java/org/apache/distributedlog/service/ClientUtils.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/logsegment/RollingPolicy.java
* (delete)
distributedlog-benchmark/src/main/java/com/twitter/distributedlog/benchmark/stream/package-info.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/RecordStream.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/util/TestUtils.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/subscription/SubscriptionStateStore.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/streamset/Partition.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/metadata/MetadataResolver.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/metadata/LogSegmentMetadataStoreUpdater.java
* (add)
distributedlog-benchmark/src/main/java/org/apache/distributedlog/benchmark/stream/LedgerStreamReader.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/serverset/package-info.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/routing/RoutingServiceProvider.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestBKDistributedLogManager.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/io/Buffer.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/zk/ZKOp.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/stats/ClientStatsLogger.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/BKAbstractLogWriter.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/EndOfStreamException.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/routing/ConsistentHashRoutingService.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/lock/ZKSessionLock.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/annotations/package-info.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/net/NetUtils.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/BKAbstractLogWriter.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/stream/ReleaseOp.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/UnsupportedMetadataVersionException.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/impl/metadata/ZKLogStreamMetadataStore.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/RequestDeniedException.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/impl/metadata/TestZKLogStreamMetadataStoreUtils.java
* (delete)
distributedlog-protocol/src/test/java/com/twitter/distributedlog/TestTimedOutTestsListener.java
* (delete)
distributedlog-client/src/test/java/com/twitter/distributedlog/client/routing/TestRegionsRoutingService.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/util/TestUtils.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/feature/DefaultFeatureProvider.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/feature/DynamicConfigurationFeatureProvider.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/injector/AsyncFailureInjector.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/announcer/ServerSetAnnouncer.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/util/Transaction.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/acl/TestZKAccessControlManager.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentRandomAccessEntryReader.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentEntryWriter.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestEntryPosition.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/injector/package-info.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/selector/LastRecordSelector.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/BKAsyncLogReader.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/function/DefaultValueMapFunction.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestNonBlockingReadsMultiReader.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/impl/TestZKLogSegmentFilters.java
* (delete)
distributedlog-benchmark/src/main/java/com/twitter/distributedlog/benchmark/Worker.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/service/DLSocketAddress.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/routing/TestName.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/proxy/HostProvider.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/stream/HeartbeatOp.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/stream/WriteOp.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/util/FutureUtils.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/DLException.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/EnvelopedRecordSetWriter.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/impl/BKNamespaceDriver.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/feature/DynamicConfigurationFeatureProvider.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/routing/RoutingUtils.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/tools/ProxyTool.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/metadata/DLConfig.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestNonBlockingReadsMultiReader.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestWriteLimiter.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/InvalidStreamNameException.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/lock/DistributedLock.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/ServiceUnavailableException.java
* (delete)
distributedlog-client/src/test/java/com/twitter/distributedlog/client/proxy/MockThriftClient.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/streamset/StreamPartitionConverter.java
* (add)
distributedlog-benchmark/src/main/java/org/apache/distributedlog/benchmark/stream/package-info.java
* (add)
distributedlog-client/src/test/java/org/apache/distributedlog/client/routing/TestRegionsRoutingService.java
* (edit) distributedlog-service/bin/dlog-start.sh
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentFilter.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/logsegment/LogSegmentWriter.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/lock/ZKDistributedLock.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/namespace/TestDistributedLogNamespaceBuilder.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/annotations/package-info.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/proxy/package-info.java
* (add)
distributedlog-client/src/test/java/org/apache/distributedlog/client/speculative/TestDefaultSpeculativeRequestExecutionPolicy.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/BookKeeperClient.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/stats/BKExceptionStatsLogger.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestBKLogReadHandler.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/InvalidStreamNameException.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/bk/TestLedgerAllocator.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/callback/LogSegmentNamesListener.java
* (delete)
distributedlog-client/src/test/java/com/twitter/distributedlog/client/proxy/MockDistributedLogServices.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/BKSyncLogReader.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestRollLogSegments.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/config/PropertiesConfigurationBuilder.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/MetadataAccessor.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/ownership/OwnershipCache.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/balancer/ClusterBalancer.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/DLIllegalStateException.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/proxy/ProxyListener.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/BKTransmitException.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/DLInterruptedException.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/callback/ReadAheadCallback.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/metadata/LogSegmentMetadataStoreUpdater.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/RequestDeniedException.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/zk/ZKTransaction.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/rate/SampledMovingAverageRate.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/acl/package-info.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/bk/TestLedgerAllocatorPool.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/net/TestDNSResolver.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/LogNotFoundException.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/lock/ZKSessionLockFactory.java
* (edit) distributedlog-service/bin/dlog-daemon.sh
* (add)
distributedlog-client/src/test/java/org/apache/distributedlog/client/routing/TestConsistentHashRoutingService.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/bk/TestLedgerAllocatorPool.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/function/GetVersionedValueFunction.java
* (add) distributedlog-core/src/main/java/org/apache/distributedlog/zk/ZKOp.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestBKLogSegmentWriter.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestBKDistributedLogManager.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/EndOfStreamException.java
* (delete)
distributedlog-client/src/test/java/com/twitter/distributedlog/client/routing/TestConsistentHashRoutingService.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/streamset/package-info.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/acl/package-info.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/LockingException.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/limiter/ChainedRequestLimiter.java
* (delete)
distributedlog-benchmark/src/main/java/com/twitter/distributedlog/benchmark/stream/StreamBenchmark.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/tools/TestDistributedLogTool.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/IdleReaderException.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/io/package-info.java
* (add)
distributedlog-client/src/test/java/org/apache/distributedlog/client/proxy/MockProxyClientBuilder.java
* (add)
distributedlog-benchmark/src/main/java/org/apache/distributedlog/benchmark/stream/AsyncReaderBenchmark.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/LogWriter.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/admin/DistributedLogAdmin.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/bk/DynamicQuorumConfigProvider.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/BKLogSegmentWriter.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/package-info.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestBKLogReadHandler.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/routing/SingleHostRoutingService.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/logsegment/BKLogSegmentRandomAccessEntryReader.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/LogExistsException.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/net/DNSResolverForRows.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/metadata/LogMetadataForReader.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/bk/LedgerAllocator.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/injector/RandomDelayFailureInjector.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/readahead/package-info.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/LogRecord.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/util/TestPermitManager.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/callback/package-info.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/config/ConfigurationListener.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/util/ConfUtils.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/routing/RegionsRoutingService.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/config/ConcurrentConstConfiguration.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/impl/logsegment/TestBKLogSegmentEntryReader.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestAppendOnlyStreamWriter.java
* (delete)
distributedlog-client/src/test/java/com/twitter/distributedlog/client/TestDistributedLogMultiStreamWriter.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/bk/LedgerAllocatorDelegator.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/namespace/DistributedLogNamespace.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/balancer/SimpleBalancer.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/stream/limiter/ServiceRequestLimiter.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/DistributedLogConstants.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/impl/acl/ZKAccessControlManager.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestReadAheadEntryReader.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestRollLogSegments.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/stream/Stream.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/ownership/package-info.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/BKLogWriteHandler.java
* (add) distributedlog-core/src/main/java/org/apache/distributedlog/MaxTxId.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/callback/NamespaceListener.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/balancer/Balancer.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/stream/StreamManagerImpl.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/DLIllegalStateException.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/routing/SingleHostRoutingService.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/logsegment/TimeBasedRollingPolicy.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestAsyncReaderLock.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/selector/LogRecordSelector.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/balancer/BalancerUtils.java
* (edit) distributedlog-protocol/src/main/resources/findbugsExclude.xml
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/limiter/RateLimiter.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/util/TestDLUtils.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/config/NullStreamConfigProvider.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/callback/LogSegmentNamesListener.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/acl/TestZKAccessControl.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/placement/StreamLoad.java
* (add)
distributedlog-benchmark/src/main/java/org/apache/distributedlog/benchmark/Utils.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/WriteLimiter.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestAsyncBulkWrite.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/LogSegmentNotFoundException.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/lock/package-info.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/feature/TestDynamicConfigurationFeatureProvider.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/proxy/ClusterClient.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/util/SimplePermitLimiter.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/NotYetImplementedException.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/io/AsyncAbortable.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/config/TestDynamicConfigurationFactory.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/lock/LockTimeoutException.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/MonitorService.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/ZooKeeperClusterTestCase.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/lock/TestZKSessionLock.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/resolver/RegionResolver.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/io/IdentityCompressionCodec.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/util/Sizable.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/metadata/ZKLogStreamMetadataStore.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/logsegment/SizeBasedRollingPolicy.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/routing/ServerSetRoutingService.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/util/FailpointUtils.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/acl/AccessControlManager.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/AsyncLogReader.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/stats/BroadCastStatsLogger.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/annotations/DistributedLogAnnotations.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/speculative/package-info.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/service/DistributedLogClient.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestReader.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/lock/ZKSessionLockFactory.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/lock/TestZKSessionLock.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/logsegment/TestRollingPolicy.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/admin/package-info.java
* (edit) distributedlog-core/src/main/thrift/metadata.thrift
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/util/TimeSequencer.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/BKLogHandler.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/bk/LedgerAllocator.java
* (edit) distributedlog-core/conf/log4j.properties
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/limiter/RequestLimiter.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/package-info.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/util/TestPermitManager.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/injector/AsyncRandomFailureInjector.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/ZKMetadataAccessor.java
* (edit) distributedlog-core/src/main/resources/findbugsExclude.xml
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/util/RetryPolicyUtils.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/placement/LeastLoadPlacementPolicy.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/bk/QuorumConfig.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/tools/package-info.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/config/PropertiesWriter.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/namespace/NamespaceDriverManager.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/ReadAheadEntryReader.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/io/AsyncAbortable.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/placement/ZKPlacementStateManager.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/ReadUtils.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/zk/DefaultZKOp.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/namespace/DistributedLogNamespaceBuilder.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/service/DistributedLogClientBuilder.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/NonBlockingReadsTestUtil.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/DistributedLogClientImpl.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/util/CommandLineUtils.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/impl/acl/ZKAccessControl.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/routing/TwitterServerSetWatcher.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/MaxLogSegmentSequenceNo.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/bk/QuorumConfigProvider.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/util/Transaction.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/lock/TestDistributedLock.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/metadata/LogMetadataForReader.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/placement/package-info.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/impl/ZKNamespaceWatcher.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/function/VoidFunctions.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/streamset/CacheableStreamPartitionConverter.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/io/IdentityCompressionCodec.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/exceptions/ZKException.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/logsegment/LogSegmentEntryReader.java
* (add)
distributedlog-protocol/src/test/java/org/apache/distributedlog/TimedOutTestsListener.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/LogRecordWithDLSN.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/stream/BulkWriteOp.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/service/DistributedLogClient.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/lock/LockAction.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestAsyncReaderWriter.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/injector/FailureInjector.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/function/CloseAsyncCloseableFunction.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/stream/StreamManager.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/metadata/MetadataUpdater.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/routing/ServerSetWatcher.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/metadata/DryrunLogSegmentMetadataStoreUpdater.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/util/MonitoredFuturePool.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/zk/TestZKTransaction.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/impl/TestZKLogSegmentMetadataStore.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/subscription/SubscriptionsStore.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/bk/QuorumConfigProvider.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/metadata/DLConfig.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/util/OrderedScheduler.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/InternalServerException.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/net/DNSResolver.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/stream/StreamImpl.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/stats/OpStats.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/lock/LockTimeoutException.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestZooKeeperClient.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestZooKeeperClient.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/config/StreamConfigProvider.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/monitor/package-info.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/logsegment/TestPerStreamLogSegmentCache.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/resolver/package-info.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/service/package-info.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/util/SchedulerUtils.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/tools/DistributedLogTool.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/annotations/DistributedLogAnnotations.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/resolver/DefaultRegionResolver.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/monitor/MonitorServiceClient.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/MetadataException.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/LogWriter.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/zk/TestZKWatcherManager.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/io/Abortables.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/util/package-info.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestZooKeeperClientBuilder.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/LogEmptyException.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/config/FileConfigurationBuilder.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/metadata/package-info.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/net/TestNetUtils.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/selector/TestLogRecordSelectors.java
* (add)
distributedlog-benchmark/src/main/java/org/apache/distributedlog/benchmark/utils/ShiftableRateLimiter.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentWriter.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/RegionUnavailableException.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/feature/package-info.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/DLClientClosedException.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/io/CompressionCodec.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/metadata/LogStreamMetadataStore.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/AlreadyClosedException.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/TooManyStreamsException.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/StatsFilter.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/util/TestSafeQueueingFuturePool.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/utils/ServerUtils.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/LogSegmentMetadata.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/LogSegmentIsTruncatedException.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/feature/TestDynamicConfigurationFeatureProvider.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/logsegment/LogSegmentMetadataStore.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/DLException.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/DistributedLogManager.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/config/PropertiesWriter.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentEntryReader.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/SizeBasedRollingPolicy.java
* (edit) distributedlog-benchmark/src/main/thrift/loadtest.thrift
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/metadata/package-info.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/proxy/HostProvider.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/util/Sizable.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/routing/TwitterServerSetWatcher.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/speculative/SpeculativeRequestExecutionPolicy.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/ZooKeeperClientBuilder.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/logsegment/LogSegmentEntryWriter.java
* (delete)
distributedlog-benchmark/src/main/java/com/twitter/distributedlog/benchmark/utils/ShiftableRateLimiter.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/limiter/ChainedRequestLimiter.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/announcer/Announcer.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/metadata/LogMetadataForWriter.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestAsyncBulkWrite.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/monitor/MonitorServiceClient.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/AlreadyTruncatedTransactionException.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/AsyncLogWriter.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestDLMTestUtil.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/limiter/RateLimiter.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/streamset/PartitionMap.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/lock/LockSessionExpiredException.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/stream/StreamOpStats.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/logsegment/BKLogSegmentEntryReader.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/config/ConfigurationSubscription.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/announcer/NOPAnnouncer.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/impl/TestZKNamespaceWatcher.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/net/NetUtils.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/admin/TestDLCK.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestInterleavedReaders.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/impl/logsegment/BKLogSegmentEntryWriter.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/InvalidEnvelopedEntryException.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/routing/RoutingService.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/stats/OwnershipStatsLogger.java
* (delete)
distributedlog-benchmark/src/main/java/com/twitter/distributedlog/benchmark/stream/ReadMode.java
* (edit) distributedlog-core/conf/zookeeper.conf.dynamic.template
* (add)
distributedlog-benchmark/src/main/java/org/apache/distributedlog/benchmark/utils/package-info.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/auditor/DLAuditor.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/impl/logsegment/BKLogSegmentEntryStore.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/metadata/LogMetadataStore.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/config/DynamicDistributedLogConfiguration.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/util/ProtocolUtils.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/ReadCancelledException.java
* (add)
distributedlog-benchmark/src/main/java/org/apache/distributedlog/benchmark/package-info.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/feature/TestConfigurationFeatureProvider.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/selector/FirstTxIdNotLessThanSelector.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/util/RetryPolicyUtils.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestReadAheadEntryReader.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/limiter/GuavaRateLimiter.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/callback/NamespaceListener.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/metadata/TestDLMetadata.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/metadata/LogMetadata.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/LogReadException.java
* (delete)
distributedlog-protocol/src/test/java/com/twitter/distributedlog/TestDLSN.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/impl/ZKLogMetadataStore.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/zk/TestZKVersionedSetOp.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/bk/DynamicQuorumConfigProvider.java
* (add)
distributedlog-service/src/main/java/org/apache/distributedlog/service/DistributedLogServer.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/io/AsyncDeleteable.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/util/Sequencer.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/feature/ConfigurationFeatureProvider.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/BKSyncLogWriter.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/lock/LockWaiter.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/util/TestConfUtils.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/PerStreamLogSegmentCache.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/util/Allocator.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestAppendOnlyStreamWriter.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/config/package-info.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/config/DynamicConfigurationFactory.java
* (add)
distributedlog-client/src/test/java/org/apache/distributedlog/service/TestDistributedLogClientBuilder.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/RetryableReadException.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/bk/LedgerAllocatorDelegator.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/AlreadyClosedException.java
* (add) distributedlog-core/src/main/java/org/apache/distributedlog/Entry.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/LogSegmentIsTruncatedException.java
* (delete)
distributedlog-benchmark/src/main/java/com/twitter/distributedlog/benchmark/stream/AbstractReaderBenchmark.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/stream/limiter/package-info.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/EnvelopedEntryReader.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/serverset/DLZkServerSet.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/lock/NopDistributedLock.java
* (edit)
distributedlog-service/src/main/java/org/apache/bookkeeper/stats/package-info.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/impl/metadata/TestZkMetadataResolver.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/limiter/ComposableRequestLimiter.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/impl/federated/TestFederatedZKLogMetadataStore.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/EndOfLogSegmentException.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/logsegment/LogSegmentMetadataCache.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/zk/ZKVersionedSetOp.java
* (add)
distributedlog-benchmark/src/main/java/org/apache/distributedlog/benchmark/Benchmarker.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/lock/NopDistributedLock.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/placement/PlacementPolicy.java
* (add)
distributedlog-benchmark/src/main/java/org/apache/distributedlog/benchmark/WriterWorker.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/feature/ConfigurationFeatureProvider.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/rate/TestMovingAverageRate.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/proxy/ProxyListener.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/impl/ZKMetadataAccessor.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/AlreadyTruncatedTransactionException.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/config/DefaultStreamConfigProvider.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/impl/logsegment/TestBKLogSegmentEntryReader.java
* (add)
distributedlog-benchmark/src/main/java/org/apache/distributedlog/benchmark/stream/AbstractReaderBenchmark.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/acl/AccessControlManager.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/selector/FirstTxIdNotLessThanSelector.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/package-info.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/selector/LastRecordSelector.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/ZooKeeperClientUtils.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/proxy/ClusterClient.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/io/AsyncCloseable.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/zk/ZKTransaction.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/selector/FirstDLSNNotLessThanSelector.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestTruncate.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/net/DNSResolverForRacks.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/util/TestSafeQueueingFuturePool.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestAsyncReaderWriter.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestBKLogWriteHandler.java
* (delete)
distributedlog-benchmark/src/main/java/com/twitter/distributedlog/benchmark/WriterWorker.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/ClientConfig.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/lock/LockListener.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/impl/federated/TestFederatedZKLogMetadataStore.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestBKLogSegmentWriter.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/stats/OpStatsListener.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/ZooKeeperClientUtils.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/InvalidEnvelopedEntryException.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/metadata/MetadataResolver.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/net/package-info.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/ChecksumFailedException.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/DLSN.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/EnvelopedEntryWriter.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/lock/LockClosedException.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/metadata/ZkMetadataResolver.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/bk/ImmutableQuorumConfigProvider.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/limiter/TestRequestLimiter.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/admin/TestDLCK.java
* (edit) distributedlog-client/src/main/resources/findbugsExclude.xml
* (add)
distributedlog-benchmark/src/main/java/org/apache/distributedlog/benchmark/stream/LedgerReadBenchmark.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/rate/TestMovingAverageRate.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/AsyncNotification.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/feature/CoreFeatureKeys.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentMetadataStore.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/util/Sequencer.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/util/package-info.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/stats/OwnershipStatsLogger.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/DLClientClosedException.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/package-info.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/stats/OpStats.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/ZKNamespaceWatcher.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/LogEmptyException.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/tools/package-info.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/LockCancelledException.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/stream/StreamOp.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/stream/AbstractStreamOp.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/rate/MovingAverageRate.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/bk/ImmutableQuorumConfigProvider.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/function/package-info.java
* (add)
distributedlog-benchmark/src/main/java/org/apache/distributedlog/benchmark/stream/SyncReaderBenchmark.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/util/BitMaskUtils.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/subscription/SubscriptionStateStore.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/callback/LogSegmentListener.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/metadata/DLMetadata.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestEnvelopedEntry.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestWriteLimiter.java
* (delete)
distributedlog-client/src/test/java/com/twitter/distributedlog/client/routing/TestInetNameResolution.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/package-info.java
* (delete)
distributedlog-benchmark/src/main/java/com/twitter/distributedlog/benchmark/stream/LedgerReadBenchmark.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/logsegment/LogSegmentRandomAccessEntryReader.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/stream/admin/StreamAdminOp.java
* (add)
distributedlog-protocol/src/test/java/org/apache/distributedlog/TestTimedOutTestsListener.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/bk/QuorumConfig.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/util/OrderedScheduler.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/EnvelopedRecordSetReader.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/config/ConcurrentBaseConfiguration.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/util/FailpointUtils.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/LogRecordSetBuffer.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/io/Buffer.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/AppendOnlyStreamReader.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/metadata/DLMetadata.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/config/FileConfigurationBuilder.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/impl/metadata/TestZKLogStreamMetadataStore.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/AppendOnlyStreamReader.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/exceptions/ZKException.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/acl/ZKAccessControl.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/tools/TestDistributedLogTool.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/lock/DistributedLockContext.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/limiter/package-info.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/metadata/LogMetadataForWriter.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/metadata/BKDLConfig.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/EntryPosition.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/OwnershipAcquireFailedException.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/config/PropertiesConfigurationBuilder.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/feature/TestConfigurationFeatureProvider.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/balancer/BalancerTool.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/util/Allocator.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/impl/TestZKLogSegmentFilters.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/impl/federated/FederatedZKLogMetadataStore.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/config/TestDynamicConfigurationFactory.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/StreamNotReadyException.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/tools/Tool.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/DistributedLogServerApp.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/routing/RoutingServiceProvider.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/impl/TestZKLogSegmentMetadataStore.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/announcer/package-info.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/net/DNSResolverForRows.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/util/BitMaskUtils.java
* (delete)
distributedlog-benchmark/src/main/java/com/twitter/distributedlog/benchmark/stream/LedgerBatchReader.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/acl/ZKAccessControlManager.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/logsegment/BKUtils.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/placement/LoadAppraiser.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/Entry.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/StreamUnavailableException.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/metadata/LogStreamMetadataStore.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/limiter/GuavaRateLimiter.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/zk/TestZKTransaction.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/config/package-info.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestReader.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/DistributedLogServer.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/limiter/RequestLimiter.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/namespace/NamespaceDriverManager.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/balancer/StreamChooser.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/config/TestDynamicDistributedLogConfiguration.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/ZooKeeperClient.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestLogSegmentCreation.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/lock/SessionLock.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestEnvelopedEntry.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/ZKLogSegmentMetadataStore.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/EnvelopedEntryReader.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/lock/SessionLockFactory.java
* (delete)
distributedlog-protocol/src/test/java/com/twitter/distributedlog/TimedOutTestsListener.java
* (delete)
distributedlog-benchmark/src/main/java/com/twitter/distributedlog/benchmark/Utils.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/namespace/DistributedLogNamespace.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/feature/AbstractFeatureProvider.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/routing/TestName.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/stream/AbstractWriteOp.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/impl/metadata/TestZKLogStreamMetadataStore.java
* (delete)
distributedlog-benchmark/src/main/java/com/twitter/distributedlog/benchmark/stream/SyncReaderBenchmark.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/namespace/NamespaceWatcher.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/config/ConcurrentBaseConfiguration.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/UnexpectedException.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/lock/LockStateChangedException.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/namespace/NamespaceDriver.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/util/CommandLineUtils.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/BKAsyncLogReader.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/LogExistsException.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/DistributedLogClientImpl.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/feature/CoreFeatureKeys.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/util/TestFutureUtils.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestSequenceID.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/metadata/TestLogMetadata.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/feature/DefaultFeatureProvider.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/BKSyncLogWriter.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/ChecksumFailedException.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/function/GetVersionedValueFunction.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/readahead/package-info.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/stream/WriteOpWithPayload.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/namespace/TestDistributedLogNamespaceBuilder.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/util/TestTimeSequencer.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/routing/RoutingUtils.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/package-info.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/stats/BKExceptionStatsLogger.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/limiter/TestRequestLimiter.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/impl/ZKLogSegmentFilters.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/TransactionIdOutOfOrderException.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/speculative/SpeculativeRequestExecutor.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestTruncate.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/OverCapacityException.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/TransactionIdOutOfOrderException.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/ReadUtils.java
* (delete)
distributedlog-benchmark/src/main/java/com/twitter/distributedlog/benchmark/stream/AsyncReaderBenchmark.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/auditor/DLAuditor.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/net/DNSResolverForRacks.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/MonitorServiceApp.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/EnvelopedEntryWriter.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/io/package-info.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/routing/package-info.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/stats/ClientStats.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/function/VoidFunctions.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/callback/ReadAheadCallback.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/logsegment/LogSegmentEntryStore.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestNonBlockingReads.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/speculative/package-info.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestLogSegmentCreation.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/injector/FailureInjector.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/config/ConcurrentConstConfiguration.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestDistributedLogConfiguration.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/util/TestConfUtils.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/OverCapacityException.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/zk/ZKWatcherManager.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/LogRecordTooLongException.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/io/package-info.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/stats/package-info.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/lock/DistributedLockContext.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/utils/package-info.java
* (delete)
distributedlog-benchmark/src/main/java/com/twitter/distributedlog/benchmark/Benchmarker.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/impl/TestZKLogMetadataStore.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/package-info.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/util/DLUtils.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/bk/package-info.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/config/TestDynamicDistributedLogConfiguration.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/EnvelopedEntry.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/io/TransmitListener.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/LedgerReadPosition.java
* (add)
distributedlog-protocol/src/test/java/org/apache/distributedlog/TestDLSN.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/util/TimeSequencer.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/zk/TestZKVersionedSetOp.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/BKLogReadHandler.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/tools/Tool.java
* (delete)
distributedlog-client/src/test/java/com/twitter/distributedlog/client/routing/TestRoutingService.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/selector/FirstDLSNNotLessThanSelector.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/WriteCancelledException.java
* (add)
distributedlog-benchmark/src/main/java/org/apache/distributedlog/benchmark/Worker.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/metadata/TestLogSegmentMetadataStoreUpdater.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/speculative/DefaultSpeculativeRequestExecutionPolicy.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/speculative/SpeculativeRequestExecutionPolicy.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/config/package-info.java
* (add)
distributedlog-client/src/test/java/org/apache/distributedlog/client/routing/TestInetNameResolution.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/routing/ServerSetWatcher.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/net/TestNetUtils.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/util/MonitoredScheduledThreadPoolExecutor.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestDistributedLogConfiguration.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentMetadataCache.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/UnexpectedException.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/DistributedLogMultiStreamWriter.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestReadUtils.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/ZooKeeperClient.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/bk/TestLedgerAllocator.java
* (edit) distributedlog-benchmark/src/main/resources/findbugsExclude.xml
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/BKLogSegmentWriter.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/subscription/ZKSubscriptionsStore.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/stats/OpStatsListener.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/impl/TestZKLogMetadataStore.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/io/package-info.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/bk/LedgerAllocatorPool.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/selector/LogRecordSelector.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/limiter/package-info.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/BKTransmitException.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/resolver/DefaultRegionResolver.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/ResponseUtils.java
* (edit) distributedlog-client/pom.xml
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/metadata/TestLogMetadata.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/service/DistributedLogClientBuilder.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/proxy/package-info.java
* (add)
distributedlog-benchmark/src/main/java/org/apache/distributedlog/benchmark/stream/ReadMode.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/metadata/LogMetadata.java
* (add)
distributedlog-client/src/test/java/org/apache/distributedlog/client/proxy/TestProxyClientManager.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/function/package-info.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/lock/TestDistributedLock.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/util/TestDLUtils.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/lock/EpochChangedException.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/DistributedLogMultiStreamWriter.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/DLSN.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/config/ServerConfiguration.java
* (delete)
distributedlog-client/src/test/java/com/twitter/distributedlog/client/proxy/MockProxyClientBuilder.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/ZKLogSegmentFilters.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/AppendOnlyStreamWriter.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/impl/subscription/ZKSubscriptionStateStore.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/MetadataException.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestBKSyncLogReader.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestAppendOnlyStreamReader.java
* (add)
distributedlog-service/src/main/java/org/apache/distributedlog/service/DistributedLogCluster.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/limiter/ComposableRequestLimiter.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestDistributedLogBase.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/stats/BroadCastStatsLogger.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/util/PermitManager.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/io/LZ4CompressionCodec.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/ClientConfig.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestLogSegmentsZK.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/config/TestConfigurationSubscription.java
* (edit) distributedlog-benchmark/conf/log4j.properties
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/EnvelopedRecordSetWriter.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/placement/EqualLoadAppraiser.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/injector/AsyncRandomFailureInjector.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/lock/SessionLock.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/package-info.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/placement/ServerLoad.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/zk/ZKWatcherManager.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/bk/LedgerAllocatorUtils.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/lock/package-info.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/feature/package-info.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/stream/limiter/DynamicRequestLimiter.java
* (add)
distributedlog-client/src/test/java/org/apache/distributedlog/client/proxy/MockThriftClient.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/DLMTestUtil.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/BKLogHandler.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/metadata/MetadataUpdater.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/BKSyncLogReader.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestLogSegmentsZK.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/InternalServerException.java
* (delete)
distributedlog-client/src/test/java/com/twitter/distributedlog/client/speculative/TestDefaultSpeculativeRequestExecutionPolicy.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/config/ConfigurationListener.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/admin/TestDistributedLogAdmin.java
* (add)
distributedlog-benchmark/src/main/java/org/apache/distributedlog/benchmark/stream/StreamBenchmark.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/stream/limiter/StreamAcquireLimiter.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/bk/LedgerAllocatorPool.java
* (add)
distributedlog-service/src/main/java/org/apache/distributedlog/service/DistributedLogServiceImpl.java
* (add)
distributedlog-service/src/main/java/org/apache/distributedlog/service/DistributedLogServerApp.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/impl/package-info.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/util/ConfUtils.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/bk/SimpleLedgerAllocator.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/LogNotFoundException.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/LogRecordSetBuffer.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/selector/FirstRecordSelector.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/config/DynamicDistributedLogConfiguration.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/ownership/OwnershipCache.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/util/SimplePermitLimiter.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/EntryBuffer.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/resolver/package-info.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestLogSegmentMetadata.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/lock/LockSessionExpiredException.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/namespace/NamespaceWatcher.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/namespace/package-info.java
* (add)
distributedlog-benchmark/src/main/java/org/apache/distributedlog/benchmark/ReaderWorker.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/MaxTxId.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/routing/ServerSetRoutingService.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/lock/ZKDistributedLock.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/DLMTestUtil.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/namespace/DistributedLogNamespaceBuilder.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/BKAsyncLogWriter.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/WriteException.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestBKLogWriteHandler.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/stats/package-info.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/net/package-info.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/lock/LockWaiter.java
* (edit) distributedlog-service/pom.xml
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/package-info.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/proxy/ProxyClient.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/util/TestFutureUtils.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/stream/limiter/StreamRequestLimiter.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/WriteLimiter.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/bk/SimpleLedgerAllocator.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/rate/MovingAverageRateFactory.java
* (add)
distributedlog-client/src/test/java/org/apache/distributedlog/client/ownership/TestOwnershipCache.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/DistributedLogCluster.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/LogReader.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/ReadAheadEntryReader.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/RetryableReadException.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/UnsupportedMetadataVersionException.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/config/ConfigurationSubscription.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/OwnershipAcquireFailedException.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/RegionUnavailableException.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/util/Utils.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/util/ProtocolUtils.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/ownership/package-info.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestBKDistributedLogNamespace.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestEntry.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestAsyncReaderLock.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/function/DefaultValueMapFunction.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/io/Abortable.java
* (delete)
distributedlog-benchmark/src/main/java/com/twitter/distributedlog/benchmark/package-info.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/service/DLSocketAddress.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/logsegment/package-info.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/lock/SessionLockFactory.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestSequenceID.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/zk/ZKVersionedSetOp.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/impl/logsegment/BKLogSegmentRandomAccessEntryReader.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/LogRecordTooLongException.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/DistributedLogConfiguration.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/EndOfLogSegmentException.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/injector/AsyncFailureInjector.java
* (add)
distributedlog-benchmark/src/main/java/org/apache/distributedlog/benchmark/stream/LedgerBatchReader.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/NonBlockingReadsTestUtil.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/streamset/IdentityStreamPartitionConverter.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/impl/metadata/TestZkMetadataResolver.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestDistributedLogBase.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/acl/TestZKAccessControlManager.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/rate/SampledMovingAverageRate.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/zk/TestZKWatcherManager.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/io/LZ4CompressionCodec.java
* (add)
distributedlog-protocol/src/test/java/org/apache/distributedlog/TestLogRecordSet.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/BookKeeperClientBuilder.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/lock/EpochChangedException.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/routing/package-info.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/subscription/ZKSubscriptionStateStore.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/util/TestTimeSequencer.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/balancer/CountBasedStreamChooser.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/stream/package-info.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/logsegment/LogSegmentFilter.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/StreamNotReadyException.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/NotYetImplementedException.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/stream/DeleteOp.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/BKTransmitPacket.java
* (delete)
distributedlog-benchmark/src/main/java/com/twitter/distributedlog/benchmark/utils/package-info.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/package-info.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/LogRecordWithDLSN.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/stream/StreamFactory.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/io/TransmitListener.java
* (delete)
distributedlog-client/src/test/java/com/twitter/distributedlog/service/TestDistributedLogClientBuilder.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/zk/DefaultZKOp.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/rate/MovingAverageRateFactory.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/AsyncLogReader.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/balancer/StreamMoverImpl.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/LockingException.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/config/TestConcurrentBaseConfiguration.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/metadata/DryrunLogSegmentMetadataStoreUpdater.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/util/MonitoredScheduledThreadPoolExecutor.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/stream/admin/CreateOp.java
* (delete)
distributedlog-benchmark/src/main/java/com/twitter/distributedlog/benchmark/stream/LedgerStreamReader.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/metadata/LogMetadataStore.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestAppendOnlyStreamReader.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/impl/metadata/BKDLConfig.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/lock/ZKSessionLock.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/admin/DistributedLogAdmin.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/admin/package-info.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/impl/metadata/TestZKLogStreamMetadataStoreUtils.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/ClientUtils.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/BKNamespaceDriver.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/MetadataAccessor.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/lock/LockStateChangedException.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/logsegment/TestRollingPolicy.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/routing/NameServerSet.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/DistributedLogConfiguration.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/LogSegmentNotFoundException.java
* (delete)
distributedlog-client/src/test/java/com/twitter/distributedlog/client/ownership/TestOwnershipCache.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/RecordStream.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/logsegment/PerStreamLogSegmentCache.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/util/SafeQueueingFuturePool.java
* (delete)
distributedlog-benchmark/src/main/java/com/twitter/distributedlog/benchmark/ReaderWorker.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/callback/LogSegmentListener.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/impl/TestZKNamespaceWatcher.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/routing/RegionsRoutingService.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/tools/DistributedLogTool.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/FlushException.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestInterleavedReaders.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/zk/LimitedPermitManager.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/impl/ZKLogSegmentMetadataStore.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/stream/admin/package-info.java
* (add)
distributedlog-client/src/test/java/org/apache/distributedlog/client/routing/TestRoutingService.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/impl/subscription/ZKSubscriptionsStore.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/DistributedLogConstants.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/BKAsyncLogWriter.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/function/GetLastTxIdFunction.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/util/SchedulerUtils.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/io/Abortables.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/acl/TestZKAccessControl.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/tools/package-info.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/bk/LedgerAllocatorUtils.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/feature/AbstractFeatureProvider.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/DistributedLogServiceImpl.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/EntryPosition.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/proxy/ProxyClientManager.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentEntryStore.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestDLMTestUtil.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/impl/logsegment/BKLogSegmentEntryReader.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/routing/RoutingService.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/AsyncLogWriter.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/streamset/DelimiterStreamPartitionConverter.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/routing/ConsistentHashRoutingService.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/impl/logsegment/BKLogSegmentAllocator.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/util/FutureUtils.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/selector/TestLogRecordSelectors.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/WriteException.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/TooManyStreamsException.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/federated/FederatedZKLogMetadataStore.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/StreamUnavailableException.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/BKTransmitPacket.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/monitor/package-info.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/callback/package-info.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/balancer/StreamMover.java
* (add)
distributedlog-client/src/test/java/org/apache/distributedlog/client/proxy/MockDistributedLogServices.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/config/TestConfigurationSubscription.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/selector/FirstRecordSelector.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/config/ServiceStreamConfigProvider.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/DistributedLogManager.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/EnvelopedEntry.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/LogRecordSet.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/lock/LockClosedException.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/stats/ClientStatsLogger.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/logsegment/TestPerStreamLogSegmentCache.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/EnvelopedRecordSetReader.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestBKSyncLogReader.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/FatalErrorHandler.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/stats/OpStatsLogger.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/ServiceUnavailableException.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/lock/LockAction.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/namespace/NamespaceDriver.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/stats/OpStatsLogger.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/LockCancelledException.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/AsyncNotification.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/util/package-info.java
* (add)
distributedlog-client/src/test/java/org/apache/distributedlog/client/TestDistributedLogMultiStreamWriter.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/zk/LimitedPermitManager.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/speculative/SpeculativeRequestExecutor.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/bk/package-info.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/LocalDLMEmulator.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/proxy/ProxyClientManager.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/util/Utils.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestLogSegmentMetadata.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/balancer/LimitedStreamChooser.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/BookKeeperClient.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/function/CloseAsyncCloseableFunction.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/BookKeeperClientBuilder.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/serverset/DLZkServerSet.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/lock/LockListener.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/io/AsyncDeleteable.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestEntryPosition.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/metadata/TestDLMetadata.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/RollingPolicy.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestReadUtils.java
* (edit) distributedlog-protocol/src/main/thrift/service.thrift
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/package-info.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/util/PermitLimiter.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/LogRecordSet.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/ServerFeatureKeys.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/acl/DefaultAccessControlManager.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/util/package-info.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/BKDistributedLogManager.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestZooKeeperClientBuilder.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/net/DNSResolver.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/logsegment/BKLogSegmentEntryStore.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/metadata/TestLogSegmentMetadataStoreUpdater.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/admin/TestDistributedLogAdmin.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/TestBKDistributedLogNamespace.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/TestNonBlockingReads.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/balancer/package-info.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/exceptions/LogReadException.java
* (delete)
distributedlog-core/src/test/java/com/twitter/distributedlog/ZooKeeperClusterTestCase.java
* (delete)
distributedlog-protocol/src/test/java/com/twitter/distributedlog/TestLogRecordSet.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/LogSegmentMetadata.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/LogReader.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/proxy/ProxyClient.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/function/GetLastTxIdFunction.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/BKDistributedLogNamespace.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/rate/MovingAverageRate.java
* (add)
distributedlog-benchmark/src/main/java/org/apache/distributedlog/benchmark/DLWriterWorker.java
* (delete)
distributedlog-client/src/test/java/com/twitter/distributedlog/client/proxy/TestProxyClientManager.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/MaxLogSegmentSequenceNo.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/stream/admin/AdminOp.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/TimeBasedRollingPolicy.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/io/CompressionUtils.java
* (delete)
distributedlog-benchmark/src/main/java/com/twitter/distributedlog/benchmark/DLWriterWorker.java
* (delete)
distributedlog-client/src/main/java/com/twitter/distributedlog/client/routing/NameServerSet.java
* (add)
distributedlog-client/src/main/java/org/apache/distributedlog/client/serverset/package-info.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/AppendOnlyStreamWriter.java
* (delete)
distributedlog-service/src/main/java/com/twitter/distributedlog/service/stream/limiter/RequestLimiterBuilder.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/acl/DefaultAccessControlManager.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/DLInterruptedException.java
* (delete)
distributedlog-protocol/src/main/java/com/twitter/distributedlog/io/CompressionCodec.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/lock/DistributedLock.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/LogRecord.java
* (delete)
distributedlog-core/src/main/java/com/twitter/distributedlog/config/DynamicConfigurationFactory.java
* (add)
distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/FlushException.java
> Repackage the source under apache namespace
> -------------------------------------------
>
> Key: DL-4
> URL: https://issues.apache.org/jira/browse/DL-4
> Project: DistributedLog
> Issue Type: Task
> Reporter: Sijie Guo
> Assignee: Khurrum Nasim
> Fix For: 0.4.0
>
>
> Per http://incubator.apache.org/guides/mentor.html#initial-clean-up, it is
> recommended but not mandated.
> Create a ticket for tracking the discussion.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
