bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/Bookie.java (7 lines): - line 42: // TODO: replace callback with futures - line 43: // TODO: replace ackBeforeSync with flags - line 57: // TODO: Shouldn't this be async? - line 74: // TODO: Replace Watcher with a completableFuture (cancellable) - line 83: // TODO: StateManager should be passed as a parameter to Bookie - line 86: // TODO: Should be constructed and passed in as a parameter - line 89: // TODO: Move this exceptions somewhere else stream/distributedlog/core/src/main/java/org/apache/distributedlog/tools/DistributedLogTool.java (3 lines): - line 1563: * TODO: refactor inspect & inspectstream. - line 1564: * TODO: support force - line 2629: // TODO: Fix it later, tracking by https://github.com/apache/distributedlog/issues/150 stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/metadata/RootRangeStoreImpl.java (3 lines): - line 258: // TODO: differentiate the error code - line 325: // TODO: differentiate the error code - line 510: // TODO: differentiate the error codes bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/MSLedgerManagerFactory.java (2 lines): - line 126: // TODO: should record version in somewhere. e.g. ZooKeeper - line 677: // TODO: currently just use zk ledger underreplication manager stream/distributedlog/core/src/main/java/org/apache/distributedlog/admin/DistributedLogAdmin.java (2 lines): - line 430: * TODO: move unbind operation to namespace driver - line 490: * TODO: move bind to namespace driver stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/journal/AbstractStateStoreWithJournal.java (2 lines): - line 438: // TODO: handle state store exception - line 444: // TODO: handle read failure bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/InterleavedLedgerStorage.java (1 line): - line 572: // TODO: we could consider remove checkpointSource and checkpointSource#newCheckpoint bookkeeper-server/src/main/java/org/apache/bookkeeper/zookeeper/ZooKeeperWatcherBase.java (1 line): - line 129: // TODO: Needs to handle AuthFailed, SaslAuthenticated events stream/distributedlog/core/src/main/java/org/apache/distributedlog/ReadUtils.java (1 line): - line 732: // TODO: improve it by estimating transaction ids. stream/clients/python/noxfile.py (1 line): - line 101: # TODO: Enable coverage report stream/distributedlog/core/src/main/java/org/apache/distributedlog/namespace/NamespaceDriver.java (1 line): - line 122: * (TODO: it is a legacy interface. should remove it if we have metadata of stream.) stream/distributedlog/core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentEntryWriter.java (1 line): - line 34: * TODO: The interface is leveraging bookkeeper's callback and status code now stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/kv/RocksdbKVStore.java (1 line): - line 208: // TODO: move create checkpoint to the checkpoint method stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/LogRecord.java (1 line): - line 129: // TODO: Replace with EnumSet stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/kv/KVCommandProcessor.java (1 line): - line 53: // TODO: better to handle this stream/distributedlog/core/src/main/java/org/apache/distributedlog/exceptions/ZKException.java (1 line): - line 24: * TODO: move ZKException to distributedlog-protocol. stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/mvcc/MVCCStoreImpl.java (1 line): - line 345: * TODO: the increment operation can be optimized using rocksdb merge operator. stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/mvcc/op/proto/ProtoRangeOpImpl.java (1 line): - line 131: // TODO: fix this bookkeeper-server/src/main/java/org/apache/bookkeeper/client/RegionAwareEnsemblePlacementPolicy.java (1 line): - line 676: * TODO: have to implement actual logic for this method for stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/TransactionIdOutOfOrderException.java (1 line): - line 26: // TODO: copied from DistributedLogConstants (we should think about how to separated common constants) bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/AutoRecoveryMain.java (1 line): - line 66: *
TODO: eliminate the direct usage of zookeeper here {@link https://github.com/apache/bookkeeper/issues/1332} bookkeeper-benchmark/src/main/java/org/apache/bookkeeper/benchmark/BenchThroughputLatency.java (1 line): - line 442: *
TODO: update benchmark to use metadata service uri {@link https://github.com/apache/bookkeeper/issues/1331} stream/clients/python/nox.py (1 line): - line 95: # TODO: Enable coverage report metadata-drivers/etcd/src/main/java/org/apache/bookkeeper/metadata/etcd/EtcdMetadataClientDriver.java (1 line): - line 79: * TODO: EtcdMetadataClientDriver has to implement this method. stream/clients/java/kv/src/main/java/org/apache/bookkeeper/clients/impl/kv/PByteBufTableImpl.java (1 line): - line 213: // TODO: we need logic to handle scale/repartitioning stream/distributedlog/core/src/main/java/org/apache/distributedlog/BKLogSegmentWriter.java (1 line): - line 893: * (TODO: moved this method to log writer level) bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/BookieImpl.java (1 line): - line 645: // TODO: When reading in the journal logs that need to be synced, we stream/distributedlog/core/src/main/java/org/apache/distributedlog/impl/federated/FederatedZKLogMetadataStore.java (1 line): - line 563: // TODO: rewrite this after we bump to zk 3.5, where we will have asynchronous version of multi stats/bookkeeper-stats-api/src/main/java/org/apache/bookkeeper/stats/OpStatsData.java (1 line): - line 31: // TODO: Figure out if we can use a Map stream/distributedlog/core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentWriter.java (1 line): - line 60: * TODO: we should remove this method. when we rewrite synchronous writer based on asynchronous writer, bookkeeper-server/src/main/java/org/apache/bookkeeper/client/ZoneawareEnsemblePlacementPolicyImpl.java (1 line): - line 836: // TODO Auto-generated method stub stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/store/MVCCStoreFactoryImpl.java (1 line): - line 122: // TODO: change to filesystem path bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/Auditor.java (1 line): - line 66: *
TODO: eliminate the direct usage of zookeeper here {@link https://github.com/apache/bookkeeper/issues/1332} bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/package-info.java (1 line): - line 23: *
TODO: this package will be moved to `bookkeeper-tools` module stream/server/src/main/java/org/apache/bookkeeper/stream/server/service/DLNamespaceProviderService.java (1 line): - line 40: *
TODO: eliminate the direct usage of zookeeper here {@link https://github.com/apache/bookkeeper/issues/1331}