[
https://issues.apache.org/jira/browse/DL-124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16058925#comment-16058925
]
Hudson commented on DL-124:
---------------------------
UNSTABLE: Integrated in Jenkins build distributedlog-nightly-build #343 (See
[https://builds.apache.org/job/distributedlog-nightly-build/343/])
DL-124: Use Java8 Future rather than twitter Future (sijie: rev
53fca4ac30c0d0f769940669be79c53dcaee3a23)
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/subscription/SubscriptionsStore.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/util/PermitLimiter.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/metadata/LogMetadataStore.java
* (edit)
distributedlog-proxy-server/src/main/java/org/apache/distributedlog/service/placement/PlacementPolicy.java
* (edit)
distributedlog-tutorials/distributedlog-basic/src/main/java/org/apache/distributedlog/basic/StreamRewinder.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/function/CloseAsyncCloseableFunction.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/admin/TestDistributedLogAdmin.java
* (edit)
distributedlog-benchmark/src/main/java/org/apache/distributedlog/benchmark/stream/LedgerReadBenchmark.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/config/DynamicConfigurationFactory.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/acl/ZKAccessControlManager.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/MetadataAccessor.java
* (add)
distributedlog-core-twitter/src/main/java/org/apache/distributedlog/AsyncLogReaderImpl.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/admin/DistributedLogAdmin.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/TimeBasedRollingPolicy.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/namespace/NamespaceDriver.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/util/Sequencer.java
* (edit)
distributedlog-proxy-server/src/main/java/org/apache/distributedlog/service/placement/ZKPlacementStateManager.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/util/PermitLimiter.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/io/Abortables.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/api/subscription/SubscriptionsStore.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/EnvelopedEntryWriter.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/metadata/MetadataUpdater.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/AsyncLogReader.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/api/subscription/SubscriptionStateStore.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/BKNamespaceDriver.java
* (edit)
distributedlog-proxy-server/src/main/java/org/apache/distributedlog/service/ResponseUtils.java
* (edit)
distributedlog-proxy-server/src/test/java/org/apache/distributedlog/service/stream/TestStreamOp.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/rate/MovingAverageRate.java
* (edit)
distributedlog-proxy-server/src/main/java/org/apache/distributedlog/service/DistributedLogServiceImpl.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/logsegment/BKLogSegmentAllocator.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/TestNonBlockingReadsMultiReader.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/io/Abortables.java
* (edit)
distributedlog-tutorials/distributedlog-messaging/src/main/java/org/apache/distributedlog/messaging/StreamTransformer.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/BKLogWriteHandler.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/io/AsyncCloseable.java
* (edit)
distributedlog-proxy-server/src/test/java/org/apache/distributedlog/service/stream/limiter/TestServiceRequestLimiter.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/TestBKLogReadHandler.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/api/AsyncLogReader.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/bk/TestLedgerAllocator.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/BKAsyncLogReader.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/AppendOnlyStreamReader.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/api/namespace/NamespaceBuilder.java
* (delete)
distributedlog-protocol/src/main/java/org/apache/distributedlog/annotations/package-info.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/metadata/DryrunLogSegmentMetadataStoreUpdater.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/api/LogWriter.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/util/Sequencer.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/TestBKSyncLogReader.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/api/AsyncLogWriter.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/TestAppendOnlyStreamReader.java
* (edit) distributedlog-tutorials/distributedlog-kafka/conf/log4j.properties
* (add)
distributedlog-core-twitter/src/main/java/org/apache/distributedlog/SubscriptionsStoreImpl.java
* (delete)
distributedlog-protocol/src/test/java/org/apache/distributedlog/TimedOutTestsListener.java
* (edit)
distributedlog-tutorials/distributedlog-basic/src/main/java/org/apache/distributedlog/basic/MultiReader.java
* (delete)
distributedlog-core/src/test/java/org/apache/distributedlog/config/TestConcurrentBaseConfiguration.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/rate/MovingAverageRate.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/AsyncNotification.java
* (add)
distributedlog-common/src/test/java/org/apache/distributedlog/common/config/TestConcurrentBaseConfiguration.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/stats/package-info.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/TestAppendOnlyStreamWriter.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/function/VoidFunctions.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/util/Utils.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/DLMTestUtil.java
* (add) distributedlog-common/pom.xml
* (add)
distributedlog-core-twitter/src/main/java/org/apache/distributedlog/subscription/SubscriptionsStore.java
* (edit)
distributedlog-proxy-server/src/main/java/org/apache/distributedlog/service/stream/limiter/ServiceRequestLimiter.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/BKTransmitPacket.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/LogReader.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/util/SimplePermitLimiter.java
* (edit)
distributedlog-tutorials/distributedlog-mapreduce/src/main/java/org/apache/distributedlog/mapreduce/DistributedLogInputFormat.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/TestAsyncReaderLock.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/acl/ZKAccessControl.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/BKDistributedLogManager.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/DistributedLogManager.java
* (add)
distributedlog-core-twitter/src/test/java/org/apache/distributedlog/TestAsyncLogReaderImpl.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/rate/SampledMovingAverageRate.java
* (edit) distributedlog-proxy-server/pom.xml
* (edit)
distributedlog-benchmark/src/main/java/org/apache/distributedlog/benchmark/stream/StreamBenchmark.java
* (edit)
distributedlog-proxy-server/src/main/java/org/apache/distributedlog/service/stream/StreamFactoryImpl.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/TestLogSegmentCreation.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/zk/LimitedPermitManager.java
* (edit)
distributedlog-proxy-server/src/main/java/org/apache/distributedlog/service/stream/WriteOp.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/EnvelopedEntry.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/logsegment/BKLogSegmentRandomAccessEntryReader.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/thrift/package-info.java
* (edit)
distributedlog-proxy-server/src/test/java/org/apache/distributedlog/service/TestDistributedLogServerBase.java
* (add)
distributedlog-core-twitter/src/main/java/org/apache/distributedlog/LogReaderImpl.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/TestTruncate.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/BKSyncLogWriter.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/util/Transaction.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/admin/TestDLCK.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/tools/TestDistributedLogTool.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/feature/ConfigurationFeatureProvider.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/metadata/LogSegmentMetadataStoreUpdater.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/util/PermitManager.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/AsyncLogWriter.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentEntryWriter.java
* (add)
distributedlog-core-twitter/src/main/java/org/apache/distributedlog/LogWriter.java
* (add)
distributedlog-core-twitter/src/main/java/org/apache/distributedlog/namespace/DistributedLogNamespaceBuilder.java
* (add)
distributedlog-common/src/test/java/org/apache/distributedlog/common/util/TestTimedOutTestsListener.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/BKAbstractLogWriter.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/api/DistributedLogManager.java
* (edit)
distributedlog-proxy-server/src/main/java/org/apache/distributedlog/service/stream/DeleteOp.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/BookKeeperClient.java
* (edit)
distributedlog-proxy-server/src/main/java/org/apache/distributedlog/service/stream/HeartbeatOp.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/limiter/ComposableRequestLimiter.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/impl/TestZKLogMetadataStore.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/config/TestDynamicDistributedLogConfiguration.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/lock/SessionLockFactory.java
* (edit)
distributedlog-protocol/src/test/java/org/apache/distributedlog/TestLogRecordSet.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/metadata/LogStreamMetadataStore.java
* (delete)
distributedlog-core/src/test/java/org/apache/distributedlog/util/TestSafeQueueingFuturePool.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/ReadAheadEntryReader.java
* (delete)
distributedlog-core/src/test/java/org/apache/distributedlog/util/TestFutureUtils.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/package-info.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/util/SchedulerUtils.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/metadata/DLMetadata.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/readahead/package-info.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/LogWriter.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/util/TestUtils.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/config/PropertiesConfigurationBuilder.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/TestSequenceID.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/util/SafeQueueingFuturePool.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/api/LogReader.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/io/AsyncDeleteable.java
* (edit) distributedlog-core/src/main/java/org/apache/distributedlog/Entry.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/TestBKLogWriteHandler.java
* (delete)
distributedlog-core/src/test/java/org/apache/distributedlog/rate/TestMovingAverageRate.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/concurrent/package-info.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentEntryReader.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/util/package-info.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/util/OrderedScheduler.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/config/ConcurrentConstConfiguration.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/config/ConfigurationSubscription.java
* (add)
distributedlog-core-twitter/src/main/java/org/apache/distributedlog/namespace/package-info.java
* (add)
distributedlog-core-twitter/src/main/java/org/apache/distributedlog/AsyncLogReader.java
* (add)
distributedlog-core-twitter/src/main/java/org/apache/distributedlog/DistributedLogManagerImpl.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/BKAsyncLogWriter.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/util/TimeSequencer.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/feature/DynamicConfigurationFeatureProvider.java
* (edit)
distributedlog-benchmark/src/main/java/org/apache/distributedlog/benchmark/WriterWorker.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/config/ConfigurationListener.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/auditor/DLAuditor.java
* (edit)
distributedlog-build-tools/src/main/resources/distributedlog/checkstyle.xml
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/stats/BroadCastStatsLogger.java
* (add)
distributedlog-core-twitter/src/main/java/org/apache/distributedlog/util/FutureUtils.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/subscription/SubscriptionStateStore.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/TestDistributedLogBase.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/util/MathUtil.java
* (add)
distributedlog-proxy-protocol/src/main/java/org/apache/distributedlog/protocol/util/TwitterFutureUtils.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/BKLogReadHandler.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/tools/DistributedLogTool.java
* (add)
distributedlog-core-twitter/src/test/java/org/apache/distributedlog/TestDistributedLogManagerImpl.java
* (edit)
distributedlog-proxy-server/src/main/java/org/apache/distributedlog/service/stream/ReleaseOp.java
* (edit)
distributedlog-benchmark/src/main/java/org/apache/distributedlog/benchmark/stream/AsyncReaderBenchmark.java
* (add)
distributedlog-core-twitter/src/main/java/org/apache/distributedlog/AsyncLogWriterImpl.java
* (add) distributedlog-core-twitter/src/main/resources/findbugsExclude.xml
* (add) distributedlog-protocol/src/test/resources/log4j.properties
* (add)
distributedlog-core-twitter/src/main/java/org/apache/distributedlog/LogReader.java
* (add) distributedlog-common/src/main/resources/findbugsExclude.xml
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/namespace/DistributedLogNamespace.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/lock/LockWaiter.java
* (edit) distributedlog-core/src/main/resources/findbugsExclude.xml
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/io/AsyncCloseable.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/RollingPolicy.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/annotations/package-info.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/impl/metadata/TestZKLogStreamMetadataStore.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/TestBKDistributedLogNamespace.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/functions/package-info.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/config/package-info.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/rate/package-info.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/rate/MovingAverageRateFactory.java
* (edit) pom.xml
* (delete)
distributedlog-protocol/src/main/java/org/apache/distributedlog/util/BitMaskUtils.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/bk/LedgerAllocatorPool.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/io/Abortable.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/callback/ReadAheadCallback.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/LogSegmentMetadata.java
* (edit)
distributedlog-proxy-server/src/main/java/org/apache/distributedlog/service/stream/AbstractStreamOp.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/config/ConcurrentConstConfiguration.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/util/Sizable.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/config/TestDynamicConfigurationFactory.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/util/OrderedScheduler.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/BKDistributedLogNamespace.java
* (add)
distributedlog-core-twitter/src/test/java/org/apache/distributedlog/TestSubscriptionStoreImpl.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/namespace/DistributedLogNamespaceBuilder.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/zk/ZKTransaction.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/TestNonBlockingReads.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/function/DefaultValueMapFunction.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/bk/TestLedgerAllocatorPool.java
* (edit)
distributedlog-tutorials/distributedlog-basic/src/main/java/org/apache/distributedlog/basic/TailReader.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/TestReadUtils.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/TestZooKeeperClient.java
* (edit)
distributedlog-proxy-server/src/main/java/org/apache/distributedlog/service/MonitorService.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/ZKLogMetadataStore.java
* (edit)
distributedlog-tutorials/distributedlog-kafka/src/main/java/org/apache/distributedlog/kafka/DLFutureRecordMetadata.java
* (add)
distributedlog-core-twitter/src/test/java/org/apache/distributedlog/namespace/TestDistributedLogNamespaceBuilder.java
* (add) distributedlog-core-twitter/pom.xml
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/util/MonitoredFuturePool.java
* (add)
distributedlog-core-twitter/src/test/java/org/apache/distributedlog/TestAsyncLogWriterImpl.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/acl/TestZKAccessControl.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/io/AsyncDeleteable.java
* (edit) distributedlog-proxy-client/pom.xml
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/io/AsyncAbortable.java
* (add)
distributedlog-core-twitter/src/main/java/org/apache/distributedlog/LogWriterImpl.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/annotations/DistributedLogAnnotations.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/io/AsyncAbortable.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/function/GetLastTxIdFunction.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/WriteLimiter.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/metadata/ZKLogStreamMetadataStore.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/impl/TestZKLogSegmentMetadataStore.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/impl/logsegment/TestBKLogSegmentEntryReader.java
* (add)
distributedlog-core-twitter/src/main/java/org/apache/distributedlog/namespace/DistributedLogNamespaceImpl.java
* (delete)
distributedlog-core/src/test/java/org/apache/distributedlog/namespace/TestDistributedLogNamespaceBuilder.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/TestInterleavedReaders.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/api/namespace/Namespace.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/util/MonitoredScheduledThreadPoolExecutor.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/TestAsyncBulkWrite.java
* (edit)
distributedlog-proxy-server/src/main/java/org/apache/distributedlog/service/stream/StreamOp.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/config/FileConfigurationBuilder.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/io/package-info.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/lock/TestDistributedLock.java
* (add)
distributedlog-core-twitter/src/main/java/org/apache/distributedlog/stats/OpStatsListener.java
* (edit)
distributedlog-proxy-server/src/main/java/org/apache/distributedlog/service/stream/StreamOpStats.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/lock/TestZKSessionLock.java
* (edit)
distributedlog-proxy-server/src/main/java/org/apache/distributedlog/service/placement/LeastLoadPlacementPolicy.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/util/ConfUtils.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/BKSyncLogReader.java
* (edit)
distributedlog-benchmark/src/main/java/org/apache/distributedlog/benchmark/stream/SyncReaderBenchmark.java
* (add)
distributedlog-core-twitter/src/main/java/org/apache/distributedlog/util/package-info.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/federated/FederatedZKLogMetadataStore.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentEntryStore.java
* (edit)
distributedlog-proxy-server/src/main/java/org/apache/distributedlog/service/stream/BulkWriteOp.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/util/SchedulerUtils.java
* (edit)
distributedlog-proxy-server/src/test/java/org/apache/distributedlog/service/placement/TestLeastLoadPlacementPolicy.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/ReadUtils.java
* (edit)
distributedlog-protocol/src/main/java/org/apache/distributedlog/EnvelopedRecordSetWriter.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/rate/MovingAverageRateFactory.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/io/package-info.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/TestLogSegmentMetadata.java
* (edit)
distributedlog-proxy-server/src/main/java/org/apache/distributedlog/service/stream/StreamManagerImpl.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/lock/ZKDistributedLock.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/concurrent/AsyncSemaphore.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/rate/SampledMovingAverageRate.java
* (edit) distributedlog-benchmark/conf/log4j.properties
* (edit)
distributedlog-benchmark/src/main/java/org/apache/distributedlog/benchmark/ReaderWorker.java
* (add)
distributedlog-core-twitter/src/test/java/org/apache/distributedlog/namespace/TestDistributedLogNamespaceImpl.java
* (delete)
distributedlog-protocol/src/main/java/org/apache/distributedlog/util/package-info.java
* (delete)
distributedlog-protocol/src/main/java/org/apache/distributedlog/annotations/DistributedLogAnnotations.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/config/ConfigurationSubscription.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/TestWriteLimiter.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/util/TestPermitManager.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/util/Permit.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentWriter.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/api/package-info.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/impl/federated/TestFederatedZKLogMetadataStore.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/config/ConcurrentBaseConfiguration.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/TestEntry.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/lock/DistributedLock.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/util/Allocator.java
* (add)
distributedlog-core/src/test/java/org/apache/distributedlog/namespace/TestNamespaceBuilder.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/api/MetadataAccessor.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/impl/TestZKNamespaceWatcher.java
* (add)
distributedlog-core-twitter/src/main/java/org/apache/distributedlog/subscription/package-info.java
* (edit) distributedlog-protocol/pom.xml
* (edit)
distributedlog-proxy-server/src/test/java/org/apache/distributedlog/service/TestDistributedLogService.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/util/package-info.java
* (edit) distributedlog-tutorials/distributedlog-messaging/conf/log4j.properties
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/subscription/ZKSubscriptionStateStore.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/config/FileConfigurationBuilder.java
* (add)
distributedlog-common/src/test/java/org/apache/distributedlog/common/concurrent/TestFutureUtils.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/bk/SimpleLedgerAllocator.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/lock/ZKSessionLock.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/logsegment/TestRollingPolicy.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/stats/OpStatsListener.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/config/ConfigurationListener.java
* (edit)
distributedlog-proxy-server/src/main/java/org/apache/distributedlog/service/config/ServerConfiguration.java
* (edit) distributedlog-tutorials/distributedlog-basic/conf/log4j.properties
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/TestLogSegmentsZK.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/util/PermitManager.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/lock/ZKSessionLockFactory.java
* (add)
distributedlog-core-twitter/src/main/java/org/apache/distributedlog/package-info.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/io/Abortable.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/stats/OpStatsListener.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/BKLogSegmentWriter.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/logsegment/BKUtils.java
* (add)
distributedlog-core-twitter/src/main/java/org/apache/distributedlog/stats/package-info.java
* (edit)
distributedlog-proxy-client/src/main/java/org/apache/distributedlog/client/DistributedLogMultiStreamWriter.java
* (edit)
distributedlog-proxy-server/src/main/java/org/apache/distributedlog/service/stream/limiter/StreamAcquireLimiter.java
* (edit)
distributedlog-tutorials/distributedlog-basic/src/main/java/org/apache/distributedlog/basic/ConsoleWriter.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/TestRollLogSegments.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/function/GetVersionedValueFunction.java
* (add)
distributedlog-common/src/test/java/org/apache/distributedlog/common/config/TestConfigurationSubscription.java
* (edit)
distributedlog-proxy-server/src/main/java/org/apache/distributedlog/service/stream/StreamImpl.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/TestAsyncReaderWriter.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/SizeBasedRollingPolicy.java
* (edit)
distributedlog-tutorials/distributedlog-basic/src/main/java/org/apache/distributedlog/basic/AtomicWriter.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/lock/SessionLock.java
* (edit) distributedlog-core/conf/log4j.properties
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/functions/VoidFunctions.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/util/BitMaskUtils.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/ZKMetadataAccessor.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/TestBKLogSegmentWriter.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/feature/TestConfigurationFeatureProvider.java
* (edit)
distributedlog-proxy-server/src/main/java/org/apache/distributedlog/service/stream/TruncateOp.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/stats/BKExceptionStatsLogger.java
* (edit)
distributedlog-proxy-server/src/main/java/org/apache/distributedlog/service/DistributedLogServer.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/acl/TestZKAccessControlManager.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/TestBKDistributedLogManager.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/metadata/TestLogSegmentMetadataStoreUpdater.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/util/FutureUtils.java
* (edit)
distributedlog-protocol/src/main/java/org/apache/distributedlog/LogRecordSet.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentMetadataStore.java
* (delete)
distributedlog-core/src/test/java/org/apache/distributedlog/config/TestConfigurationSubscription.java
* (delete)
distributedlog-protocol/src/test/java/org/apache/distributedlog/TestTimedOutTestsListener.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/feature/TestDynamicConfigurationFeatureProvider.java
* (add)
distributedlog-common/src/test/java/org/apache/distributedlog/common/config/PropertiesWriter.java
* (add)
distributedlog-common/src/test/java/org/apache/distributedlog/common/util/TimedOutTestsListener.java
* (add)
distributedlog-core-twitter/src/test/java/org/apache/distributedlog/TestLogWriterImpl.java
* (add)
distributedlog-core-twitter/src/main/java/org/apache/distributedlog/AsyncLogWriter.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/subscription/ZKSubscriptionsStore.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/config/PropertiesConfigurationBuilder.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/concurrent/FutureUtils.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/TestReadAheadEntryReader.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/stats/BroadCastStatsLogger.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/AppendOnlyStreamWriter.java
* (add)
distributedlog-core-twitter/src/main/java/org/apache/distributedlog/namespace/DistributedLogNamespace.java
* (edit)
distributedlog-proxy-server/src/main/java/org/apache/distributedlog/service/config/DefaultStreamConfigProvider.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/BKLogHandler.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/NonBlockingReadsTestUtil.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/config/PropertiesWriter.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/lock/NopDistributedLock.java
* (add)
distributedlog-core-twitter/src/test/java/org/apache/distributedlog/TestLogReaderImpl.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/DistributedLogConfiguration.java
* (edit)
distributedlog-benchmark/src/main/java/org/apache/distributedlog/benchmark/DLWriterWorker.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/ZKLogSegmentMetadataStore.java
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/config/ConcurrentBaseConfiguration.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/logsegment/BKLogSegmentEntryStore.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/impl/logsegment/BKLogSegmentEntryReader.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/bk/LedgerAllocatorDelegator.java
* (edit)
distributedlog-core/src/test/java/org/apache/distributedlog/TestReader.java
* (add)
distributedlog-core-twitter/src/main/java/org/apache/distributedlog/DistributedLogManager.java
* (edit)
distributedlog-proxy-server/src/test/java/org/apache/distributedlog/service/stream/TestStreamManager.java
* (add)
distributedlog-common/src/main/java/org/apache/distributedlog/common/concurrent/FutureEventListener.java
* (edit) distributedlog-core/pom.xml
* (delete)
distributedlog-core/src/main/java/org/apache/distributedlog/util/Sizable.java
* (add)
distributedlog-core/src/main/java/org/apache/distributedlog/api/namespace/package-info.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentRandomAccessEntryReader.java
* (edit)
distributedlog-core/src/main/java/org/apache/distributedlog/config/DynamicDistributedLogConfiguration.java
* (edit)
distributedlog-tutorials/distributedlog-messaging/src/main/java/org/apache/distributedlog/messaging/ReaderWithOffsets.java
> Use Java8 Future rather than twitter Future
> -------------------------------------------
>
> Key: DL-124
> URL: https://issues.apache.org/jira/browse/DL-124
> Project: DistributedLog
> Issue Type: Bug
> Affects Versions: 0.4.0
> Reporter: Gerrit Sundaram
> Assignee: Sijie Guo
> Labels: help-wanted
> Fix For: 0.5.0
>
>
> Since it is written in java, it would be good to leverage java8 future rather
> than introducing dependencies on scala.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
