This is an automated email from the ASF dual-hosted git repository.
merlimat pushed a change to branch
dependabot/maven/org.bouncycastle-bc-fips-1.0.2.6
in repository https://gitbox.apache.org/repos/asf/bookkeeper.git
from b8ae936758 Update licenses
add 534ba20dd9 Update BK version in the Docker file (#4704)
add 6c8141e38f Fix download page after website framework upgrade to
Docusaurus 3 (#4724)
add 1808a084cb Upgrade zookeeper to 3.9.5 in docker-compose and
integration tests (#4726)
add be1f6aa86f Fix broken link in README.md (#4729)
add 951f10d9e7 [client] fix writeLac memory leak and thread safety issue
(#4713)
add d08fcb7094 test: Use mock to eliminate BookieSocketAddressTest
dependency on local system configuration (#4711)
add 497aa4e53b Count the connection failure as the condition of quarantine
(#4727)
add a7f0ba1ae1 build(deps): bump org.apache.commons:commons-lang3 from
3.17.0 to 3.20.0 (#4725)
add 8664dd9629 Fix read thread blocking in sendResponseAndWait causing
READ_ENTRY_REQUEST p99 latency spike (#4730)
add 8a8f4d607d [FIX] fix SyncLedgerIterator.hasNext() failing to iterate
across ZK ledger ranges (#4731)
add 6dc59255dc [FIX] Fix IllegalThreadStateException in ComponentStarter
shutdown hook (#4733)
add edf2155563 feat: migrate native-io implementation from C to Rust
(#4738)
add af117a669a Add rerun-failure command to bkbot (#4746)
add 6fac859db3 Upgrade Netty to 4.2.12.Final (#4744)
add ad2b6e939d fix: ensure discard_max_bytes is set to 0 only for existing
block devices (#4745)
add b5ce0e5ff0 [FIX] Fix flaky BookieAutoRecoveryTest#testOpenLedgers
timeout (#4743)
add 7b362b1d8f Install native build toolchain in website PR validation
workflow (#4753)
add fe5b8062cf BP-69: Adopt slog for structured logging (#4751)
add 7410987980 Fix race condition NPE in V3 response handling during
timeout check (#4737)
add a61a6305db Support bookie server config tcp keep-alive (#4762)
add ed71a06dc8 BP-69: Convert bookkeeper-common to slog (phase 1) (#4754)
add 22a37eccdd BP-69: Convert stats and allocator modules to slog (phase
2) (#4755)
add a3ec40b1db BP-69: Convert bookkeeper-server to slog (phase 3) (#4756)
add 51abbc248f BP-69: Convert stream/distributedlog modules to slog (phase
5) (#4757)
add 46c842ca4a BP-69: Convert http, tools, benchmark and metadata-drivers
to slog (phase 4+6) (#4758)
add 697bd594df Fix NPE in PendingAddOp.maybeTimeout() when clientCtx is
null after recycling (#4760)
add 34ec6a45df [Fix] ConcurrentLongHashMap throw
ArrayIndexOutOfBoundsException (#4771)
add 0b7cc3d0a4 Upgrade OpenTelemetry libraries to 1.61.0 / 2.27.0 (#4773)
add 449fe78dd5 BP-69: Print slog context attrs in log4j2; add OTel JSON
example (#4770)
add db5cd4e2a2 BP-69: Remove bookkeeper-slogger module (#4764)
add 66a6d5d434 BP-69: Allow caller to pass a parent slog Logger to
created/opened ledgers (#4766)
add de34d1434c BP-69: Inherit LedgerHandle logger context in ledger
operations (#4767)
add 354cc54965 Log only overridden config in BookieServer startup (#4768)
add bb1a7cbf9e [FIX] Avoid killing the Auditor leader in
BookieAutoRecoveryTest (#4769)
add e42928e73b BP-69: Convert remaining SLF4J usages in non-test code to
slog (#4765)
add 28b3336910 Upgrade Netty to 4.2.13 to address CVEs (#4775)
add a871f6efc2 Upgrade jctools to 4.0.6 (jctools-core-jdk11) (#4776)
add ad8f4fc333 Migrate from Yahoo DataSketches to Apache DataSketches
7.0.1 (KLL) (#4774)
add 58c8503562 [[BP-62] Expose batchReadUnconfirmedAsync to ReadHandle
(#4739)
add 12d4bbdfed Migrate DataFormats from protobuf-java to LightProto (#4779)
add a0231ede67 Fix LedgerHandle.batchReadUnconfirmedAsync: use slog log
instead of LOG (#4782)
add c2866286ce Migrate stream non-gRPC protos to LightProto (#4781)
add 9633bb740e Migrate stream gRPC protos to LightProto (#4783)
add 47efc0dd6d Migrate BookkeeperProtocol from protobuf-java to LightProto
(#4780)
add 985fe2a766 fix: add javadoc support for pom-only shaded modules (#4787)
add 8b6671fff8 Scope gRPC dependencies and rely on grpc-bom for single
version (#4784)
add 6ef121e2b7 Upgrade vert.x to 4.5.25 to address CVE-2026-6860 (#4790)
add 076fabd23d Upgrade vertx to 4.5.27 to address CVE-2026-6860 (#4792)
add 3565d0e289 Upgrade thrift to 0.23.0 to address CVE-2026-43869 (#4791)
add 1dc894fbb6 Upgrade Netty to 4.2.14 (#4799)
add 18a4368d2d Fix batch reads hanging after digest mismatch retries are
ignored (#4789)
add 4a98f1806c Fix WriteSet use-after-recycle in sequence reads (#4788)
add cbb336702a Fix issue where options for sanity test command are ignored
(#4691)
add 8e88b03b6a Optimize bounded batch reads by predicting entry count
(#4741)
add ccfabfaf50 fix Bookkeeper can't startup cause by 'IOException:
Recovery log xxx is missing' (#4740)
add 3c4a02673f Include lombok config in source release (#4808)
add 55e0088171 Fix release user id (#4806)
add 0af6e6071a Add cargo-zigbuild for release dockerfile (#4805)
add 345c3d92b5 Upgrade to Netty 4.2.15 to address CVEs (#4813)
add 4a012a2a1e Generate 4.18.0 release note (#4807)
add 82df77c951 Use ASF-allowlisted dtolnay/rust-toolchain revision in
setup-native-build (#4828)
add 15a961b67b Revert "Fix read thread blocking in sendResponseAndWait
causing READ_ENTRY_REQUEST p99 latency spike (#4730)" (#4830)
add 451b6a59ef Fix table service txn request corruption on silent client
retries (#4829)
add f1d7cc16f3 Add spin-wait hint to BlockingMpscQueue producer-side busy
loops (#4831)
add 970f56ea04 Use ThreadLocalRandom for thread selection in
OrderedExecutor (#4832)
add d476a7b9e2 Write journal entry length prefix and payload in a single
BufferedChannel write (#4833)
add 6a4842e023 Add OpenBuilder.withKeepUpdateMetadata and
DeleteBuilder.withLoggerContext to the builder API (#4834)
add bcb3e708f1 Skip journal flush-trace loop when debug logging is
disabled (#4835)
add 68cc8dcbd1 Use batch-draining queues in SingleThreadExecutor (#4836)
add ef200f22f2 Generate 4.17.4 release note (#4826)
add 5b0cf0de80 Use ASF-allowlisted dtolnay/rust-toolchain revision in
setup-native-build (#4851)
add 1a02b5d9fb Generate 4.17.4 website docs (#4853)
add a4b8c2aff1 Update latest docker image version to 4.17.4 (#4852)
add 39cd6e089d build: update 4.17.4 to latest_release (#4858)
add 55650aa78f docs: add news about 4.17.4 release (#4859)
add a41c70061d Issue 4797:Prevent thread leak when BookKeeper client
constructor fails (#4798)
add 898d65985d build(deps): bump brace-expansion in /site3/website (#4866)
add 9590a97f67 build(deps): bump nanoid from 3.3.11 to 3.3.18 in
/site3/website (#4868)
add 0a2d5bee28 Avoid per-checksum boxing in Java9IntHash by using
MethodHandle.invokeExact (#4876)
add fc25542e9d Bump Jetty to 12.1.10 and fix binary license metadata
(#4871)
add badd5f854a Pin a ledger's callbacks to a caller-chosen worker thread
via withOrderingKey (#4881)
add 06869bc002 Upgrade RocksDB JNI to 10.10.1.1 while preserving 7.9.2
index compatibility (#4886)
add c1a9fb6ae3 Merge remote-tracking branch 'origin/master' into
bcfips-1.0.2.6
No new revisions were added by this update.
Summary of changes:
.../action.yml | 19 +-
.github/actions/tune-runner-vm/action.yml | 6 +-
.github/workflows/bk-ci.yml | 22 +
.github/workflows/bk-streamstorage-python.yml | 4 +-
.github/workflows/ci-bkbot.yaml | 46 ++-
.github/workflows/codeql.yml | 4 +
.github/workflows/java21-daily-build.yml | 2 +
.github/workflows/website-pr-validation.yml | 2 +
.github/workflows/windows-daily-build.yml | 2 +
README.md | 6 +-
bookkeeper-benchmark/conf/log4j2.xml | 6 +-
.../apache/bookkeeper/benchmark/BenchBookie.java | 27 +-
.../benchmark/BenchReadThroughputLatency.java | 41 +-
.../benchmark/BenchThroughputLatency.java | 78 ++--
.../apache/bookkeeper/benchmark/TestClient.java | 46 ++-
.../common/allocator/LeakDetectionPolicy.java | 10 +-
.../allocator/impl/ByteBufAllocatorImpl.java | 16 +-
.../bookkeeper/common/util/ShutdownUtil.java | 16 +-
bookkeeper-common/pom.xml | 14 +-
.../common/collections/BlockingMpscQueue.java | 6 +
.../bookkeeper/common/collections/BusyWait.java | 8 +-
...java => GrowableBatchedArrayBlockingQueue.java} | 236 ++++++-----
.../GrowableMpScArrayConsumerBlockingQueue.java | 331 ---------------
.../component/AbstractLifecycleComponent.java | 20 +-
.../component/AutoCloseableLifecycleComponent.java | 10 +-
.../common/component/ComponentInfoPublisher.java | 18 +-
.../common/component/ComponentStarter.java | 34 +-
.../common/component/LifecycleComponentStack.java | 12 +-
.../bookkeeper/common/concurrent/FutureUtils.java | 14 +-
.../apache/bookkeeper/common/conf/ConfigDef.java | 10 +-
.../apache/bookkeeper/common/conf/ConfigKey.java | 2 -
.../common/conf/validators/ClassValidator.java | 19 +-
.../common/util/LogExceptionRunnable.java | 9 +-
.../bookkeeper/common/util/OrderedExecutor.java | 26 +-
.../bookkeeper/common/util/SafeRunnable.java | 7 +-
.../common/util/SingleThreadExecutor.java | 56 +--
.../SingleThreadSafeScheduledExecutorService.java | 9 +-
.../collections/BatchedArrayBlockingQueueTest.java | 2 +-
.../GrowableArrayBlockingQueueTest.java | 273 -------------
.../GrowableBatchedArrayBlockingQueueTest.java | 380 +++++++++++++++++
.../common/util/TestOrderedExecutorDecorators.java | 5 +-
bookkeeper-dist/src/assemble/bin-all.xml | 1 -
bookkeeper-dist/src/assemble/bin-server.xml | 1 -
bookkeeper-dist/src/assemble/bkctl.xml | 2 -
bookkeeper-dist/src/assemble/src.xml | 1 +
.../src/main/resources/LICENSE-all.bin.txt | 268 ++++++------
.../src/main/resources/LICENSE-bkctl.bin.txt | 176 +++-----
.../src/main/resources/LICENSE-server.bin.txt | 267 ++++++------
.../src/main/resources/NOTICE-all.bin.txt | 78 ++--
.../src/main/resources/NOTICE-bkctl.bin.txt | 47 ++-
.../src/main/resources/NOTICE-server.bin.txt | 78 ++--
.../google-auth-library-credentials-0.20.0/LICENSE | 28 --
.../apache/bookkeeper/http/HttpServerLoader.java | 19 +-
.../http/servlet/BookieHttpServiceServlet.java | 7 +-
.../http/servlet/BookieServletHttpServer.java | 7 +-
.../http/vertx/VertxAbstractHandler.java | 11 +-
.../bookkeeper/http/vertx/VertxHttpServer.java | 25 +-
bookkeeper-proto/pom.xml | 22 +-
bookkeeper-server/pom.xml | 14 +-
.../bookkeeper/bookie/BookieCriticalThread.java | 12 +-
.../org/apache/bookkeeper/bookie/BookieImpl.java | 156 +++----
.../apache/bookkeeper/bookie/BookieResources.java | 7 +-
.../org/apache/bookkeeper/bookie/BookieShell.java | 67 +--
.../bookkeeper/bookie/BookieStateManager.java | 30 +-
.../org/apache/bookkeeper/bookie/BookieStatus.java | 36 +-
.../org/apache/bookkeeper/bookie/BookieThread.java | 12 +-
.../apache/bookkeeper/bookie/BufferedChannel.java | 73 +++-
.../java/org/apache/bookkeeper/bookie/Cookie.java | 36 +-
.../bookkeeper/bookie/DefaultEntryLogger.java | 137 ++++---
.../bookkeeper/bookie/EntryLogCompactor.java | 15 +-
.../bookkeeper/bookie/EntryLogManagerBase.java | 21 +-
.../EntryLogManagerForEntryLogPerLedger.java | 46 ++-
.../bookie/EntryLogManagerForSingleEntryLog.java | 6 +-
.../bookkeeper/bookie/EntryLoggerAllocator.java | 15 +-
.../apache/bookkeeper/bookie/EntryMemTable.java | 9 +-
.../bookie/EntryMemTableWithParallelFlusher.java | 12 +-
.../org/apache/bookkeeper/bookie/FileInfo.java | 48 ++-
.../bookkeeper/bookie/FileInfoBackingCache.java | 11 +-
.../bookkeeper/bookie/FileSystemUpgrade.java | 65 +--
.../bookkeeper/bookie/GarbageCollectorThread.java | 217 ++++++----
.../bookkeeper/bookie/IndexInMemPageMgr.java | 30 +-
.../bookkeeper/bookie/IndexPersistenceMgr.java | 43 +-
.../bookie/InterleavedLedgerStorage.java | 70 ++--
.../InterleavedStorageRegenerateIndexOp.java | 48 ++-
.../java/org/apache/bookkeeper/bookie/Journal.java | 132 +++---
.../apache/bookkeeper/bookie/JournalChannel.java | 25 +-
.../apache/bookkeeper/bookie/LedgerCacheImpl.java | 9 +-
.../bookkeeper/bookie/LedgerDescriptorImpl.java | 19 +-
.../bookkeeper/bookie/LedgerDirsManager.java | 19 +-
.../bookkeeper/bookie/LedgerDirsMonitor.java | 41 +-
.../apache/bookkeeper/bookie/LedgerEntryPage.java | 20 +-
.../bookkeeper/bookie/LegacyCookieValidation.java | 28 +-
.../bookie/LocalBookieEnsemblePlacementPolicy.java | 8 +-
.../apache/bookkeeper/bookie/ReadOnlyBookie.java | 10 +-
.../bookie/ScanAndCompareGarbageCollector.java | 70 ++--
.../bookkeeper/bookie/SlowBufferedChannel.java | 6 +
.../bookkeeper/bookie/SortedLedgerStorage.java | 17 +-
.../org/apache/bookkeeper/bookie/SyncThread.java | 26 +-
.../bookie/TransactionalEntryLogCompactor.java | 78 ++--
.../bookie/UncleanShutdownDetectionImpl.java | 43 +-
.../bookie/datainteg/DataIntegrityCheckImpl.java | 201 ++++++---
.../datainteg/DataIntegrityCookieValidation.java | 23 +-
.../bookie/datainteg/DataIntegrityService.java | 33 +-
.../bookie/datainteg/EntryCopierImpl.java | 9 +-
.../bookie/datainteg/MetadataAsyncIterator.java | 9 +-
.../bookkeeper/bookie/datainteg/WriteSets.java | 3 -
.../DirectCompactionEntryLog.java | 64 +--
.../directentrylogger/DirectEntryLogger.java | 66 +--
.../storage/directentrylogger/DirectWriter.java | 19 +-
.../storage/directentrylogger/EntryLogIdsImpl.java | 18 +-
.../bookie/storage/directentrylogger/Events.java | 145 -------
.../bookie/storage/ldb/DbLedgerStorage.java | 18 +-
.../bookie/storage/ldb/EntryLocationIndex.java | 53 ++-
.../bookie/storage/ldb/KeyValueStorageRocksDB.java | 33 +-
.../bookie/storage/ldb/LedgerMetadataIndex.java | 98 ++---
.../bookie/storage/ldb/LedgersIndexCheckOp.java | 46 +--
.../bookie/storage/ldb/LedgersIndexRebuildOp.java | 69 ++--
.../storage/ldb/LocationsIndexRebuildOp.java | 33 +-
.../storage/ldb/PersistentEntryLogMetadataMap.java | 25 +-
.../bookkeeper/bookie/storage/ldb/ReadCache.java | 10 +-
.../ldb/SingleDirectoryDbLedgerStorage.java | 198 ++++-----
.../bookkeeper/bookie/storage/ldb/WriteCache.java | 23 +-
.../apache/bookkeeper/client/BatchedReadOp.java | 88 ++--
.../org/apache/bookkeeper/client/BookKeeper.java | 348 +++++++++-------
.../apache/bookkeeper/client/BookKeeperAdmin.java | 205 ++++++----
.../client/BookieAddressResolverDisabled.java | 4 +-
.../apache/bookkeeper/client/BookieInfoReader.java | 127 +++---
.../bookkeeper/client/BookieWatcherImpl.java | 57 +--
.../client/DefaultBookieAddressResolver.java | 23 +-
.../client/DefaultEnsemblePlacementPolicy.java | 5 +-
.../DefaultSpeculativeRequestExecutionPolicy.java | 29 +-
.../client/DynamicWeightedRandomSelectionImpl.java | 5 +-
.../apache/bookkeeper/client/EnsembleUtils.java | 29 +-
.../bookkeeper/client/ExplicitLacFlushPolicy.java | 47 ++-
.../apache/bookkeeper/client/ForceLedgerOp.java | 32 +-
.../apache/bookkeeper/client/LedgerChecker.java | 39 +-
.../apache/bookkeeper/client/LedgerCreateOp.java | 121 ++++--
.../apache/bookkeeper/client/LedgerDeleteOp.java | 31 +-
.../client/LedgerFragmentReplicator.java | 101 +++--
.../org/apache/bookkeeper/client/LedgerHandle.java | 383 +++++++++++++-----
.../apache/bookkeeper/client/LedgerHandleAdv.java | 34 +-
.../bookkeeper/client/LedgerMetadataImpl.java | 5 +-
.../bookkeeper/client/LedgerMetadataUtils.java | 5 +-
.../org/apache/bookkeeper/client/LedgerOpenOp.java | 140 +++++--
.../apache/bookkeeper/client/LedgerRecoveryOp.java | 36 +-
.../client/ListenerBasedPendingReadOp.java | 4 +-
.../bookkeeper/client/MetadataUpdateLoop.java | 56 +--
.../org/apache/bookkeeper/client/PendingAddOp.java | 109 +++--
.../apache/bookkeeper/client/PendingReadLacOp.java | 29 +-
.../apache/bookkeeper/client/PendingReadOp.java | 85 +++-
.../bookkeeper/client/PendingWriteLacOp.java | 40 +-
.../RackawareEnsemblePlacementPolicyImpl.java | 171 +++++---
.../client/ReadLastConfirmedAndEntryOp.java | 136 ++++---
.../bookkeeper/client/ReadLastConfirmedOp.java | 51 ++-
.../bookkeeper/client/ReadOnlyLedgerHandle.java | 82 ++--
.../org/apache/bookkeeper/client/ReadOpBase.java | 47 ++-
.../client/RegionAwareEnsemblePlacementPolicy.java | 93 +++--
.../client/RoundRobinDistributionSchedule.java | 15 +-
.../bookkeeper/client/SyncCallbackUtils.java | 10 +-
.../TopologyAwareEnsemblePlacementPolicy.java | 100 +++--
.../bookkeeper/client/TryReadLastConfirmedOp.java | 39 +-
.../apache/bookkeeper/client/UpdateLedgerOp.java | 33 +-
.../client/WeightedRandomSelectionImpl.java | 37 +-
.../ZoneawareEnsemblePlacementPolicyImpl.java | 138 ++++---
.../bookkeeper/client/api/CreateAdvBuilder.java | 14 +
.../bookkeeper/client/api/CreateBuilder.java | 37 ++
.../bookkeeper/client/api/DeleteBuilder.java | 18 +
.../apache/bookkeeper/client/api/OpenBuilder.java | 53 +++
.../apache/bookkeeper/client/api/ReadHandle.java | 16 +
.../bookkeeper/client/impl/OpenBuilderBase.java | 29 +-
.../bookkeeper/conf/AbstractConfiguration.java | 2 -
.../bookkeeper/conf/ClientConfiguration.java | 23 ++
.../bookkeeper/conf/ServerConfiguration.java | 66 +++
.../bookkeeper/discover/ZKRegistrationClient.java | 84 ++--
.../bookkeeper/discover/ZKRegistrationManager.java | 147 +++----
.../meta/AbstractHierarchicalLedgerManager.java | 23 +-
.../bookkeeper/meta/AbstractZkLedgerManager.java | 196 +++++----
.../meta/AbstractZkLedgerManagerFactory.java | 38 +-
.../bookkeeper/meta/CleanupLedgerManager.java | 2 -
.../apache/bookkeeper/meta/FlatLedgerManager.java | 5 +-
.../bookkeeper/meta/HierarchicalLedgerManager.java | 5 +-
.../org/apache/bookkeeper/meta/LedgerLayout.java | 12 +-
.../bookkeeper/meta/LedgerMetadataSerDe.java | 299 +++++++-------
.../meta/LegacyHierarchicalLedgerManager.java | 15 +-
.../meta/LongHierarchicalLedgerManager.java | 17 +-
.../bookkeeper/meta/LongZkLedgerIdGenerator.java | 44 +-
.../bookkeeper/meta/MSLedgerManagerFactory.java | 135 ++++---
.../apache/bookkeeper/meta/MetadataDrivers.java | 30 +-
.../bookkeeper/meta/ZkLedgerAuditorManager.java | 25 +-
.../bookkeeper/meta/ZkLedgerIdGenerator.java | 24 +-
.../meta/ZkLedgerUnderreplicationManager.java | 276 ++++++-------
.../bookkeeper/meta/zk/ZKMetadataBookieDriver.java | 2 -
.../bookkeeper/meta/zk/ZKMetadataClientDriver.java | 2 -
.../bookkeeper/meta/zk/ZKMetadataDriverBase.java | 36 +-
.../bookkeeper/metastore/MetastoreUtils.java | 23 +-
.../main/java/org/apache/bookkeeper/net/DNS.java | 27 +-
.../apache/bookkeeper/net/NetworkTopologyImpl.java | 29 +-
.../apache/bookkeeper/net/ScriptBasedMapping.java | 30 +-
.../bookkeeper/net/StabilizeNetworkTopology.java | 13 +-
.../org/apache/bookkeeper/proto/AddCompletion.java | 39 +-
.../org/apache/bookkeeper/proto/AuthHandler.java | 153 +++----
.../java/org/apache/bookkeeper/proto/BKStats.java | 7 +-
.../bookkeeper/proto/BatchedReadCompletion.java | 12 +-
.../proto/BatchedReadEntryProcessor.java | 9 +-
.../org/apache/bookkeeper/proto/BookieClient.java | 119 +++++-
.../apache/bookkeeper/proto/BookieClientImpl.java | 87 ++--
.../apache/bookkeeper/proto/BookieNettyServer.java | 89 ++--
.../bookkeeper/proto/BookieProtoEncoding.java | 189 ++++-----
.../apache/bookkeeper/proto/BookieProtocol.java | 1 -
.../bookkeeper/proto/BookieRequestHandler.java | 20 +-
.../bookkeeper/proto/BookieRequestProcessor.java | 226 +++++------
.../org/apache/bookkeeper/proto/BookieServer.java | 62 ++-
.../proto/BookkeeperInternalCallbacks.java | 14 +-
.../apache/bookkeeper/proto/ByteStringUtil.java | 80 ----
.../org/apache/bookkeeper/proto/CompletionKey.java | 1 -
.../apache/bookkeeper/proto/CompletionValue.java | 71 ++--
.../proto/DefaultPerChannelBookieClientPool.java | 6 +-
.../bookkeeper/proto/EntryCompletionKey.java | 4 +-
.../bookkeeper/proto/ForceLedgerCompletion.java | 24 +-
.../bookkeeper/proto/ForceLedgerProcessorV3.java | 39 +-
.../bookkeeper/proto/GetBookieInfoCompletion.java | 13 +-
.../bookkeeper/proto/GetBookieInfoProcessorV3.java | 40 +-
.../proto/GetListOfEntriesOfLedgerCompletion.java | 16 +-
.../proto/GetListOfEntriesOfLedgerProcessorV3.java | 44 +-
.../proto/LongPollReadEntryProcessorV3.java | 83 ++--
.../bookkeeper/proto/PacketProcessorBase.java | 42 +-
.../bookkeeper/proto/PacketProcessorBaseV3.java | 27 +-
.../bookkeeper/proto/PerChannelBookieClient.java | 450 +++++++++++----------
.../apache/bookkeeper/proto/ReadCompletion.java | 61 +--
.../bookkeeper/proto/ReadEntryProcessor.java | 88 ++--
.../bookkeeper/proto/ReadEntryProcessorV3.java | 142 ++++---
.../apache/bookkeeper/proto/ReadLacCompletion.java | 20 +-
.../bookkeeper/proto/ReadLacProcessorV3.java | 64 +--
.../org/apache/bookkeeper/proto/RequestUtils.java | 30 +-
.../bookkeeper/proto/StartTLSCompletion.java | 16 +-
.../apache/bookkeeper/proto/TxnCompletionKey.java | 2 +-
.../bookkeeper/proto/WriteEntryProcessor.java | 37 +-
.../bookkeeper/proto/WriteEntryProcessorV3.java | 78 ++--
.../bookkeeper/proto/WriteLacCompletion.java | 24 +-
.../bookkeeper/proto/WriteLacProcessorV3.java | 82 ++--
.../proto/checksum/CRC32CDigestManager.java | 4 +-
.../bookkeeper/proto/checksum/DigestManager.java | 55 ++-
.../proto/checksum/MacDigestManager.java | 7 +-
.../org/apache/bookkeeper/replication/Auditor.java | 152 +++----
.../replication/AuditorBookieCheckTask.java | 30 +-
.../replication/AuditorCheckAllLedgersTask.java | 72 ++--
.../bookkeeper/replication/AuditorElector.java | 26 +-
.../AuditorPlacementPolicyCheckTask.java | 118 +++---
.../replication/AuditorReplicasCheckTask.java | 164 ++++----
.../apache/bookkeeper/replication/AuditorTask.java | 12 +-
.../bookkeeper/replication/AutoRecoveryMain.java | 52 +--
.../replication/BookieLedgerIndexer.java | 11 +-
.../replication/ReplicationEnableCb.java | 14 +-
.../bookkeeper/replication/ReplicationWorker.java | 176 ++++----
.../bookkeeper/sasl/SASLBookieAuthProvider.java | 12 +-
.../sasl/SASLBookieAuthProviderFactory.java | 20 +-
.../bookkeeper/sasl/SASLClientAuthProvider.java | 18 +-
.../bookkeeper/sasl/SASLClientProviderFactory.java | 13 +-
.../apache/bookkeeper/sasl/SaslClientState.java | 25 +-
.../apache/bookkeeper/sasl/SaslServerState.java | 51 ++-
.../apache/bookkeeper/sasl/TGTRefreshThread.java | 106 ++---
.../apache/bookkeeper/server/EmbeddedServer.java | 31 +-
.../java/org/apache/bookkeeper/server/Main.java | 40 +-
.../server/http/BKHttpServiceProvider.java | 8 +-
.../server/http/service/BookieSanityService.java | 9 +-
.../server/http/service/ClusterInfoService.java | 6 +-
.../server/http/service/DecommissionService.java | 34 +-
.../server/http/service/DeleteLedgerService.java | 9 +-
.../server/http/service/ExpandStorageService.java | 11 +-
.../server/http/service/GCDetailsService.java | 9 +-
.../server/http/service/GetLastLogMarkService.java | 20 +-
.../server/http/service/GetLedgerMetaService.java | 9 +-
.../server/http/service/ListBookieInfoService.java | 9 +-
.../server/http/service/ListBookiesService.java | 12 +-
.../server/http/service/ListDiskFilesService.java | 9 +-
.../server/http/service/ListLedgerService.java | 9 +-
.../service/ListUnderReplicatedLedgerService.java | 11 +-
.../service/LostBookieRecoveryDelayService.java | 11 +-
.../http/service/ReadLedgerEntryService.java | 9 +-
.../server/http/service/RecoveryBookieService.java | 20 +-
.../http/service/ResumeCompactionService.java | 9 +-
.../http/service/SuspendCompactionService.java | 13 +-
.../server/http/service/TriggerAuditService.java | 11 +-
.../server/http/service/TriggerGCService.java | 19 +-
.../service/TriggerLocationCompactService.java | 15 +-
.../server/http/service/WhoIsAuditorService.java | 11 +-
.../bookkeeper/server/service/BookieService.java | 9 +-
.../bookkeeper/server/service/ScrubberService.java | 14 +-
.../bookkeeper/streaming/LedgerOutputStream.java | 16 +-
.../apache/bookkeeper/tls/BookieAuthZFactory.java | 36 +-
.../bookkeeper/tls/FileModifiedTimeUpdater.java | 10 +-
.../tls/SecurityProviderFactoryFactory.java | 12 +-
.../apache/bookkeeper/tls/TLSContextFactory.java | 64 +--
.../autorecovery/ListUnderReplicatedCommand.java | 23 +-
.../LostBookieRecoveryDelayCommand.java | 13 +-
.../QueryAutoRecoveryStatusCommand.java | 27 +-
.../cli/commands/autorecovery/ToggleCommand.java | 17 +-
.../commands/autorecovery/WhoIsAuditorCommand.java | 9 +-
.../bookie/CheckDBLedgersIndexCommand.java | 12 +-
.../commands/bookie/ConvertToDBStorageCommand.java | 23 +-
.../bookie/ConvertToInterleavedStorageCommand.java | 17 +-
.../cli/commands/bookie/FlipBookieIdCommand.java | 25 +-
.../tools/cli/commands/bookie/FormatCommand.java | 4 -
.../tools/cli/commands/bookie/FormatUtil.java | 49 ++-
.../tools/cli/commands/bookie/LastMarkCommand.java | 13 +-
.../tools/cli/commands/bookie/LedgerCommand.java | 9 +-
.../commands/bookie/ListActiveLedgersCommand.java | 34 +-
.../commands/bookie/ListFilesOnDiscCommand.java | 21 +-
.../cli/commands/bookie/ListLedgersCommand.java | 22 +-
.../bookie/LocalConsistencyCheckCommand.java | 18 +-
.../cli/commands/bookie/ReadJournalCommand.java | 20 +-
.../cli/commands/bookie/ReadLedgerCommand.java | 33 +-
.../tools/cli/commands/bookie/ReadLogCommand.java | 51 ++-
.../commands/bookie/ReadLogMetadataCommand.java | 26 +-
.../RebuildDBLedgerLocationsIndexCommand.java | 10 +-
.../bookie/RebuildDBLedgersIndexCommand.java | 12 +-
...generateInterleavedStorageIndexFileCommand.java | 12 +-
.../cli/commands/bookie/SanityTestCommand.java | 46 ++-
.../bookie/UpdateBookieInLedgerCommand.java | 25 +-
.../cli/commands/bookies/ClusterInfoCommand.java | 13 +-
.../cli/commands/bookies/DecommissionCommand.java | 24 +-
.../cli/commands/bookies/EndpointInfoCommand.java | 37 +-
.../tools/cli/commands/bookies/InfoCommand.java | 28 +-
.../cli/commands/bookies/InstanceIdCommand.java | 12 +-
.../cli/commands/bookies/ListBookiesCommand.java | 17 +-
.../bookies/NukeExistingClusterCommand.java | 8 +-
.../tools/cli/commands/bookies/RecoverCommand.java | 53 +--
.../cli/commands/client/DeleteLedgerCommand.java | 7 +-
.../cli/commands/client/LedgerMetaDataCommand.java | 13 +-
.../cli/commands/client/SimpleTestCommand.java | 12 +-
.../tools/cli/commands/cookie/AdminCommand.java | 64 +--
.../tools/cli/commands/cookie/CookieCommand.java | 3 -
.../cli/commands/cookie/CreateCookieCommand.java | 2 -
.../cli/commands/cookie/DeleteCookieCommand.java | 2 -
.../cli/commands/cookie/GenerateCookieCommand.java | 2 -
.../cli/commands/cookie/GetCookieCommand.java | 2 -
.../cli/commands/cookie/UpdateCookieCommand.java | 2 -
.../health/SwitchOfHealthCheckCommand.java | 20 +-
.../tools/cli/helpers/ClientCommand.java | 6 +-
.../tools/cli/helpers/DiscoveryCommand.java | 6 +-
.../org/apache/bookkeeper/util/ByteBufList.java | 43 ++
.../org/apache/bookkeeper/util/DiskChecker.java | 20 +-
.../org/apache/bookkeeper/util/EntryFormatter.java | 12 +-
.../org/apache/bookkeeper/util/EventLoopUtil.java | 28 +-
.../java/org/apache/bookkeeper/util/HardLink.java | 9 +-
.../java/org/apache/bookkeeper/util/IOUtils.java | 9 +-
.../apache/bookkeeper/util/LedgerIdFormatter.java | 14 +-
.../apache/bookkeeper/util/LocalBookKeeper.java | 42 +-
.../bookkeeper/util/OrderedGenericCallback.java | 10 +-
.../org/apache/bookkeeper/util/PageCacheUtil.java | 13 +-
.../bookkeeper/util/StringEntryFormatter.java | 4 +-
.../org/apache/bookkeeper/util/StringUtils.java | 7 +-
.../org/apache/bookkeeper/util/SubTreeCache.java | 5 +-
.../java/org/apache/bookkeeper/util/ZkUtils.java | 13 +-
.../util/collections/ConcurrentLongHashMap.java | 109 ++---
.../zookeeper/CustomZooKeeperHostProvider.java | 12 +-
.../ExponentialBackOffWithDeadlinePolicy.java | 11 +-
.../bookkeeper/zookeeper/ZooKeeperClient.java | 32 +-
.../bookkeeper/zookeeper/ZooKeeperWatcherBase.java | 32 +-
.../org/apache/bookkeeper/zookeeper/ZooWorker.java | 16 +-
bookkeeper-server/src/main/resources/log4j2.xml | 2 +-
.../apache/bookkeeper/bookie/BookieImplTest.java | 12 +-
.../bookie/BookieInitializationTest.java | 9 +-
.../apache/bookkeeper/bookie/BookieShellTest.java | 41 ++
.../bookkeeper/bookie/BookieSocketAddressTest.java | 49 ++-
.../bookkeeper/bookie/BufferedChannelTest.java | 40 ++
.../bookie/GarbageCollectorThreadTest.java | 17 +-
.../bookie/storage/EntryLogTestUtils.java | 8 +-
.../directentrylogger/TestDirectEntryLogger.java | 26 +-
.../TestDirectEntryLoggerCompat.java | 24 +-
.../directentrylogger/TestDirectReader.java | 14 +-
.../directentrylogger/TestDirectWriter.java | 28 +-
.../storage/directentrylogger/TestEntryLogIds.java | 32 +-
.../storage/directentrylogger/TestMetadata.java | 4 +-
.../TestTransactionalEntryLogCompactor.java | 8 +-
.../bookie/storage/ldb/DbLedgerStorageTest.java | 240 +++++++++++
.../storage/ldb/KeyValueStorageRocksDBTest.java | 55 +++
.../client/BookKeeperConstructorFailureTest.java | 176 ++++++++
.../apache/bookkeeper/client/BookKeeperTest.java | 10 +
.../org/apache/bookkeeper/client/ClientUtil.java | 2 +-
.../apache/bookkeeper/client/MdcContextTest.java | 14 +-
.../bookkeeper/client/MockBookKeeperTestCase.java | 98 +++++
.../apache/bookkeeper/client/PendingAddOpTest.java | 110 +++++
.../bookkeeper/client/PendingWriteLacOpTest.java | 179 ++++++++
.../client/ReadLastConfirmedAndEntryOpTest.java | 4 +
.../bookkeeper/client/ReadLastConfirmedOpTest.java | 2 +-
.../apache/bookkeeper/client/TestBatchedRead.java | 110 +++++
.../client/TestGetBookieInfoTimeout.java | 10 +-
.../TestLedgerFragmentReplicationWithMock.java | 2 +-
.../client/TestSequenceReadWriteSetRecycle.java | 382 +++++++++++++++++
.../bookkeeper/client/api/BookKeeperApiTest.java | 148 +++++++
.../api/BookKeeperBuildersOpenLedgerTest.java | 5 +-
.../client/api/BookKeeperBuildersTest.java | 43 ++
.../bookkeeper/client/api/LedgerMetadataTest.java | 146 +++++++
.../bookkeeper/client/api/LoggerContextTest.java | 253 ++++++++++++
.../bookkeeper/client/api/OrderingKeyTest.java | 209 ++++++++++
.../proto/BatchedReadEntryProcessorTest.java | 173 +++++++-
.../bookkeeper/proto/BookieProtoEncodingTest.java | 89 ++--
.../proto/ForceLedgerProcessorV3Test.java | 19 +-
.../proto/GetBookieInfoProcessorV3Test.java | 19 +-
.../proto/LongPollReadEntryProcessorV3Test.java | 31 +-
.../apache/bookkeeper/proto/MockBookieClient.java | 36 +-
.../org/apache/bookkeeper/proto/MockBookies.java | 42 +-
.../apache/bookkeeper/proto/MockBookiesTest.java | 68 ++++
.../bookkeeper/proto/ReadEntryProcessorTest.java | 2 +
.../bookkeeper/proto/TestBackwardCompatCMS42.java | 39 +-
.../proto/TestBookieNettyServerTcpKeepalive.java | 187 +++++++++
.../proto/TestBookieRequestProcessor.java | 123 +++---
.../proto/TestPerChannelBookieClient.java | 16 +-
.../TestPerChannelBookieClientTcpKeepalive.java | 89 +++-
.../proto/WriteEntryProcessorV3Test.java | 29 +-
.../replication/BookieAutoRecoveryTest.java | 92 +++--
.../TestLedgerUnderreplicationManager.java | 17 +-
.../apache/bookkeeper/test/BookieClientTest.java | 99 ++++-
.../apache/bookkeeper/util/ByteBufListTest.java | 65 +++
.../org/apache/bookkeeper/util/LoggerOutput.java | 27 +-
.../collections/ConcurrentLongHashMapTest.java | 415 +++++++++++++++++--
.../src/test/resources/conf/default_rocksdb.conf | 18 +-
.../resources/conf/entry_location_rocksdb.conf | 30 +-
.../resources/conf/ledger_metadata_rocksdb.conf | 18 +-
bookkeeper-slogger/api/pom.xml | 27 --
.../apache/bookkeeper/slogger/AbstractSlogger.java | 275 -------------
.../apache/bookkeeper/slogger/ConsoleSlogger.java | 129 ------
.../org/apache/bookkeeper/slogger/NullSlogger.java | 63 ---
.../org/apache/bookkeeper/slogger/Sloggable.java | 27 --
.../bookkeeper/slogger/SloggableAccumulator.java | 27 --
.../org/apache/bookkeeper/slogger/Slogger.java | 47 ---
.../apache/bookkeeper/slogger/package-info.java | 23 --
.../apache/bookkeeper/slogger/ConcurrencyTest.java | 77 ----
.../bookkeeper/slogger/ConsoleSloggerTest.java | 39 --
.../org/apache/bookkeeper/slogger/MockSlogger.java | 87 ----
.../org/apache/bookkeeper/slogger/SloggerTest.java | 163 --------
bookkeeper-slogger/pom.xml | 49 ---
bookkeeper-slogger/slf4j/pom.xml | 34 --
.../bookkeeper/slogger/slf4j/Slf4jSlogger.java | 106 -----
.../bookkeeper/slogger/slf4j/package-info.java | 23 --
.../apache/bookkeeper/slogger/slf4j/Slf4jTest.java | 37 --
.../main/resources/bookkeeper/findbugsExclude.xml | 13 +-
.../scurrilous/circe/checksum/Java9IntHash.java | 74 +++-
.../circe/checksum/Java9IntHashTest.java | 46 +++
conf/default_rocksdb.conf.default | 18 +-
conf/entry_location_rocksdb.conf.default | 28 +-
conf/ledger_metadata_rocksdb.conf.default | 18 +-
conf/log4j2.cli.xml | 2 +-
conf/log4j2.otel-json.xml | 86 ++++
conf/log4j2.shell.xml | 2 +-
conf/log4j2.xml | 29 +-
conf/otel-log-template.json | 63 +++
.../common/util/affinity/impl/CpuAffinityImpl.java | 27 +-
.../util/affinity/impl/IsolatedProcessors.java | 9 +-
deploy/docker-compose/compose/values.yaml | 2 +-
deploy/docker-compose/docker-compose.yaml | 6 +-
dev/release/000-run-docker.sh | 2 +-
dev/release/Dockerfile | 21 +-
docker/Dockerfile | 2 +-
.../install-python-client.sh => lombok.config | 8 +-
metadata-drivers/etcd/pom.xml | 6 +-
.../io/etcd/jetcd/impl/EtcdConnectionManager.java | 8 +-
.../metadata/etcd/Etcd64bitIdGenerator.java | 8 +-
.../metadata/etcd/EtcdBookieRegister.java | 39 +-
.../metadata/etcd/EtcdLayoutManager.java | 9 +-
.../metadata/etcd/EtcdLedgerManager.java | 44 +-
.../metadata/etcd/EtcdMetadataBookieDriver.java | 4 +-
.../metadata/etcd/EtcdMetadataClientDriver.java | 4 +-
.../metadata/etcd/EtcdMetadataDriverBase.java | 14 +-
.../metadata/etcd/EtcdRegistrationClient.java | 2 -
.../metadata/etcd/EtcdRegistrationManager.java | 64 +--
.../bookkeeper/metadata/etcd/EtcdWatchClient.java | 6 +-
.../bookkeeper/metadata/etcd/EtcdWatcher.java | 10 +-
.../metadata/etcd/helpers/KeySetReader.java | 14 +-
.../metadata/etcd/helpers/KeyStream.java | 10 +-
.../metadata/etcd/helpers/ValueStream.java | 28 +-
metadata-drivers/jetcd-core-shaded/pom.xml | 15 +
...ava => SingleThreadExecutorQueueBenchmark.java} | 65 +--
.../apache/bookkeeper/proto/ProtocolBenchmark.java | 150 +++----
.../proto/checksum/DigestManagerBenchmark.java | 2 +-
.../proto/checksum/DigestTypeBenchmark.java | 2 +-
.../ConcurrentLongHashMapBenchmark.java | 431 ++++++++++++++++++++
.../{bookie => util/collections}/package-info.java | 2 +-
native-io/pom.xml | 281 +++++++------
native-io/src/main/assembly/assembly.xml | 62 ---
.../common/util/nativeio/NativeIOJni.java | 35 +-
.../common/util/nativeio/NativeIOLibraryPath.java | 124 ++++++
.../src/main/native-io-jni/cpp/native_io_jni.c | 325 ---------------
native-io/src/main/native-io-jni/rust/Cargo.lock | 301 ++++++++++++++
.../src/main/native-io-jni/rust/Cargo.toml | 33 +-
.../src/main/native-io-jni/rust/build.rs | 26 +-
native-io/src/main/native-io-jni/rust/src/lib.rs | 346 ++++++++++++++++
.../util/nativeio/NativeIOLibraryPathTest.java | 100 +++++
pom.xml | 147 +++----
shaded/bookkeeper-server-shaded/pom.xml | 16 +-
shaded/bookkeeper-server-tests-shaded/pom.xml | 16 +-
shaded/distributedlog-core-shaded/pom.xml | 16 +-
site3/website/docusaurus.config.js | 30 +-
site3/website/package.json | 5 +-
site3/website/scripts/build-website.sh | 3 -
site3/website/scripts/replace.js | 50 ---
.../src/pages/bps/BP-69-slog-structured-logging.md | 278 +++++++++++++
.../src/pages/community/bookkeeper-proposals.md | 3 +-
site3/website/src/pages/release-notes.md | 185 +++++++++
.../src/pages/{releases.md => releases.mdx} | 5 +
.../admin/autorecovery.md | 0
.../admin/bookies.md | 0
.../admin/decomission.md | 0
.../admin/geo-replication.md | 0
.../admin/http.md | 0
.../admin/metrics.md | 0
.../admin/perf.md | 0
.../admin/placement.md | 0
.../admin/upgrade.md | 0
.../api/distributedlog-api.md | 0
.../api/ledger-adv-api.md | 0
.../api/ledger-api.md | 8 +-
.../api/overview.md | 0
.../deployment/kubernetes.md | 0
.../deployment/manual.md | 0
.../development/codebase.md | 0
.../development/protocol.md | 0
.../getting-started/concepts.md | 0
.../getting-started/installation.md | 0
.../getting-started/run-locally.md | 0
.../overview/overview.md | 6 +-
.../reference/cli.md | 0
.../reference/config.md | 0
.../security/overview.md | 0
.../security/sasl.md | 0
.../security/tls.md | 0
.../security/zookeeper.md | 0
...-sidebars.json => version-4.17.4-sidebars.json} | 0
site3/website/versions.json | 2 +-
site3/website/yarn.lock | 111 +----
.../apache/bookkeeper/stats/AlertStatsLogger.java | 8 +-
.../java/org/apache/bookkeeper/stats/Stats.java | 28 +-
.../apache/bookkeeper/stats/ThreadRegistry.java | 10 +-
.../stats/codahale/CodahaleMetricsProvider.java | 13 +-
.../otel-metrics-provider/pom.xml | 2 +-
.../bookkeeper/stats/otel/OtelMetricsProvider.java | 35 +-
.../prometheus-metrics-provider/pom.xml | 4 +-
.../prometheus/DataSketchesOpStatsLogger.java | 33 +-
.../prometheus/PrometheusMetricsProvider.java | 16 +-
.../ThreadScopedDataSketchesStatsLogger.java | 26 +-
.../bookkeeper/stats/utils/StatsDocGenerator.java | 21 +-
.../BKRegistrationNameResolverProvider.java | 15 +-
.../clients/SimpleStorageClientImpl.java | 18 +-
.../bookkeeper/clients/StorageClientImpl.java | 14 +-
.../admin/SimpleStorageAdminClientImpl.java | 5 +-
.../clients/admin/StorageAdminClientImpl.java | 12 +-
.../bookkeeper/clients/StorageClientImplTest.java | 82 ++--
.../clients/admin/TestStorageAdminClientImpl.java | 40 +-
stream/clients/java/base/pom.xml | 14 +
.../clients/grpc/MetaRangeServiceFutureStub.java | 56 +++
.../clients/grpc/RootRangeServiceFutureStub.java | 96 +++++
.../grpc/StorageContainerServiceFutureStub.java | 57 +++
.../clients/grpc/TableServiceFutureStub.java | 88 ++++
.../bookkeeper/clients/grpc}/package-info.java | 6 +-
.../clients/impl/channel/StorageServerChannel.java | 20 +-
.../impl/channel/StorageServerChannelManager.java | 32 +-
.../impl/container/StorageContainerChannel.java | 22 +-
.../StorageContainerClientInterceptor.java | 23 +-
.../impl/container/StorageContainerManager.java | 7 +-
.../clients/impl/internal/LocationClientImpl.java | 11 +-
.../clients/impl/internal/MetaRangeClientImpl.java | 4 +-
.../clients/impl/internal/RootRangeClientImpl.java | 6 +-
.../internal/RootRangeClientImplWithRetries.java | 6 +-
.../internal/StorageServerClientManagerImpl.java | 4 +-
.../clients/impl/routing/RangeRouter.java | 4 +-
.../bookkeeper/clients/utils/GrpcChannels.java | 4 +-
.../utils/ListenableFutureRpcProcessor.java | 4 +-
.../apache/bookkeeper/clients/utils/NetUtils.java | 5 +-
.../clients/grpc/GrpcClientTestBase.java | 24 +-
.../channel/TestStorageServerChannelManager.java | 15 +-
.../container/TestStorageContainerChannel.java | 115 ++----
.../impl/container/TestStorageContainerInfo.java | 5 +-
.../container/TestStorageContainerManager.java | 10 +-
.../impl/internal/RootRangeClientImplTestBase.java | 15 +-
.../RootRangeClientImplWithRetriesTest.java | 8 +-
.../impl/internal/TestLocationClientImpl.java | 33 +-
.../impl/internal/TestMetaRangeClientImpl.java | 67 ++-
.../impl/internal/TestProtocolInternalUtils.java | 98 ++---
.../TestRootRangeClientCreateNamespaceRpc.java | 35 +-
.../TestRootRangeClientCreateStreamRpc.java | 27 +-
.../TestRootRangeClientDeleteNamespaceRpc.java | 12 +-
.../TestRootRangeClientDeleteStreamRpc.java | 12 +-
.../TestRootRangeClientGetNamespaceRpc.java | 35 +-
.../TestRootRangeClientGetStreamByIdRpc.java | 27 +-
.../internal/TestRootRangeClientGetStreamRpc.java | 27 +-
.../TestStorageServerClientManagerImpl.java | 33 +-
.../impl/internal/TestStreamMetadataCache.java | 16 +-
.../impl/internal/api/TestHashStreamRanges.java | 5 +-
.../impl/internal/api/TestStreamRanges.java | 25 +-
.../apache/bookkeeper/clients/impl/kv/KvUtils.java | 142 +++----
.../clients/impl/kv/PByteBufSimpleTableImpl.java | 159 +++++---
.../clients/impl/kv/PByteBufTableImpl.java | 14 +-
.../clients/impl/kv/PByteBufTableRangeImpl.java | 100 +++--
.../clients/impl/kv/TxnRequestProcessor.java | 15 +-
.../impl/kv/DeleteRequestProcessorTest.java | 15 +-
.../impl/kv/IncrementRequestProcessorTest.java | 15 +-
.../impl/kv/PByteBufSimpleTableImplTest.java | 166 ++++++++
.../clients/impl/kv/PutRequestProcessorTest.java | 15 +-
.../clients/impl/kv/RangeRequestProcessorTest.java | 15 +-
.../bookkeeper/clients/impl/kv/TestKvUtils.java | 40 +-
.../clients/impl/kv/TestPByteBufTableImpl.java | 16 +-
.../clients/impl/kv/TxnRequestProcessorTest.java | 96 ++++-
stream/common/pom.xml | 21 +-
.../resolver/ServiceNameResolverProvider.java | 10 +-
.../common/util/AbstractAutoAsyncCloseable.java | 4 +-
.../common/grpc/proxy/PingPongServiceTestBase.java | 20 +-
.../grpc/stats/GrpcStatsIntegrationTest.java | 20 +-
.../bookkeeper/common/router/HashRouterTest.java | 13 +-
stream/conf/log4j2.cli.xml | 6 +-
stream/conf/log4j2.xml | 6 +-
.../common/config/ConfigurationSubscription.java | 27 +-
.../distributedlog/common/util/SchedulerUtils.java | 6 +-
.../org/apache/distributedlog/io/Abortables.java | 16 +-
.../common/config/PropertiesWriter.java | 9 +-
.../config/TestConfigurationSubscription.java | 7 +-
.../distributedlog/AppendOnlyStreamReader.java | 26 +-
.../distributedlog/AppendOnlyStreamWriter.java | 11 +-
.../apache/distributedlog/BKAbstractLogWriter.java | 53 +--
.../apache/distributedlog/BKAsyncLogReader.java | 63 +--
.../apache/distributedlog/BKAsyncLogWriter.java | 6 +-
.../distributedlog/BKDistributedLogManager.java | 29 +-
.../distributedlog/BKDistributedLogNamespace.java | 9 +-
.../org/apache/distributedlog/BKLogHandler.java | 29 +-
.../apache/distributedlog/BKLogReadHandler.java | 21 +-
.../apache/distributedlog/BKLogSegmentWriter.java | 124 +++---
.../apache/distributedlog/BKLogWriteHandler.java | 138 ++++---
.../org/apache/distributedlog/BKSyncLogWriter.java | 14 +-
.../apache/distributedlog/BookKeeperClient.java | 48 +--
.../DistributedLogConfiguration.java | 13 +-
.../distributedlog/EnvelopedEntryWriter.java | 9 +-
.../apache/distributedlog/LocalDLMEmulator.java | 37 +-
.../apache/distributedlog/LogSegmentMetadata.java | 24 +-
.../java/org/apache/distributedlog/MaxTxId.java | 7 +-
.../distributedlog/ReadAheadEntryReader.java | 114 +++---
.../java/org/apache/distributedlog/ReadUtils.java | 68 ++--
.../org/apache/distributedlog/ZooKeeperClient.java | 37 +-
.../distributedlog/ZooKeeperClientBuilder.java | 7 +-
.../distributedlog/admin/DistributedLogAdmin.java | 22 +-
.../api/namespace/NamespaceBuilder.java | 8 +-
.../apache/distributedlog/auditor/DLAuditor.java | 79 ++--
.../distributedlog/bk/LedgerAllocatorPool.java | 39 +-
.../org/apache/distributedlog/bk/QuorumConfig.java | 18 +-
.../distributedlog/bk/SimpleLedgerAllocator.java | 84 ++--
.../config/DynamicConfigurationFactory.java | 7 +-
.../feature/AbstractFeatureProvider.java | 8 +-
.../feature/ConfigurationFeatureProvider.java | 12 +-
.../DynamicConfigurationFeatureProvider.java | 12 +-
.../distributedlog/impl/BKNamespaceDriver.java | 78 ++--
.../distributedlog/impl/ZKLogSegmentFilters.java | 22 +-
.../impl/ZKLogSegmentMetadataStore.java | 18 +-
.../distributedlog/impl/ZKMetadataAccessor.java | 24 +-
.../distributedlog/impl/ZKNamespaceWatcher.java | 20 +-
.../impl/acl/ZKAccessControlManager.java | 73 ++--
.../federated/FederatedZKLogMetadataStore.java | 46 ++-
.../impl/logsegment/BKLogSegmentEntryReader.java | 12 +-
.../impl/logsegment/BKLogSegmentEntryStore.java | 21 +-
.../distributedlog/impl/metadata/BKDLConfig.java | 20 +-
.../impl/metadata/ZKLogStreamMetadataStore.java | 60 +--
.../subscription/ZKSubscriptionStateStore.java | 13 +-
.../injector/RandomDelayFailureInjector.java | 8 +-
.../limiter/ComposableRequestLimiter.java | 5 +-
.../org/apache/distributedlog/lock/LockWaiter.java | 10 +-
.../distributedlog/lock/ZKDistributedLock.java | 22 +-
.../apache/distributedlog/lock/ZKSessionLock.java | 233 +++++++----
.../logsegment/LogSegmentMetadataCache.java | 14 +-
.../logsegment/PerStreamLogSegmentCache.java | 37 +-
.../logsegment/TimeBasedRollingPolicy.java | 14 +-
.../apache/distributedlog/metadata/DLMetadata.java | 17 +-
.../metadata/LogSegmentMetadataStoreUpdater.java | 11 +-
.../namespace/NamespaceDriverManager.java | 14 +-
.../org/apache/distributedlog/net/DNSResolver.java | 9 +-
.../distributedlog/tools/DistributedLogTool.java | 13 +-
.../apache/distributedlog/util/FailpointUtils.java | 7 +-
.../java/org/apache/distributedlog/util/Utils.java | 9 +-
.../distributedlog/zk/LimitedPermitManager.java | 18 +-
.../apache/distributedlog/zk/ZKWatcherManager.java | 27 +-
.../org/apache/distributedlog/DLMTestUtil.java | 16 +-
.../distributedlog/NonBlockingReadsTestUtil.java | 21 +-
.../distributedlog/TestAppendOnlyStreamReader.java | 6 +-
.../distributedlog/TestAppendOnlyStreamWriter.java | 9 +-
.../apache/distributedlog/TestAsyncBulkWrite.java | 10 +-
.../apache/distributedlog/TestAsyncReaderLock.java | 20 +-
.../distributedlog/TestAsyncReaderWriter.java | 76 ++--
.../TestBKDistributedLogManager.java | 42 +-
.../TestBKDistributedLogNamespace.java | 16 +-
.../distributedlog/TestBKLogReadHandler.java | 7 +-
.../distributedlog/TestBKLogSegmentWriter.java | 4 +-
.../distributedlog/TestBKLogWriteHandler.java | 8 +-
.../apache/distributedlog/TestBKSyncLogReader.java | 18 +-
.../apache/distributedlog/TestCancelledRead.java | 5 +-
.../org/apache/distributedlog/TestDLMTestUtil.java | 5 +-
.../distributedlog/TestDistributedLogBase.java | 19 +-
.../distributedlog/TestInterleavedReaders.java | 21 +-
.../distributedlog/TestLogSegmentCreation.java | 13 +-
.../distributedlog/TestLogSegmentMetadata.java | 10 +-
.../apache/distributedlog/TestLogSegmentsZK.java | 5 +-
.../distributedlog/TestNonBlockingReads.java | 10 +-
.../TestNonBlockingReadsMultiReader.java | 25 +-
.../org/apache/distributedlog/TestReadUtils.java | 7 +-
.../java/org/apache/distributedlog/TestReader.java | 33 +-
.../apache/distributedlog/TestRollLogSegments.java | 47 ++-
.../org/apache/distributedlog/TestSequenceID.java | 9 +-
.../org/apache/distributedlog/TestTruncate.java | 21 +-
.../java/org/apache/distributedlog/TestTxnId.java | 7 +-
.../apache/distributedlog/TestWriteLimiter.java | 6 +-
.../apache/distributedlog/TestZooKeeperClient.java | 11 +-
.../distributedlog/ZooKeeperClientUtils.java | 10 +-
.../distributedlog/ZooKeeperClusterTestCase.java | 8 +-
.../acl/TestZKAccessControlManager.java | 26 +-
.../org/apache/distributedlog/admin/TestDLCK.java | 14 +-
.../admin/TestDistributedLogAdmin.java | 14 +-
.../distributedlog/bk/TestLedgerAllocator.java | 10 +-
.../distributedlog/bk/TestLedgerAllocatorPool.java | 16 +-
.../distributedlog/config/PropertiesWriter.java | 9 +-
.../config/TestDynamicConfigurationFactory.java | 6 +-
.../impl/TestZKLogSegmentFilters.java | 13 +-
.../impl/TestZKLogSegmentMetadataStore.java | 22 +-
.../metadata/TestZKLogStreamMetadataStore.java | 8 +-
.../distributedlog/lock/TestDistributedLock.java | 18 +-
.../distributedlog/lock/TestZKSessionLock.java | 18 +-
.../TestLogSegmentMetadataStoreUpdater.java | 14 +-
.../tools/TestDistributedLogTool.java | 7 +-
.../org/apache/distributedlog/fs/DLFileSystem.java | 13 +-
.../apache/distributedlog/fs/DLInputStream.java | 4 +-
.../apache/distributedlog/fs/DLOutputStream.java | 6 +-
.../apache/distributedlog/fs/TestDLFileSystem.java | 4 +-
.../distributedlog/EnvelopedRecordSetReader.java | 4 +-
.../distributedlog/EnvelopedRecordSetWriter.java | 4 +-
.../java/org/apache/distributedlog/LogRecord.java | 42 +-
.../apache/distributedlog/TestLogRecordSet.java | 4 +-
stream/proto/pom.xml | 42 +-
.../stream/protocol/ProtocolConstants.java | 62 +--
.../stream/protocol/util/ProtoUtils.java | 89 ++--
.../stream/protocol/util/TestProtoUtils.java | 10 +-
.../stream/cluster/StandaloneStarter.java | 6 +-
.../bookkeeper/stream/cluster/StreamCluster.java | 66 ++-
.../bookkeeper/stream/server/StorageServer.java | 49 ++-
.../bookkeeper/stream/server/grpc/GrpcServer.java | 6 +-
.../server/grpc/GrpcStorageContainerService.java | 28 +-
.../stream/server/service/BookieService.java | 10 +-
.../stream/server/service/BookieWatchService.java | 16 +-
.../server/service/ClusterControllerService.java | 4 +-
.../server/service/CuratorProviderService.java | 8 +-
.../server/service/DLNamespaceProviderService.java | 27 +-
.../service/RegistrationServiceProvider.java | 19 +-
.../server/service/RegistrationStateService.java | 10 +-
.../stream/server/service/StorageService.java | 4 +-
stream/statelib/pom.xml | 30 +-
.../apache/bookkeeper/statelib/StateStores.java | 4 +-
.../org/apache/bookkeeper/statelib/impl/Bytes.java | 19 -
.../journal/AbstractStateStoreWithJournal.java | 74 ++--
.../statelib/impl/kv/KVCommandProcessor.java | 20 +-
.../bookkeeper/statelib/impl/kv/KVUtils.java | 56 +--
.../statelib/impl/kv/RocksdbKVAsyncStore.java | 18 +-
.../statelib/impl/kv/RocksdbKVStore.java | 25 +-
.../impl/mvcc/MVCCAsyncBytesStoreImpl.java | 4 +-
.../statelib/impl/mvcc/MVCCCommandProcessor.java | 12 +-
.../statelib/impl/mvcc/MVCCRecordCoder.java | 41 +-
.../statelib/impl/mvcc/MVCCStoreImpl.java | 8 +-
.../bookkeeper/statelib/impl/mvcc/MVCCUtils.java | 133 +++---
.../impl/mvcc/op/proto/ProtoCompareImpl.java | 11 +-
.../impl/mvcc/op/proto/ProtoDeleteOpImpl.java | 13 +-
.../impl/mvcc/op/proto/ProtoIncrementOpImpl.java | 4 +-
.../impl/mvcc/op/proto/ProtoPutOpImpl.java | 6 +-
.../impl/mvcc/op/proto/ProtoRangeOpImpl.java | 13 +-
.../impl/mvcc/op/proto/ProtoTxnOpImpl.java | 6 +-
.../impl/rocksdb/checkpoint/CheckpointFile.java | 26 +-
.../impl/rocksdb/checkpoint/CheckpointInfo.java | 19 +-
.../impl/rocksdb/checkpoint/RocksCheckpointer.java | 18 +-
.../rocksdb/checkpoint/RocksdbCheckpointTask.java | 31 +-
.../rocksdb/checkpoint/RocksdbRestoreTask.java | 10 +-
.../rocksdb/checkpoint/dlog/DLCheckpointStore.java | 6 +-
.../rocksdb/checkpoint/dlog/DLInputStream.java | 4 +-
.../rocksdb/checkpoint/dlog/DLOutputStream.java | 6 +-
.../statelib/impl/kv/TestRocksdbKVAsyncStore.java | 4 +-
.../kv/TestRocksdbKVAsyncStoreWithCheckpoints.java | 4 +-
.../impl/kv/TestRocksdbKVStoreCheckpoint.java | 4 +-
.../statelib/impl/kv/TestStateStore.java | 4 +-
.../impl/mvcc/TestMVCCAsyncBytesStoreImpl.java | 10 +-
.../statelib/impl/mvcc/TestMVCCStoreImpl.java | 4 +-
.../impl/mvcc/op/proto/ProtoCompareImplTest.java | 30 +-
.../rocksdb/checkpoint/RocksCheckpointerTest.java | 15 +-
.../testing/executors/MockExecutorController.java | 6 +-
.../impl/cluster/ClusterControllerLeaderImpl.java | 16 +-
.../impl/cluster/InMemClusterMetadataStore.java | 6 +-
.../cluster/ZkClusterControllerLeaderSelector.java | 4 +-
.../ZkClusterControllerLeaderSelectorListener.java | 6 +-
.../storage/impl/cluster/ZkClusterInitializer.java | 16 +-
.../impl/cluster/ZkClusterMetadataStore.java | 44 +-
.../storage/impl/grpc/GrpcMetaRangeService.java | 9 +-
.../storage/impl/grpc/GrpcRootRangeService.java | 30 +-
.../stream/storage/impl/grpc/GrpcTableService.java | 59 ++-
.../stream/storage/impl/kv/TableStoreImpl.java | 116 +++---
.../stream/storage/impl/kv/TableStoreUtils.java | 147 ++++---
.../impl/metadata/CreateNamespaceProcessor.java | 5 +-
.../impl/metadata/DeleteNamespaceProcessor.java | 5 +-
.../storage/impl/metadata/MetaRangeStoreImpl.java | 34 +-
.../storage/impl/metadata/RootRangeStoreImpl.java | 165 ++++----
.../impl/metadata/stream/MetaRangeImpl.java | 89 ++--
.../impl/routing/RangeRoutingTableImpl.java | 4 +-
.../routing/RoutingHeaderProxyInterceptor.java | 214 +++++++---
.../impl/sc/DefaultStorageContainerController.java | 81 ++--
.../storage/impl/sc/StorageContainerImpl.java | 15 +-
.../impl/sc/StorageContainerRegistryImpl.java | 23 +-
.../storage/impl/sc/ZkStorageContainerManager.java | 95 +++--
.../impl/service/RangeStoreServiceImpl.java | 59 ++-
.../storage/impl/store/MVCCStoreFactoryImpl.java | 38 +-
.../impl/TestStorageContainerStoreImpl.java | 240 ++++++-----
.../cluster/ClusterControllerLeaderImplTest.java | 6 +-
.../cluster/InMemClusterMetadataStoreTest.java | 48 +--
.../ZkClusterControllerLeaderSelectorTest.java | 8 +-
.../impl/cluster/ZkClusterMetadataStoreTest.java | 44 +-
.../impl/grpc/TestGrpcMetaRangeService.java | 28 +-
.../impl/grpc/TestGrpcRootRangeService.java | 206 +++++-----
.../storage/impl/grpc/TestGrpcTableService.java | 165 ++++----
.../stream/storage/impl/kv/TableStoreImplTest.java | 309 +++++++-------
.../storage/impl/kv/TableStoreUtilsTest.java | 30 +-
.../impl/metadata/MetaRangeStoreImplTest.java | 16 +-
.../impl/metadata/TestRootRangeStoreImpl.java | 25 +-
.../impl/metadata/stream/TestMetaRangeImpl.java | 14 +-
.../impl/routing/RangeRoutingTableImplTest.java | 31 +-
.../routing/RoutingHeaderProxyInterceptorTest.java | 177 ++++----
...torageContainerProxyChannelManagerImplTest.java | 19 +-
.../sc/DefaultStorageContainerControllerTest.java | 62 +--
.../impl/sc/ZkStorageContainerManagerTest.java | 44 +-
.../impl/service/RangeStoreServiceImplTest.java | 102 ++---
.../impl/store/MVCCStoreFactoryImplTest.java | 11 +-
stream/tests-common/pom.xml | 40 +-
.../bookkeeper/tests/rpc/PingPongService.java | 26 +-
.../main/proto/proto2_coder_test_messages.proto | 53 ---
.../tests/containers/BKStandaloneContainer.java | 8 +-
.../tests/containers/BookieContainer.java | 14 +-
.../tests/containers/ChaosContainer.java | 26 +-
.../bookkeeper/tests/containers/ZKContainer.java | 11 +-
.../tests/containers/wait/HttpWaitStrategy.java | 10 +-
.../3-node-all-version-unstarted.yaml | 2 +-
.../integration/utils/BookKeeperClusterUtils.java | 20 +-
.../tests/integration/utils/DockerUtils.java | 53 ++-
.../tests/integration/utils/MavenClassLoader.java | 8 +-
.../tests/integration/utils/ThreadReaper.java | 13 +-
.../integration/utils/ZooKeeperAwaitStrategy.java | 6 +-
.../integration/stream/LocationClientTest.java | 4 +-
.../integration/stream/StorageAdminClientTest.java | 13 +-
.../integration/stream/TableClientSimpleTest.java | 21 +-
.../tests/integration/stream/TableClientTest.java | 10 +-
.../shaded/BookKeeperServerShadedJarTest.java | 10 +-
.../shaded/DistributedLogCoreShadedJarTest.java | 12 +-
.../apache/bookkeeper/tools/common/BKCommand.java | 15 +-
.../org/apache/bookkeeper/tools/framework/Cli.java | 4 +-
.../org/apache/bookkeeper/tools/cli/BKCtl.java | 4 +-
.../org/apache/bookkeeper/tools/perf/BKPerf.java | 4 +-
.../bookkeeper/tools/perf/dlog/PerfReader.java | 20 +-
.../bookkeeper/tools/perf/dlog/PerfReaderBase.java | 62 +--
.../tools/perf/dlog/PerfSegmentReader.java | 22 +-
.../bookkeeper/tools/perf/dlog/PerfWriter.java | 74 ++--
.../bookkeeper/tools/perf/dlog/ReadCommand.java | 4 +-
.../tools/perf/dlog/SegmentReadCommand.java | 4 +-
.../bookkeeper/tools/perf/dlog/WriteCommand.java | 4 +-
.../tools/perf/journal/AppendCommand.java | 4 +-
.../tools/perf/journal/JournalWriter.java | 90 +++--
.../tools/perf/table/BenchmarkCommand.java | 4 +-
.../bookkeeper/tools/perf/table/IncrementTask.java | 6 +-
.../bookkeeper/tools/perf/table/PerfClient.java | 61 +--
.../bookkeeper/tools/perf/table/WriteTask.java | 6 +-
.../stream/cli/commands/AbstractStreamCommand.java | 8 +-
.../stream/cli/commands/AdminCommand.java | 6 +-
.../stream/cli/commands/ClientCommand.java | 10 +-
.../cli/commands/cluster/InitClusterCommand.java | 34 +-
.../commands/namespace/CreateNamespaceCommand.java | 9 +-
.../cli/commands/table/CreateTableCommand.java | 11 +-
871 files changed, 20918 insertions(+), 15092 deletions(-)
copy .github/actions/{copy-test-reports => setup-native-build}/action.yml (60%)
copy
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/collections/{BatchedArrayBlockingQueue.java
=> GrowableBatchedArrayBlockingQueue.java} (63%)
delete mode 100644
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/collections/GrowableMpScArrayConsumerBlockingQueue.java
delete mode 100644
bookkeeper-common/src/test/java/org/apache/bookkeeper/common/collections/GrowableArrayBlockingQueueTest.java
create mode 100644
bookkeeper-common/src/test/java/org/apache/bookkeeper/common/collections/GrowableBatchedArrayBlockingQueueTest.java
delete mode 100644
bookkeeper-dist/src/main/resources/deps/google-auth-library-credentials-0.20.0/LICENSE
delete mode 100644
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/directentrylogger/Events.java
delete mode 100644
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/ByteStringUtil.java
create mode 100644
bookkeeper-server/src/test/java/org/apache/bookkeeper/client/BookKeeperConstructorFailureTest.java
create mode 100644
bookkeeper-server/src/test/java/org/apache/bookkeeper/client/PendingWriteLacOpTest.java
create mode 100644
bookkeeper-server/src/test/java/org/apache/bookkeeper/client/TestSequenceReadWriteSetRecycle.java
create mode 100644
bookkeeper-server/src/test/java/org/apache/bookkeeper/client/api/LoggerContextTest.java
create mode 100644
bookkeeper-server/src/test/java/org/apache/bookkeeper/client/api/OrderingKeyTest.java
create mode 100644
bookkeeper-server/src/test/java/org/apache/bookkeeper/proto/MockBookiesTest.java
create mode 100644
bookkeeper-server/src/test/java/org/apache/bookkeeper/proto/TestBookieNettyServerTcpKeepalive.java
delete mode 100644 bookkeeper-slogger/api/pom.xml
delete mode 100644
bookkeeper-slogger/api/src/main/java/org/apache/bookkeeper/slogger/AbstractSlogger.java
delete mode 100644
bookkeeper-slogger/api/src/main/java/org/apache/bookkeeper/slogger/ConsoleSlogger.java
delete mode 100644
bookkeeper-slogger/api/src/main/java/org/apache/bookkeeper/slogger/NullSlogger.java
delete mode 100644
bookkeeper-slogger/api/src/main/java/org/apache/bookkeeper/slogger/Sloggable.java
delete mode 100644
bookkeeper-slogger/api/src/main/java/org/apache/bookkeeper/slogger/SloggableAccumulator.java
delete mode 100644
bookkeeper-slogger/api/src/main/java/org/apache/bookkeeper/slogger/Slogger.java
delete mode 100644
bookkeeper-slogger/api/src/main/java/org/apache/bookkeeper/slogger/package-info.java
delete mode 100644
bookkeeper-slogger/api/src/test/java/org/apache/bookkeeper/slogger/ConcurrencyTest.java
delete mode 100644
bookkeeper-slogger/api/src/test/java/org/apache/bookkeeper/slogger/ConsoleSloggerTest.java
delete mode 100644
bookkeeper-slogger/api/src/test/java/org/apache/bookkeeper/slogger/MockSlogger.java
delete mode 100644
bookkeeper-slogger/api/src/test/java/org/apache/bookkeeper/slogger/SloggerTest.java
delete mode 100644 bookkeeper-slogger/pom.xml
delete mode 100644 bookkeeper-slogger/slf4j/pom.xml
delete mode 100644
bookkeeper-slogger/slf4j/src/main/java/org/apache/bookkeeper/slogger/slf4j/Slf4jSlogger.java
delete mode 100644
bookkeeper-slogger/slf4j/src/main/java/org/apache/bookkeeper/slogger/slf4j/package-info.java
delete mode 100644
bookkeeper-slogger/slf4j/src/test/java/org/apache/bookkeeper/slogger/slf4j/Slf4jTest.java
create mode 100644 conf/log4j2.otel-json.xml
create mode 100644 conf/otel-log-template.json
copy
tests/docker-images/current-version-image/scripts/install-python-client.sh =>
lombok.config (75%)
copy
microbenchmarks/src/main/java/org/apache/bookkeeper/common/{MpScQueueBenchmark.java
=> SingleThreadExecutorQueueBenchmark.java} (57%)
create mode 100644
microbenchmarks/src/main/java/org/apache/bookkeeper/util/collections/ConcurrentLongHashMapBenchmark.java
copy microbenchmarks/src/main/java/org/apache/bookkeeper/{bookie =>
util/collections}/package-info.java (94%)
delete mode 100644 native-io/src/main/assembly/assembly.xml
create mode 100644
native-io/src/main/java/org/apache/bookkeeper/common/util/nativeio/NativeIOLibraryPath.java
delete mode 100644 native-io/src/main/native-io-jni/cpp/native_io_jni.c
create mode 100644 native-io/src/main/native-io-jni/rust/Cargo.lock
copy .test-infra/scripts/slack-email-digest/configuration-example.yaml =>
native-io/src/main/native-io-jni/rust/Cargo.toml (68%)
copy
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util/MdcUtils.java
=> native-io/src/main/native-io-jni/rust/build.rs (57%)
create mode 100644 native-io/src/main/native-io-jni/rust/src/lib.rs
create mode 100644
native-io/src/test/java/org/apache/bookkeeper/common/util/nativeio/NativeIOLibraryPathTest.java
delete mode 100755 site3/website/scripts/replace.js
create mode 100644 site3/website/src/pages/bps/BP-69-slog-structured-logging.md
rename site3/website/src/pages/{releases.md => releases.mdx} (98%)
rename site3/website/versioned_docs/{version-4.17.3 =>
version-4.17.4}/admin/autorecovery.md (100%)
rename site3/website/versioned_docs/{version-4.17.3 =>
version-4.17.4}/admin/bookies.md (100%)
rename site3/website/versioned_docs/{version-4.17.3 =>
version-4.17.4}/admin/decomission.md (100%)
rename site3/website/versioned_docs/{version-4.17.3 =>
version-4.17.4}/admin/geo-replication.md (100%)
rename site3/website/versioned_docs/{version-4.17.3 =>
version-4.17.4}/admin/http.md (100%)
rename site3/website/versioned_docs/{version-4.17.3 =>
version-4.17.4}/admin/metrics.md (100%)
rename site3/website/versioned_docs/{version-4.17.3 =>
version-4.17.4}/admin/perf.md (100%)
rename site3/website/versioned_docs/{version-4.17.3 =>
version-4.17.4}/admin/placement.md (100%)
rename site3/website/versioned_docs/{version-4.17.3 =>
version-4.17.4}/admin/upgrade.md (100%)
rename site3/website/versioned_docs/{version-4.17.3 =>
version-4.17.4}/api/distributedlog-api.md (100%)
rename site3/website/versioned_docs/{version-4.17.3 =>
version-4.17.4}/api/ledger-adv-api.md (100%)
rename site3/website/versioned_docs/{version-4.17.3 =>
version-4.17.4}/api/ledger-api.md (99%)
rename site3/website/versioned_docs/{version-4.17.3 =>
version-4.17.4}/api/overview.md (100%)
rename site3/website/versioned_docs/{version-4.17.3 =>
version-4.17.4}/deployment/kubernetes.md (100%)
rename site3/website/versioned_docs/{version-4.17.3 =>
version-4.17.4}/deployment/manual.md (100%)
rename site3/website/versioned_docs/{version-4.17.3 =>
version-4.17.4}/development/codebase.md (100%)
rename site3/website/versioned_docs/{version-4.17.3 =>
version-4.17.4}/development/protocol.md (100%)
rename site3/website/versioned_docs/{version-4.17.3 =>
version-4.17.4}/getting-started/concepts.md (100%)
rename site3/website/versioned_docs/{version-4.17.3 =>
version-4.17.4}/getting-started/installation.md (100%)
rename site3/website/versioned_docs/{version-4.17.3 =>
version-4.17.4}/getting-started/run-locally.md (100%)
rename site3/website/versioned_docs/{version-4.17.3 =>
version-4.17.4}/overview/overview.md (97%)
rename site3/website/versioned_docs/{version-4.17.3 =>
version-4.17.4}/reference/cli.md (100%)
rename site3/website/versioned_docs/{version-4.17.3 =>
version-4.17.4}/reference/config.md (100%)
rename site3/website/versioned_docs/{version-4.17.3 =>
version-4.17.4}/security/overview.md (100%)
rename site3/website/versioned_docs/{version-4.17.3 =>
version-4.17.4}/security/sasl.md (100%)
rename site3/website/versioned_docs/{version-4.17.3 =>
version-4.17.4}/security/tls.md (100%)
rename site3/website/versioned_docs/{version-4.17.3 =>
version-4.17.4}/security/zookeeper.md (100%)
rename site3/website/versioned_sidebars/{version-4.17.3-sidebars.json =>
version-4.17.4-sidebars.json} (100%)
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/grpc/MetaRangeServiceFutureStub.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/grpc/RootRangeServiceFutureStub.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/grpc/StorageContainerServiceFutureStub.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/grpc/TableServiceFutureStub.java
copy {bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util =>
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/grpc}/package-info.java
(76%)
create mode 100644
stream/clients/java/kv/src/test/java/org/apache/bookkeeper/clients/impl/kv/PByteBufSimpleTableImplTest.java
delete mode 100644
stream/tests-common/src/main/proto/proto2_coder_test_messages.proto
