This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch dependabot/maven/org.jsoup-jsoup-1.15.3
in repository https://gitbox.apache.org/repos/asf/bookkeeper.git
omit e13ff02910 Bump jsoup from 1.14.3 to 1.15.3
add 73294ce00f Fixed back API of Crc32cIntChecksum (#3826)
add 3dcd8d5869 Remove callback threadpool for sending add responses (#3825)
add 7852db6059 remove unused 'close ledger manager' comment (#3827)
add 227b166018 Support build in the aarch64 linux platform (#3828)
add 20aad8006e Avoid using thread-local WriteSet when possible (#3829)
add b4112dfdbf Fix Spotbugs check failed (#3836)
add dfde3d6836 Pass BookieRequestHandler instead of Channel to the request
processors (#3835)
add 128c52eeff Simplified the logic for ForceWriteThread after we
introduced queue.drainTo() (#3830)
add 3199fbe4d6 Add directIO entry logger settings documents (#3789)
add 3844bf128c Make RrocksDB checksum type configurable (#3793)
add bf5a6aabb6 BP61: revert BP-59 to release ByteBuf using
ReferenceCountUtil.release() instead of ReferenceCountUtil.safeRelease() (#3796)
add 1bd1745742 fix website deploy build failed (#3841)
add 73c5a0e011 Added BatchedArrayBlockingQueue (#3838)
add 08c3138aeb Add num not adhering placement ledgers replicated metric
for ReplicationWorker (#3652)
add d6748f915d Group and flush add-responses after journal sync (#3837)
add 5703132316 Fix memory leak issue of reading small entries (#3844)
add 09365dfdd8 Make read entry request recyclable (#3842)
add f9313195f0 Avoid unnecessary force write. (#3847)
add caddb6ee5b Correct the running job name for the test group (#3851)
add 0a21dd5387 add timeout for two flaky timeout tests (#3855)
add 3a488150e9 add V2 protocal and warmupMessages support for benchMark
(#3856)
add cd43c91add disable trimStackTrack for code-coverage profile (#3854)
add 06c3cabde7 Fix bkperf log directory not found (#3858)
add 263d8cc32e [improve] Fix indexDirs upgrade failed (#3762)
add 1a8d84251b Bump checkstyle-plugin from 3.1.2 to 3.2.1 (#3850)
add caea6c9451 [Flaky] Fix flaky test in
testRaceGuavaEvictAndReleaseBeforeRetain (#3857)
add ebf3108d54 Fix NPE in BenchThroughputLatency (#3859)
add 0bc1785134 Update website to 4.15.4 (#3862)
add 5542afe6b6 change rocksDB config level_compaction_dynamic_level_bytes
to CFOptions (#3860)
add 8ea5590e78 Correct the running job flag for the test group. (#3865)
add ea04926a0a Release note for 4.15.4 (#3831)
add 0fa39b6236 Add trigger entry location index rocksDB compact interface.
(#3802)
add 915deb035b Pick the higher leak detection level between netty and
bookkeeper. (#3794)
add 8aee66a2f7 Disable code coverage and codecov report (#3863)
add 2fad33bfcf Add small files check in garbage collection (#3631)
add ed542b9636 [improvement] Delay all audit task when have a already
delayed bookie check task (#3818)
add a633ec4bd8 Change order of doGcLedgers and extractMetaFromEntryLogs
(#3869)
add c3e5bfe431 [Bugfix] make metadataDriver initialization more robust
(#3873)
add dda42a3a33 Enable CI for the streamstorage python client (#3875)
add e19cb9d822 Fix compaction threshold default value precision problem.
(#3871)
add 234b817cdb Single buffer for small add requests (#3783)
add b3aca10dea Add log for entry log file delete. (#3872)
add e3c24ae138 Improve group and flush add-responses after journal sync
(#3848)
add 9fe07bb1fd Add V2 protocol support for BenchReadThroughputLatency
(#3878)
add 97e3bb1962 Use BatchedArrayBlockingQueue in Journal (#3843)
add e3bfd80653 add branch-4.16 protection (#3883)
add 5deadcc241 Fix write entry failed in without writing journal case
(#3884)
add 8dede59332 Remove unused jenkins profile (#3885)
add cbd634dbe0 Bump javadoc-plugin from 3.1.1 to 3.2.0 (#3853)
add ee1424456b fix BookieWriteLedgerTest parameterized failed (#3890)
add e440132802 Optimize log4j dependency in Bookkeeper (#3892)
add 164417afc2 release ledgerHandler when no missing fragments in
checkAllLedgers (#3888)
add 0171a408e2 upgrade hadoop version to 3.3.5 to resolve CVE-2019-10202
(#3896)
add a6387d191f [Bookie] Prevent transit to writable mode when
forceReadOnly mode is active (#3881)
add 04e572b9bc Execute clean indexes in finally (#3772)
add f1657eaf4c [Bug] SingleDirectoryDbLedgerStorage#flushMutex does not
release lock on all exception paths (#3909)
add ceba60565c Fix keys leak in EntryLocationIndex when ledgersToDelete is
empty (#3903)
add f5455f0158 [feature] [server] add
dbStorage_readAheadCacheBatchBytesSize properties when read ahead entries
(#3895)
add 912896deb2 Cleanup CbThreadFactory (#3907)
add 35e9da9b55 Upgrade docker base image to resolve CVE-2023-0286 (#3916)
add df4492012c [fix] DigestManager should not advance readerIndex (#3919)
add 94e15b3dc0 Remove avro, hadoop-auth and jersey-json dependencies from
hadoop-common to resolve CVE-2019-10202, CVE-2023-1370 and CVE-2022-45685
(#3911)
add b088df620a [stats][bookie] Add bookie sanity test metrics (#3924)
add ca33b31d39 Enable PCBC completionObjects autoShrink to reduce memory
usage and gc (#3913)
add cad1436375 Fix ReclaimedSpaceViaDeletes stats incorrect problem.
(#3906)
add 2645ab90f5 Generate 4.16.1 release note (#3922)
add 2364621870 Fix release-major script bug (#3934)
add 3a9fe1b287 recycle dropping read-write requests when various
exceptions happened (#3912)
add c765aea600 fix wrong update checkAllLedgersTime when ledgerReplication
disabled (#3939)
add 6f1b2b0bc1 Generate 4.16.0 release note (#3882)
add 73e7bb402d Generate 4.16.0 website docs (#3933)
add efd3457d6e Generate 4.16.1 website docs (#3941)
add fffcca08bd Upgrade jetty version to 9.4.51.v20230217 (#3937)
add 93fc91742d Upgrade docusaurus to 2.4.0 (#3936)
add 16282e71df Fix some metrics generated by prometheus client without
type info (#3927)
add bbea67b095 Use ChannelVoidPromise to avoid useless promise objects
creation (#3733)
add b37403f978 Bump snakeyaml from 1.33 to 2.0 (#3839)
add 1fead36861 When the executor has been shut down, do not schedule task
(#3946)
add 53c3e2a79c add auditor skipping check task times metric (#3945)
add 3b99af9aac Enhance LedgerFragment toString method (#3833)
add 551b2d5117 drop invalid entryFormat arg from shell command (#3938)
add 5beb8948ba Return activeLogChannel if new create (#3894)
add 8309b1895c Fix garbage collection blocked by runtime exception (#3901)
add a122b6b9ec Fix npe when iterate pendingLedgersUpdates and
pendingDeletedLedgers. (#3955)
add c924cfeb50 Avoid compaction to trigger extra flushes DbLedgerStorage
(#3959)
add 575a81c79e Added support for OpenTelemetry metrics backend (#3968)
add e93a7f1f9b check indexBaseDir specified with ledgerBaseDir (#3967)
add 808b909edf clear channel when channelInactive (#3966)
add f8d81f7eb8 Upgrade Netty to 4.1.93.Final (#3975)
add 50bf016ecd Fix journal without flush (#3979)
add 7f64246ad3 Format otel module depedencies (#3970)
add c8c593ee6d Fix memory leak of direct memory. (#3983)
add b062e9ed7e [Bug] Always one orphan ledger is created (#3813)
add 1809e69c6d Fix arbitrary file upload vulnerability with
httpServerEnabled (#3982)
add 945df0ce39 Reduce unnecessary creation of ReplicationEnableCb objects
(#3960)
add eff38e45e3 Fix ledger replicated failed blocks bookie decommission
process (#3917)
add bf06642c82 Unify ByteBufAllocator for the DirectIO component (#3985)
add 2baee3629f Change pendingDeletedLedgers as ConcurrentHashSet (#3989)
add 5e9fdc2f81 Support skip invalid journal record in replying journal
stage (#3956)
add 8085f66ece Make slogger use current class (#3994)
add 5ca8d83aed Upgrade snappy-java to address multiple CVEs (#3993)
add e188ed82d3 Upgrade grpc and protobuf to address CVE-2023-32732 (#3992)
add ffc8e8bec1 Fix issue with binary compatibility with older grpc
versions at runtime in the bookkeeper client. (#3997)
add 23c83a341f Bump master version to 4.17.0-SNAPSHOT (#3995)
add 8a76703ee4 Fix data lost when configured multiple ledger directories
(#3329)
add 147b5bf846 Fix trigger GC not work (#3998)
add 1fbf791ae8 Upgrade Netty to 4.1.94.Final (#3999)
add 9eb14b0754 Release note 4.16.2 (#4002)
add 52e780f326 Bump guava version from 31.0.1-jre to 32.0.1-jre (#4008)
add a99f2e1a43 [fix] Keep entryLogMeta when entryLogFile deletion fails
(#3965)
add fb0d3d6faa Add read failed log for ledger checker. (#4010)
add 528f373aac Recycle LongWrapper finally (#4007)
add c967299dec Optimize getActiveLedgersInRange (#4005)
add 4ebb34e77e [improve] Add ClusterInfo shell Command (#4004)
add d85e99057b Pin order executor in LedgerHandle (#3738)
add 843df32d2b fix latest_release to 4.16.2 (#4029)
add 58765b0bb1 Use Bouncycastle jdk18on instead of jdk15on (#4028)
add 3bf08fef12 Fix deletedLedgers count (#4026)
add ad0ed213c0 Allow to set max operation numbers in a single rocksdb
batch (#4044)
add f30ff4f2ad Improve sanity test command. (#4045)
add 5b5c053317 fix the stats/bookkeeper-stats-providers hype-link (#4054)
add ba31274476 docs: fix typos in README (#4019)
add 5a47c1d3a0 [release] Force to use linux/amd64 to build release (#4060)
add da1d8eb7c0 Enable kv logs in log4j configuration (#3986)
add 0b0fe0bb42 fix read write request leak when executor full. (#4024)
add 269374fe53 fix AutoCloseableLifecycleComponent close exception log
(#4042)
add 69f27b71c6 Optimize getEntryLogMetadata (#3948)
add 84a80f5998 Remove underreplicaiton callback (#4058)
add 2e8be78ab8 Make compatible between DefaultEntryLogger and
DirectEntryLogger (#4041)
add 64bc9878c6 Fix comment typo in StreamCluster (#4064)
add 104f3163f8 Fix readEntry parameter order (#4059)
add 1666d820a3 Add explanatory messages to the asserts (#4055)
add 09aec9ca52 Optimize bookie decommission check wait interval (#4070)
add e8da8eb6cb Generate 4.14.8 release note (#4053)
add 1942cac687 Add javadocs in ConcurrentLongHashMap and similar classes.
(#4068)
add 056fe7b554 Print compaction progress (#4071)
add 9156276f86 Release note 4.16.3 (#4065)
add 50e30db96a Some UTs fail when running under JDK17 (#4084)
add abb5981676 Rackaware placement policy support local node awareness by
hostname (#4057)
add 95320f41ca Fix NoSuchElementException when rereplicate empty ledgers
(#4039)
add 907c273431 BP-64: Improve the description of 47 commands for
bin/bookkeeper (#4102)
add 3221aa3092 Ignore the empty `perRegionPlacement` when
RegionAwareEnsemblePlacementPolicy#newEnsemble (#4106)
add b33a0c9571 Upgrade Zookeeper to 3.8.3 to address CVE-2023-44981 (#4112)
add 342063a66e Update the document of diskUsageWarnThreshold (#4072)
add a8a25a2cc6 New API for batched reads (#4051)
add 65dfa8a173 Update release note for 4.16.2 (#4082)
add 230fc2634e Generate 4.14.8 website documents (#4076)
add 85d7bb3ecf Fix bug of negative JournalQueueSize (#4077)
add 61c03adab7 Upgrade bc-fips to 1.0.2.4 to fix CVE-2022-45146 (#3915)
add bf9a5cf3ee Remove the unused logs in the
CleanupLedgerManager.recordPromise (#4121)
add 192f88bb47 [website]rest api documentation patch for GC and
ReadonlyState (#3877)
add acde49c349 Make AutoRecovery enable stickyReadS as default. (#4125)
add c07e72aabd Fix no known bookies after reset racks for all BKs (#4128)
add c1b7f76d77 Update Jetty dependency. (#4141)
add b3662b7a23 issue 4109: Fix Flaky-test:
HandleFailuresTest.testHandleFailureBookieNotInWriteSet (#4110)
add 7a5f8912c8 make waitForNewAuditor stronger. (#4078)
add 2c2c583d6d Tune the test case (#4093)
add a842f3e92c Fix a slow gc thread shutdown when compacting (#4127)
add 11ccebbe60 Use Flaky flag to skip
testBookieServerZKSessionExpireBehaviour test (#4144)
add be1749c3db fix calculate checkSum when using Java9IntHash (#4140)
add a8d97f6809 Update StatsProvider URL (#4148)
add 5be03cfdfb when setExplicitLac is called the ledgersCount should
increased (#4138)
add 9aad0453f0 FastTimer to return rates if queried at the same second as
update (#4152)
add d370e09507 Release note 4.15.5 (#4151)
add 6f5d756550 Upgrade Netty to 4.1.104.Final and io_uring to 0.0.24.Final
(#4157)
add bce832e389 [fix][conf-stats] Fix default configuration
'statsProviderClass' (#4156)
add 1e3efa112b Fix auditor thread leak problem. (#4162)
add 9dab13911c Fix logging configurations are broken in docker image
(#4137)
add 5dc5f498ac [doc] fix bookkeeper binary path (#4166)
add d189c20ba0 split performance in two parts and add sticky reads part.
(#4131)
add f88f437872 Update copy right year from 2023 to 2024 (#4167)
add 031069cf31 Entry write support local node region aware placement
policy (#4063)
add 381510e459 Increase journal thread priority (#4120)
add 8b57234130 Add OpenTelemetry stats provider and change Prometheus
stats provider to the default provider (#4168)
add 70e11c96f7 [doc] Fix stats providers in configuration (#4169)
add eb233b0e45 Fix the autorecovery failed replicate by add entry fenced
error (#4163)
add 787d9b2301 Update Docker README.md (#4160)
add 24464ba428 Skip sync the RocksDB when no changes (#3904)
add 5fc3eefcb7 Generate 4.15.5 website (#4158)
add cc1c2e012f Issue 4134: Fixing memory leak error when using
DirectEntryLogger (#4135)
add f2e85f796c Optimize shell log print (#4037)
add 62ea072854 fix a config error (#4098)
add 13e7efaa97 fix LedgerHandle `ensembleChangeCounter` not used. (#4103)
add af419cccba Try to use jdk api to create hardlink when rename file when
compaction. (#3876)
add c40f756d1a rebase (#4146)
add bdbb5ec4a6 Chagne the method getUnderreplicatedFragments to the
package private (#4174)
add 54168b5d64 Improve auto-recovery noise log when some bookie down.
(#4118)
add 113d40ac50 Change callbacks in CleanupLedgerManager as a Set (#4123)
add c3748dd0bb Fix auditor elector executor block problem. (#4165)
add 92e41c1493 [BP-62] Batch read protocol change: Support encoding and
decoding for batchReadRequest and batchReadResponse (#4177)
add 0b0504fed0 [BP-62] Bookie server introduces the
BatchedReadEntryProcessor to handle batch read request (#4187)
add 262be78a61 [BP-62] Bookkeeper client introduce batch read request api.
(#4188)
add 5b0aaf1acd Generate 4.16.4 website doc (#4191)
add 7b1912f11c Generate 4.16.4 release note (#4182)
add 1eceb5dd21 [improve][docker] fix yaml and dockerfile (#4186)
add dc2bb1dfed Enable reorder read sequence for bk client by default
(#4139)
add e1d72cf4ec [BP-62] Refactor read op, and introduce batchReadOp. (#4190)
add 22097343ce [BP-62] LedgerHandle introduces batch read API. (#4195)
add 9c373f7e7b Fix checksum calculation bug when the payload is a
CompositeByteBuf with readerIndex > 0 (#4196)
add e50d5f232e Bump jsoup from 1.14.3 to 1.15.3
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (e13ff02910)
\
N -- N -- N refs/heads/dependabot/maven/org.jsoup-jsoup-1.15.3
(e50d5f232e)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 1 +
.github/workflows/bk-ci.yml | 64 +-
.github/workflows/bk-streamstorage-python.yml | 85 +
.github/workflows/website-deploy.yaml | 7 +-
.github/workflows/website-pr-validation.yml | 7 +-
NOTICE | 2 +-
README.md | 8 +-
bin/bkperf | 2 +
bin/bookkeeper | 4 +-
bookkeeper-benchmark/pom.xml | 2 +-
.../benchmark/BenchReadThroughputLatency.java | 5 +
.../benchmark/BenchThroughputLatency.java | 17 +-
bookkeeper-common-allocator/pom.xml | 2 +-
.../common/allocator/LeakDetectionPolicy.java | 17 +-
.../impl/ByteBufAllocatorBuilderTest.java | 12 +-
bookkeeper-common/pom.xml | 2 +-
.../collections/BatchedArrayBlockingQueue.java | 409 +++
.../common/collections/BatchedBlockingQueue.java | 43 +-
.../common/collections/BlockingMpscQueue.java | 41 +-
.../component/AbstractLifecycleComponent.java | 2 +-
.../component/AutoCloseableLifecycleComponent.java | 2 +-
...est.java => BatchedArrayBlockingQueueTest.java} | 169 +-
bookkeeper-dist/all/pom.xml | 7 +-
bookkeeper-dist/bkctl/pom.xml | 2 +-
bookkeeper-dist/pom.xml | 2 +-
bookkeeper-dist/server/pom.xml | 7 +-
bookkeeper-dist/src/assemble/bin-all.xml | 2 +-
bookkeeper-dist/src/assemble/bin-server.xml | 2 +-
bookkeeper-dist/src/assemble/bkctl.xml | 2 +-
.../src/main/resources/LICENSE-all.bin.txt | 295 +-
.../src/main/resources/LICENSE-bkctl.bin.txt | 246 +-
.../src/main/resources/LICENSE-server.bin.txt | 295 +-
.../src/main/resources/NOTICE-all.bin.txt | 82 +-
.../src/main/resources/NOTICE-bkctl.bin.txt | 62 +-
.../src/main/resources/NOTICE-server.bin.txt | 82 +-
.../LICENSE.aalto-xml.txt | 0
.../LICENSE.base64.txt | 0
.../LICENSE.bouncycastle.txt | 0
.../LICENSE.caliper.txt | 0
.../LICENSE.commons-lang.txt | 0
.../LICENSE.commons-logging.txt | 0
.../LICENSE.compress-lzf.txt | 0
.../LICENSE.dnsinfo.txt | 0
.../LICENSE.harmony.txt | 0
.../LICENSE.hpack.txt | 0
.../LICENSE.hyper-hpack.txt | 0
.../LICENSE.jboss-marshalling.txt | 0
.../LICENSE.jbzip2.txt | 0
.../LICENSE.jctools.txt | 0
.../LICENSE.jfastlz.txt | 0
.../LICENSE.jsr166y.txt | 0
.../LICENSE.jzlib.txt | 0
.../LICENSE.libdivsufsort.txt | 0
.../LICENSE.log4j.txt | 0
.../{netty-4.1.89.Final => netty}/LICENSE.lz4.txt | 0
.../LICENSE.lzma-java.txt | 0
.../LICENSE.mvn-wrapper.txt | 0
.../LICENSE.nghttp2-hpack.txt | 0
.../LICENSE.protobuf.txt | 0
.../LICENSE.slf4j.txt | 0
.../LICENSE.snappy.txt | 0
.../LICENSE.webbit.txt | 0
.../NOTICE.harmony.txt | 0
bookkeeper-http/http-server/pom.xml | 2 +-
.../org/apache/bookkeeper/http/HttpRouter.java | 3 +
.../org/apache/bookkeeper/http/HttpServer.java | 2 +
bookkeeper-http/pom.xml | 2 +-
bookkeeper-http/servlet-http-server/pom.xml | 2 +-
bookkeeper-http/vertx-http-server/pom.xml | 2 +-
.../bookkeeper/http/vertx/VertxHttpServer.java | 2 +-
.../bookkeeper/http/vertx/TestVertxHttpServer.java | 76 +
bookkeeper-proto/pom.xml | 2 +-
.../src/main/proto/BookkeeperProtocol.proto | 1 +
bookkeeper-server/pom.xml | 20 +-
.../bookkeeper/bookie/BookKeeperServerStats.java | 6 +-
.../org/apache/bookkeeper/bookie/BookieImpl.java | 23 +-
.../org/apache/bookkeeper/bookie/BookieShell.java | 415 ++-
.../bookkeeper/bookie/BookieStateManager.java | 46 +-
.../apache/bookkeeper/bookie/BufferedChannel.java | 2 +-
.../bookkeeper/bookie/DefaultEntryLogger.java | 58 +-
.../bookie/EntryLogManagerForSingleEntryLog.java | 1 +
.../bookkeeper/bookie/EntryLoggerAllocator.java | 4 +-
.../bookkeeper/bookie/FileSystemUpgrade.java | 13 +-
.../bookkeeper/bookie/GarbageCollectorThread.java | 78 +-
.../bookie/InterleavedLedgerStorage.java | 4 +-
.../java/org/apache/bookkeeper/bookie/Journal.java | 577 ++-
.../apache/bookkeeper/bookie/LedgerStorage.java | 23 +-
.../bookkeeper/bookie/SortedLedgerStorage.java | 2 +-
.../org/apache/bookkeeper/bookie/StateManager.java | 5 +
.../bookie/datainteg/EntryCopierImpl.java | 2 +-
.../bookie/stats/GarbageCollectorStats.java | 7 +
.../bookkeeper/bookie/stats/JournalStats.java | 30 -
.../bookie/storage/directentrylogger/Buffer.java | 10 +-
.../storage/directentrylogger/BufferPool.java | 5 +-
.../DirectCompactionEntryLog.java | 4 +-
.../directentrylogger/DirectEntryLogger.java | 15 +-
.../storage/directentrylogger/DirectReader.java | 9 +-
.../storage/directentrylogger/DirectWriter.java | 15 +-
.../storage/directentrylogger/EntryLogIdsImpl.java | 83 +
.../storage/directentrylogger/LogMetadata.java | 8 +-
.../storage/directentrylogger/LogReaderScan.java | 8 +-
.../bookie/storage/ldb/DbLedgerStorage.java | 59 +-
.../bookie/storage/ldb/EntryLocationIndex.java | 24 +-
.../bookie/storage/ldb/KeyValueStorage.java | 14 +
.../bookie/storage/ldb/KeyValueStorageRocksDB.java | 85 +-
.../bookie/storage/ldb/LedgerMetadataIndex.java | 72 +-
.../bookie/storage/ldb/LedgersIndexRebuildOp.java | 2 +-
.../ldb/SingleDirectoryDbLedgerStorage.java | 128 +-
.../apache/bookkeeper/client/BatchedReadOp.java | 321 ++
.../apache/bookkeeper/client/BookKeeperAdmin.java | 9 +-
.../bookkeeper/client/ClientInternalConf.java | 6 +-
.../bookkeeper/client/DistributionSchedule.java | 12 +
.../apache/bookkeeper/client/LedgerChecker.java | 15 +-
.../apache/bookkeeper/client/LedgerFragment.java | 11 +-
.../client/LedgerFragmentReplicator.java | 21 +-
.../org/apache/bookkeeper/client/LedgerHandle.java | 285 +-
.../client/ListenerBasedPendingReadOp.java | 2 +-
.../org/apache/bookkeeper/client/PendingAddOp.java | 30 +-
.../apache/bookkeeper/client/PendingReadOp.java | 526 +--
.../bookkeeper/client/PendingWriteLacOp.java | 10 +-
.../client/RackawareEnsemblePlacementPolicy.java | 30 +-
.../RackawareEnsemblePlacementPolicyImpl.java | 62 +-
.../org/apache/bookkeeper/client/ReadOpBase.java | 293 ++
.../client/RegionAwareEnsemblePlacementPolicy.java | 31 +-
.../client/RoundRobinDistributionSchedule.java | 18 +-
.../TopologyAwareEnsemblePlacementPolicy.java | 5 +-
.../apache/bookkeeper/client/api/ReadHandle.java | 32 +
.../bookkeeper/conf/AbstractConfiguration.java | 13 +-
.../bookkeeper/conf/ClientConfiguration.java | 28 +-
.../bookkeeper/conf/ServerConfiguration.java | 107 +-
.../bookkeeper/meta/CleanupLedgerManager.java | 22 +-
.../meta/LedgerUnderreplicationManager.java | 5 +-
.../meta/ZkLedgerUnderreplicationManager.java | 2 +-
.../apache/bookkeeper/net/NetworkTopologyImpl.java | 3 +
.../bookkeeper/processor/RequestProcessor.java | 4 +-
.../org/apache/bookkeeper/proto/AuthHandler.java | 48 +-
.../proto/BatchedReadEntryProcessor.java | 116 +
.../org/apache/bookkeeper/proto/BookieClient.java | 45 +-
.../apache/bookkeeper/proto/BookieClientImpl.java | 46 +-
.../bookkeeper/proto/BookieProtoEncoding.java | 127 +-
.../apache/bookkeeper/proto/BookieProtocol.java | 219 +-
.../bookkeeper/proto/BookieRequestHandler.java | 51 +-
.../bookkeeper/proto/BookieRequestProcessor.java | 144 +-
.../org/apache/bookkeeper/proto/BookieServer.java | 3 +-
.../proto/BookkeeperInternalCallbacks.java | 11 +
.../bookkeeper/proto/ForceLedgerProcessorV3.java | 7 +-
.../bookkeeper/proto/GetBookieInfoProcessorV3.java | 5 +-
.../proto/GetListOfEntriesOfLedgerProcessorV3.java | 5 +-
.../proto/LongPollReadEntryProcessorV3.java | 5 +-
.../bookkeeper/proto/PacketProcessorBase.java | 30 +-
.../bookkeeper/proto/PacketProcessorBaseV3.java | 7 +-
.../bookkeeper/proto/PerChannelBookieClient.java | 232 +-
.../bookkeeper/proto/ReadEntryProcessor.java | 53 +-
.../bookkeeper/proto/ReadEntryProcessorV3.java | 11 +-
.../bookkeeper/proto/ReadLacProcessorV3.java | 5 +-
.../apache/bookkeeper/proto/ResponseBuilder.java | 13 +-
.../bookkeeper/proto/WriteEntryProcessor.java | 21 +-
.../bookkeeper/proto/WriteEntryProcessorV3.java | 13 +-
.../bookkeeper/proto/WriteLacProcessorV3.java | 8 +-
.../proto/checksum/CRC32CDigestManager.java | 12 +-
.../proto/checksum/CRC32DigestManager.java | 14 +-
.../bookkeeper/proto/checksum/DigestManager.java | 131 +-
.../proto/checksum/DirectMemoryCRC32Digest.java | 18 +-
.../proto/checksum/DummyDigestManager.java | 12 +-
.../proto/checksum/MacDigestManager.java | 13 +-
.../proto/checksum/StandardCRC32Digest.java | 5 +
.../org/apache/bookkeeper/replication/Auditor.java | 55 +-
.../replication/AuditorBookieCheckTask.java | 10 +-
.../replication/AuditorCheckAllLedgersTask.java | 38 +-
.../bookkeeper/replication/AuditorElector.java | 55 +-
.../AuditorPlacementPolicyCheckTask.java | 13 +-
.../replication/AuditorReplicasCheckTask.java | 12 +-
.../bookkeeper/replication/AuditorStats.java | 28 +-
.../apache/bookkeeper/replication/AuditorTask.java | 14 +-
.../bookkeeper/replication/ReplicationStats.java | 4 +-
.../bookkeeper/replication/ReplicationWorker.java | 32 +-
.../apache/bookkeeper/server/EmbeddedServer.java | 14 +-
.../server/http/BKHttpServiceProvider.java | 3 +
.../http/service/BookieStateReadOnlyService.java | 5 +
.../server/http/service/TriggerGCService.java | 74 +-
.../service/TriggerLocationCompactService.java | 143 +
.../cli/commands/bookie/ReadJournalCommand.java | 2 +-
.../cli/commands/bookie/SanityTestCommand.java | 149 +-
.../cli/commands/bookies/ClusterInfoCommand.java | 137 +
.../cli/commands/cookie/CreateCookieCommand.java | 6 +
.../cli/commands/cookie/DeleteCookieCommand.java | 7 +
.../cli/commands/cookie/GenerateCookieCommand.java | 17 +
.../cli/commands/cookie/GetCookieCommand.java | 7 +
.../cli/commands/cookie/UpdateCookieCommand.java | 9 +
.../tools/cli/helpers/BookieShellCommand.java | 4 +-
.../org/apache/bookkeeper/util/ByteBufList.java | 40 +-
.../org/apache/bookkeeper/util/ByteBufVisitor.java | 1132 ++++++
.../java/org/apache/bookkeeper/util/HardLink.java | 32 +-
.../LedgerDirUtil.java} | 116 +-
.../apache/bookkeeper/util/NettyChannelUtil.java | 62 +
.../org/apache/bookkeeper/util/PageCacheUtil.java | 2 +-
.../util/collections/ConcurrentLongHashMap.java | 19 +
.../util/collections/ConcurrentLongHashSet.java | 13 +
.../collections/ConcurrentLongLongHashMap.java | 15 +
.../collections/ConcurrentLongLongPairHashMap.java | 20 +
.../util/collections/ConcurrentOpenHashMap.java | 20 +
.../util/collections/ConcurrentOpenHashSet.java | 18 +
.../bookkeeper/bookie/BookieJournalForceTest.java | 21 +-
.../bookie/BookieJournalPageCacheFlushTest.java | 24 +-
.../bookkeeper/bookie/BookieJournalTest.java | 127 +-
.../apache/bookkeeper/bookie/BookieShellTest.java | 14 +
.../bookie/CheckpointOnNewLedgersTest.java | 4 +-
.../bookkeeper/bookie/ClusterInfoCommandTest.java | 63 +
.../apache/bookkeeper/bookie/CreateNewLogTest.java | 40 +
.../bookkeeper/bookie/DefaultEntryLogTest.java | 47 +
.../bookie/FileInfoBackingCacheTest.java | 16 +-
.../bookie/GarbageCollectorThreadTest.java | 135 +
.../apache/bookkeeper/bookie/LedgerCacheTest.java | 9 +-
.../bookkeeper/bookie/MockLedgerStorage.java | 2 +-
.../apache/bookkeeper/bookie/TestBookieImpl.java | 28 +-
.../org/apache/bookkeeper/bookie/UpgradeTest.java | 133 +-
.../bookie/storage/EntryLogTestUtils.java | 1 +
.../storage/directentrylogger/TestBuffer.java | 17 +-
.../directentrylogger/TestDirectEntryLogger.java | 8 +-
.../directentrylogger/TestDirectReader.java | 15 +-
.../directentrylogger/TestDirectWriter.java | 23 +-
.../{ => directentrylogger}/TestEntryLogIds.java | 19 +-
.../storage/directentrylogger/TestMetadata.java | 2 +-
.../TestTransactionalEntryLogCompactor.java | 1 -
.../storage/ldb/DbLedgerStorageReadCacheTest.java | 368 ++
.../bookie/storage/ldb/DbLedgerStorageTest.java | 197 +-
.../storage/ldb/DbLedgerStorageWriteCacheTest.java | 10 +-
.../storage/ldb/KeyValueStorageRocksDBTest.java | 53 +
.../bookie/storage/ldb/KeyValueStorageTest.java | 37 +
.../bookie/storage/ldb/WriteCacheTest.java | 4 +-
.../bookkeeper/client/BookieWriteLedgerTest.java | 95 +
.../org/apache/bookkeeper/client/ClientUtil.java | 6 +-
.../bookkeeper/client/HandleFailuresTest.java | 38 +-
.../bookkeeper/client/LedgerHandleAdapter.java | 9 +-
.../apache/bookkeeper/client/MockBookKeeper.java | 17 +-
.../bookkeeper/client/MockBookKeeperTestCase.java | 12 +-
.../apache/bookkeeper/client/MockLedgerHandle.java | 11 +-
.../apache/bookkeeper/client/MockReadHandle.java | 2 +-
.../client/ParallelLedgerRecoveryTest.java | 7 +-
.../client/ReadLastConfirmedAndEntryOpTest.java | 21 +-
...{TestParallelRead.java => TestBatchedRead.java} | 222 +-
.../client/TestLedgerFragmentReplication.java | 14 +-
.../TestLedgerFragmentReplicationWithMock.java | 111 +
.../apache/bookkeeper/client/TestParallelRead.java | 17 +-
.../bookkeeper/client/TestPendingReadLacOp.java | 11 +-
.../TestRackawareEnsemblePlacementPolicy.java | 84 +
.../TestRegionAwareEnsemblePlacementPolicy.java | 165 +
...tiveRead.java => TestSpeculativeBatchRead.java} | 54 +-
.../bookkeeper/conf/AbstractConfigurationTest.java | 49 +
.../bookkeeper/net/NetworkTopologyImplTest.java | 40 +
...est.java => BatchedReadEntryProcessorTest.java} | 67 +-
.../proto/BookieBackpressureForV2Test.java | 4 +
.../bookkeeper/proto/BookieProtoEncodingTest.java | 34 +
.../proto/ForceLedgerProcessorV3Test.java | 19 +-
.../proto/GetBookieInfoProcessorV3Test.java | 12 +-
.../proto/LongPollReadEntryProcessorV3Test.java | 9 +-
.../apache/bookkeeper/proto/MockBookieClient.java | 80 +-
.../org/apache/bookkeeper/proto/MockBookies.java | 38 +-
.../bookkeeper/proto/ReadEntryProcessorTest.java | 21 +-
.../bookkeeper/proto/TestBackwardCompatCMS42.java | 5 +-
.../proto/TestBookieRequestProcessor.java | 27 +-
.../bookkeeper/proto/WriteEntryProcessorTest.java | 66 +-
.../proto/WriteEntryProcessorV3Test.java | 13 +-
.../CompositeByteBufUnwrapBugReproduceTest.java | 280 ++
.../bookkeeper/replication/AuditorBookieTest.java | 13 +-
.../AuditorCheckAllLedgersTaskTest.java | 2 +-
.../replication/AuditorLedgerCheckerTest.java | 130 +-
.../replication/AuditorPeriodicCheckTest.java | 241 +-
.../AuditorPlacementPolicyCheckTaskTest.java | 2 +-
.../AuditorPlacementPolicyCheckTest.java | 2 +-
.../replication/AuditorReplicasCheckTaskTest.java | 2 +-
.../replication/AuditorReplicasCheckTest.java | 2 +-
.../replication/ReplicationTestUtil.java | 2 +-
.../replication/TestReplicationWorker.java | 39 +-
.../bookkeeper/server/http/TestHttpService.java | 89 +
.../server/http/service/TriggerGCServiceTest.java | 147 +
.../apache/bookkeeper/test/BookieClientTest.java | 398 +++
.../apache/bookkeeper/test/BookieZKExpireTest.java | 3 +-
.../org/apache/bookkeeper/test/OpStatTest.java | 2 -
.../apache/bookkeeper/util/ByteBufListTest.java | 42 +-
.../bookkeeper/util/NettyChannelUtilTest.java | 73 +
.../org/apache/bookkeeper/util/TestHardLink.java | 82 +
.../resources/conf/entry_location_rocksdb.conf | 6 +-
.../resources/test_entry_location_rocksdb.conf | 16 +
bookkeeper-slogger/api/pom.xml | 2 +-
bookkeeper-slogger/pom.xml | 2 +-
bookkeeper-slogger/slf4j/pom.xml | 2 +-
buildtools/pom.xml | 4 +-
.../main/resources/bookkeeper/findbugsExclude.xml | 5 +
circe-checksum/pom.xml | 13 +-
.../circe/checksum/Crc32cIntChecksum.java | 40 +
.../com/scurrilous/circe/checksum/IntHash.java | 4 +
.../scurrilous/circe/checksum/Java8IntHash.java | 10 +
.../scurrilous/circe/checksum/Java9IntHash.java | 42 +-
.../com/scurrilous/circe/checksum/JniIntHash.java | 10 +
.../circe/checksum/Java9IntHashTest.java | 121 +
conf/bk_server.conf | 54 +-
conf/bkenv.sh | 3 -
conf/default_rocksdb.conf.default | 6 +-
conf/entry_location_rocksdb.conf.default | 6 +-
conf/ledger_metadata_rocksdb.conf.default | 6 +-
conf/log4j2.shell.xml | 35 +-
conf/log4j2.xml | 16 +
cpu-affinity/pom.xml | 2 +-
deploy/kubernetes/gke/bookkeeper.statefulset.yml | 1 -
dev/docker/Dockerfile | 2 +-
dev/release/000-run-docker.sh | 2 +-
dev/release/Dockerfile | 2 +-
docker/README.md | 6 +-
docker/scripts/apply-config-from-env.py | 23 +-
docker/scripts/common.sh | 2 +-
docker/scripts/init_zookeeper.sh | 2 +-
metadata-drivers/etcd/pom.xml | 10 +-
metadata-drivers/pom.xml | 2 +-
microbenchmarks/pom.xml | 2 +-
.../bookkeeper/bookie/GroupSortBenchmark.java | 3 +-
.../bookkeeper/common/MpScQueueBenchmark.java | 134 +
.../apache/bookkeeper/proto/ProtocolBenchmark.java | 16 -
.../proto/checksum/DigestManagerBenchmark.java | 5 +-
native-io/pom.xml | 2 +-
pom.xml | 121 +-
shaded/bookkeeper-server-shaded/pom.xml | 2 +-
shaded/bookkeeper-server-tests-shaded/pom.xml | 2 +-
shaded/distributedlog-core-shaded/pom.xml | 2 +-
shaded/pom.xml | 2 +-
site3/website/docs/admin/bookies.md | 6 +
site3/website/docs/admin/http.md | 143 +-
site3/website/docs/admin/metrics.md | 4 +-
site3/website/docs/getting-started/installation.md | 4 +-
site3/website/docs/reference/cli.md | 1 -
site3/website/docs/reference/config.md | 18 +-
site3/website/docusaurus.config.js | 4 +-
site3/website/package.json | 4 +-
site3/website/scripts/release-major.sh | 2 -
.../pages/bps/BP-62-new-API-for-batched-reads.md | 305 ++
site3/website/src/pages/community/coding-guide.md | 2 +-
site3/website/src/pages/release-notes.md | 448 +++
site3/website/static/img/batch_read.png | Bin 0 -> 222133 bytes
site3/website/static/img/single_read.png | Bin 0 -> 190477 bytes
.../version-4.14.7/api/ledger-api.md | 841 -----
.../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
.../reference/metrics.md | 0
.../security/overview.md | 0
.../security/sasl.md | 0
.../security/tls.md | 0
.../security/zookeeper.md | 0
.../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 | 0
.../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 | 2 +-
.../reference/cli.md | 0
.../reference/config.md | 0
.../security/overview.md | 0
.../security/sasl.md | 0
.../security/tls.md | 0
.../security/zookeeper.md | 0
.../version-4.16.4}/admin/autorecovery.md | 0
.../version-4.16.4}/admin/bookies.md | 0
.../version-4.16.4}/admin/decomission.md | 0
.../version-4.16.4}/admin/geo-replication.md | 0
.../version-4.16.4}/admin/http.md | 41 +
.../admin/metrics.md | 1 +
.../version-4.16.4}/admin/perf.md | 0
.../version-4.16.4}/admin/placement.md | 0
.../version-4.16.4}/admin/upgrade.md | 0
.../version-4.16.4}/api/distributedlog-api.md | 0
.../version-4.16.4}/api/ledger-adv-api.md | 0
.../version-4.16.4}/api/ledger-api.md | 8 +-
.../version-4.16.4}/api/overview.md | 0
.../version-4.16.4}/deployment/kubernetes.md | 0
.../version-4.16.4}/deployment/manual.md | 0
.../version-4.16.4}/development/codebase.md | 0
.../version-4.16.4}/development/protocol.md | 0
.../version-4.16.4}/getting-started/concepts.md | 0
.../getting-started/installation.md | 0
.../version-4.16.4}/getting-started/run-locally.md | 0
.../version-4.16.4}/overview/overview.md | 6 +-
.../version-4.16.4}/reference/cli.md | 0
.../version-4.16.4}/reference/config.md | 16 +-
.../version-4.16.4}/security/overview.md | 0
.../version-4.16.4}/security/sasl.md | 0
.../version-4.16.4}/security/tls.md | 0
.../version-4.16.4}/security/zookeeper.md | 0
.../version-4.14.7-sidebars.json | 161 -
...-sidebars.json => version-4.14.8-sidebars.json} | 48 +-
...-sidebars.json => version-4.15.5-sidebars.json} | 0
.../version-4.16.4-sidebars.json} | 46 +-
site3/website/versions.json | 5 +-
site3/website/yarn.lock | 3732 +++++++++++++-------
...le_m1_aol.properties => aarch64_aol.properties} | 34 +
stats/bookkeeper-stats-api/pom.xml | 2 +-
.../codahale-metrics-provider/pom.xml | 2 +-
.../bookkeeper/stats/codahale/FastTimer.java | 5 +-
.../bookkeeper/stats/codahale/FastTimerTest.java | 12 +
.../pom.xml | 61 +-
.../apache/bookkeeper/stats/otel/OtelCounter.java} | 55 +-
.../bookkeeper/stats/otel/OtelMetricsProvider.java | 150 +
.../bookkeeper/stats/otel/OtelOpStatsLogger.java | 69 +
.../bookkeeper/stats/otel/OtelStatsLogger.java} | 62 +-
.../apache/bookkeeper/stats/otel/ScopeContext.java | 20 +-
.../bookkeeper/stats/otel}/package-info.java | 4 +-
stats/bookkeeper-stats-providers/pom.xml | 3 +-
.../prometheus-metrics-provider/pom.xml | 2 +-
.../stats/prometheus/PrometheusTextFormat.java | 27 +
.../stats/prometheus/PrometheusTextFormatTest.java | 39 -
.../stats/prometheus/TestPrometheusFormatter.java | 56 +
stats/pom.xml | 2 +-
stats/utils/pom.xml | 2 +-
stream/api/pom.xml | 2 +-
stream/bk-grpc-name-resolver/pom.xml | 2 +-
stream/clients/java/all/pom.xml | 2 +-
stream/clients/java/base/pom.xml | 2 +-
.../impl/container/TestStorageContainerInfo.java | 8 +-
stream/clients/java/kv/pom.xml | 2 +-
.../clients/impl/kv/PByteBufSimpleTableImpl.java | 24 +-
.../clients/impl/kv/PByteBufTableRangeImpl.java | 24 +-
stream/clients/java/pom.xml | 2 +-
stream/clients/pom.xml | 20 +-
stream/clients/python/.flake8 | 1 +
stream/clients/python/.gitignore | 2 +
stream/clients/python/README.rst | 19 +
.../python/bookkeeper/common/protobuf_helpers.py | 22 +-
.../clients/python/bookkeeper/proto/cluster_pb2.py | 207 +-
.../clients/python/bookkeeper/proto/common_pb2.py | 70 +-
stream/clients/python/bookkeeper/proto/kv_pb2.py | 192 +-
.../clients/python/bookkeeper/proto/kv_rpc_pb2.py | 1302 +------
.../python/bookkeeper/proto/kv_store_pb2.py | 312 +-
.../clients/python/bookkeeper/proto/storage_pb2.py | 1328 +------
.../clients/python/bookkeeper/proto/stream_pb2.py | 1401 +-------
.../clients/python/docker}/Dockerfile | 33 +-
.../test.sh => docker/build-local-image.sh} | 20 +-
.../python/scripts/docker_integration_tests.sh | 7 +-
.../python/scripts/run_integration_tests.sh | 3 +
stream/clients/python/scripts/test.sh | 1 -
stream/clients/python/setup.py | 4 +-
.../tests/integration/bookkeeper/kv/test_client.py | 1 -
stream/common/pom.xml | 10 +-
.../resolver/ServiceNameResolverProvider.java | 2 +-
.../common/router/AbstractHashRouter.java | 2 +-
stream/distributedlog/common/pom.xml | 2 +-
.../distributedlog/io/TestCompressionCodec.java | 12 +-
stream/distributedlog/core/pom.xml | 2 +-
.../org/apache/bookkeeper/client/LedgerReader.java | 2 +-
.../org/apache/distributedlog/EnvelopedEntry.java | 2 +-
.../distributedlog/EnvelopedEntryReader.java | 2 +-
.../distributedlog/EnvelopedEntryWriter.java | 8 +-
.../distributedlog/bk/SimpleLedgerAllocator.java | 4 +-
.../impl/logsegment/BKLogSegmentEntryReader.java | 2 +-
.../distributedlog/tools/DistributedLogTool.java | 6 +-
.../distributedlog/TestBKLogWriteHandler.java | 48 +
.../java/org/apache/distributedlog/TestEntry.java | 8 +-
.../apache/distributedlog/TestRollLogSegments.java | 2 +
stream/distributedlog/io/dlfs/pom.xml | 14 +-
stream/distributedlog/io/pom.xml | 2 +-
stream/distributedlog/pom.xml | 2 +-
stream/distributedlog/protocol/pom.xml | 2 +-
.../distributedlog/EnvelopedRecordSetReader.java | 8 +-
.../distributedlog/EnvelopedRecordSetWriter.java | 8 +-
.../java/org/apache/distributedlog/LogRecord.java | 2 +-
stream/pom.xml | 2 +-
stream/proto/pom.xml | 2 +-
stream/server/pom.xml | 2 +-
.../bookkeeper/stream/cluster/StreamCluster.java | 2 +-
stream/statelib/pom.xml | 2 +-
.../journal/AbstractStateStoreWithJournal.java | 4 +-
.../bookkeeper/statelib/impl/kv/KVUtils.java | 2 +-
.../statelib/impl/kv/RocksdbKVAsyncStore.java | 4 +-
.../bookkeeper/statelib/impl/mvcc/MVCCRecord.java | 4 +-
.../statelib/impl/mvcc/MVCCRecordCoder.java | 2 +-
.../statelib/impl/mvcc/MVCCStoreImpl.java | 2 +-
stream/storage/api/pom.xml | 2 +-
stream/storage/impl/pom.xml | 2 +-
.../routing/RoutingHeaderProxyInterceptor.java | 2 +-
stream/storage/pom.xml | 2 +-
stream/tests-common/pom.xml | 10 +-
tests/backward-compat/bc-non-fips/pom.xml | 8 +-
.../current-server-old-clients/pom.xml | 2 +-
.../hierarchical-ledger-manager/pom.xml | 2 +-
tests/backward-compat/hostname-bookieid/pom.xml | 2 +-
.../backward-compat/old-cookie-new-cluster/pom.xml | 2 +-
tests/backward-compat/pom.xml | 2 +-
tests/backward-compat/recovery-no-password/pom.xml | 2 +-
tests/backward-compat/upgrade-direct/pom.xml | 2 +-
tests/backward-compat/upgrade/pom.xml | 2 +-
tests/backward-compat/yahoo-custom-version/pom.xml | 2 +-
.../all-released-versions-image/pom.xml | 2 +-
tests/docker-images/all-versions-image/pom.xml | 2 +-
tests/docker-images/pom.xml | 2 +-
tests/docker-images/statestore-image/Dockerfile | 8 +-
.../docker-images/statestore-image/bin/bookkeeper | 3 +-
tests/integration-tests-base-groovy/pom.xml | 2 +-
tests/integration-tests-base/pom.xml | 2 +-
tests/integration-tests-topologies/pom.xml | 2 +-
tests/integration-tests-utils/pom.xml | 2 +-
tests/integration/cluster/pom.xml | 2 +-
tests/integration/pom.xml | 2 +-
tests/integration/smoke/pom.xml | 2 +-
tests/integration/standalone/pom.xml | 2 +-
tests/pom.xml | 2 +-
tests/scripts/pom.xml | 2 +-
tests/shaded/bookkeeper-server-shaded-test/pom.xml | 2 +-
.../bookkeeper-server-tests-shaded-test/pom.xml | 2 +-
.../shaded/distributedlog-core-shaded-test/pom.xml | 2 +-
tests/shaded/pom.xml | 2 +-
testtools/pom.xml | 15 +-
tools/all/pom.xml | 2 +-
tools/framework/pom.xml | 2 +-
.../bookkeeper/tools/framework/CliCommand.java | 4 +
tools/ledger/pom.xml | 2 +-
.../cli/commands/bookie/SanityTestCommandTest.java | 59 +-
.../commands/cookie/CreateCookieCommandTest.java | 2 +-
.../commands/cookie/UpdateCookieCommandTest.java | 2 +-
tools/perf/pom.xml | 2 +-
.../tools/perf/journal/JournalWriter.java | 2 +-
.../bookkeeper/tools/perf/table/IncrementTask.java | 2 +-
.../bookkeeper/tools/perf/table/WriteTask.java | 4 +-
tools/pom.xml | 2 +-
tools/stream/pom.xml | 2 +-
.../stream/cli/commands/table/DelCommand.java | 2 +-
558 files changed, 16554 insertions(+), 9998 deletions(-)
create mode 100644 .github/workflows/bk-streamstorage-python.yml
create mode 100644
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/collections/BatchedArrayBlockingQueue.java
copy
bookkeeper-server/src/main/java/org/apache/bookkeeper/feature/Feature.java =>
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/collections/BatchedBlockingQueue.java
(50%)
copy
bookkeeper-common/src/test/java/org/apache/bookkeeper/common/collections/{GrowableArrayBlockingQueueTest.java
=> BatchedArrayBlockingQueueTest.java} (61%)
rename bookkeeper-dist/src/main/resources/deps/{netty-4.1.89.Final =>
netty}/LICENSE.aalto-xml.txt (100%)
rename bookkeeper-dist/src/main/resources/deps/{netty-4.1.89.Final =>
netty}/LICENSE.base64.txt (100%)
rename bookkeeper-dist/src/main/resources/deps/{netty-4.1.89.Final =>
netty}/LICENSE.bouncycastle.txt (100%)
rename bookkeeper-dist/src/main/resources/deps/{netty-4.1.89.Final =>
netty}/LICENSE.caliper.txt (100%)
rename bookkeeper-dist/src/main/resources/deps/{netty-4.1.89.Final =>
netty}/LICENSE.commons-lang.txt (100%)
rename bookkeeper-dist/src/main/resources/deps/{netty-4.1.89.Final =>
netty}/LICENSE.commons-logging.txt (100%)
rename bookkeeper-dist/src/main/resources/deps/{netty-4.1.89.Final =>
netty}/LICENSE.compress-lzf.txt (100%)
rename bookkeeper-dist/src/main/resources/deps/{netty-4.1.89.Final =>
netty}/LICENSE.dnsinfo.txt (100%)
rename bookkeeper-dist/src/main/resources/deps/{netty-4.1.89.Final =>
netty}/LICENSE.harmony.txt (100%)
rename bookkeeper-dist/src/main/resources/deps/{netty-4.1.89.Final =>
netty}/LICENSE.hpack.txt (100%)
rename bookkeeper-dist/src/main/resources/deps/{netty-4.1.89.Final =>
netty}/LICENSE.hyper-hpack.txt (100%)
rename bookkeeper-dist/src/main/resources/deps/{netty-4.1.89.Final =>
netty}/LICENSE.jboss-marshalling.txt (100%)
rename bookkeeper-dist/src/main/resources/deps/{netty-4.1.89.Final =>
netty}/LICENSE.jbzip2.txt (100%)
rename bookkeeper-dist/src/main/resources/deps/{netty-4.1.89.Final =>
netty}/LICENSE.jctools.txt (100%)
rename bookkeeper-dist/src/main/resources/deps/{netty-4.1.89.Final =>
netty}/LICENSE.jfastlz.txt (100%)
rename bookkeeper-dist/src/main/resources/deps/{netty-4.1.89.Final =>
netty}/LICENSE.jsr166y.txt (100%)
rename bookkeeper-dist/src/main/resources/deps/{netty-4.1.89.Final =>
netty}/LICENSE.jzlib.txt (100%)
rename bookkeeper-dist/src/main/resources/deps/{netty-4.1.89.Final =>
netty}/LICENSE.libdivsufsort.txt (100%)
rename bookkeeper-dist/src/main/resources/deps/{netty-4.1.89.Final =>
netty}/LICENSE.log4j.txt (100%)
rename bookkeeper-dist/src/main/resources/deps/{netty-4.1.89.Final =>
netty}/LICENSE.lz4.txt (100%)
rename bookkeeper-dist/src/main/resources/deps/{netty-4.1.89.Final =>
netty}/LICENSE.lzma-java.txt (100%)
rename bookkeeper-dist/src/main/resources/deps/{netty-4.1.89.Final =>
netty}/LICENSE.mvn-wrapper.txt (100%)
rename bookkeeper-dist/src/main/resources/deps/{netty-4.1.89.Final =>
netty}/LICENSE.nghttp2-hpack.txt (100%)
rename bookkeeper-dist/src/main/resources/deps/{netty-4.1.89.Final =>
netty}/LICENSE.protobuf.txt (100%)
rename bookkeeper-dist/src/main/resources/deps/{netty-4.1.89.Final =>
netty}/LICENSE.slf4j.txt (100%)
rename bookkeeper-dist/src/main/resources/deps/{netty-4.1.89.Final =>
netty}/LICENSE.snappy.txt (100%)
rename bookkeeper-dist/src/main/resources/deps/{netty-4.1.89.Final =>
netty}/LICENSE.webbit.txt (100%)
rename bookkeeper-dist/src/main/resources/deps/{netty-4.1.89.Final =>
netty}/NOTICE.harmony.txt (100%)
create mode 100644
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/directentrylogger/EntryLogIdsImpl.java
create mode 100644
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/BatchedReadOp.java
create mode 100644
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/ReadOpBase.java
create mode 100644
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BatchedReadEntryProcessor.java
create mode 100644
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/TriggerLocationCompactService.java
create mode 100644
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookies/ClusterInfoCommand.java
create mode 100644
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/ByteBufVisitor.java
rename
bookkeeper-server/src/main/java/org/apache/bookkeeper/{bookie/storage/EntryLogIdsImpl.java
=> util/LedgerDirUtil.java} (63%)
create mode 100644
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/NettyChannelUtil.java
create mode 100644
bookkeeper-server/src/test/java/org/apache/bookkeeper/bookie/ClusterInfoCommandTest.java
rename bookkeeper-server/src/test/java/org/apache/bookkeeper/bookie/storage/{
=> directentrylogger}/TestEntryLogIds.java (93%)
create mode 100644
bookkeeper-server/src/test/java/org/apache/bookkeeper/bookie/storage/ldb/DbLedgerStorageReadCacheTest.java
copy
bookkeeper-server/src/test/java/org/apache/bookkeeper/client/{TestParallelRead.java
=> TestBatchedRead.java} (51%)
create mode 100644
bookkeeper-server/src/test/java/org/apache/bookkeeper/client/TestLedgerFragmentReplicationWithMock.java
copy
bookkeeper-server/src/test/java/org/apache/bookkeeper/client/{TestSpeculativeRead.java
=> TestSpeculativeBatchRead.java} (91%)
copy
bookkeeper-server/src/test/java/org/apache/bookkeeper/proto/{ReadEntryProcessorTest.java
=> BatchedReadEntryProcessorTest.java} (71%)
create mode 100644
bookkeeper-server/src/test/java/org/apache/bookkeeper/proto/checksum/CompositeByteBufUnwrapBugReproduceTest.java
create mode 100644
bookkeeper-server/src/test/java/org/apache/bookkeeper/server/http/service/TriggerGCServiceTest.java
create mode 100644
bookkeeper-server/src/test/java/org/apache/bookkeeper/util/NettyChannelUtilTest.java
create mode 100644
bookkeeper-server/src/test/java/org/apache/bookkeeper/util/TestHardLink.java
create mode 100644
circe-checksum/src/test/java/com/scurrilous/circe/checksum/Java9IntHashTest.java
create mode 100644
microbenchmarks/src/main/java/org/apache/bookkeeper/common/MpScQueueBenchmark.java
create mode 100644
site3/website/src/pages/bps/BP-62-new-API-for-batched-reads.md
create mode 100644 site3/website/static/img/batch_read.png
create mode 100644 site3/website/static/img/single_read.png
delete mode 100644
site3/website/versioned_docs/version-4.14.7/api/ledger-api.md
rename site3/website/versioned_docs/{version-4.14.7 =>
version-4.14.8}/admin/autorecovery.md (100%)
rename site3/website/versioned_docs/{version-4.14.7 =>
version-4.14.8}/admin/bookies.md (100%)
rename site3/website/versioned_docs/{version-4.14.7 =>
version-4.14.8}/admin/decomission.md (100%)
rename site3/website/versioned_docs/{version-4.14.7 =>
version-4.14.8}/admin/geo-replication.md (100%)
rename site3/website/versioned_docs/{version-4.14.7 =>
version-4.14.8}/admin/http.md (100%)
rename site3/website/versioned_docs/{version-4.14.7 =>
version-4.14.8}/admin/metrics.md (100%)
rename site3/website/versioned_docs/{version-4.14.7 =>
version-4.14.8}/admin/perf.md (100%)
rename site3/website/versioned_docs/{version-4.14.7 =>
version-4.14.8}/admin/placement.md (100%)
rename site3/website/versioned_docs/{version-4.14.7 =>
version-4.14.8}/admin/upgrade.md (100%)
rename site3/website/versioned_docs/{version-4.14.7 =>
version-4.14.8}/api/distributedlog-api.md (100%)
rename site3/website/versioned_docs/{version-4.14.7 =>
version-4.14.8}/api/ledger-adv-api.md (100%)
copy site3/website/versioned_docs/{version-4.12.1 =>
version-4.14.8}/api/ledger-api.md (99%)
rename site3/website/versioned_docs/{version-4.14.7 =>
version-4.14.8}/api/overview.md (100%)
rename site3/website/versioned_docs/{version-4.14.7 =>
version-4.14.8}/deployment/kubernetes.md (100%)
rename site3/website/versioned_docs/{version-4.14.7 =>
version-4.14.8}/deployment/manual.md (100%)
rename site3/website/versioned_docs/{version-4.14.7 =>
version-4.14.8}/development/codebase.md (100%)
rename site3/website/versioned_docs/{version-4.14.7 =>
version-4.14.8}/development/protocol.md (100%)
rename site3/website/versioned_docs/{version-4.14.7 =>
version-4.14.8}/getting-started/concepts.md (100%)
rename site3/website/versioned_docs/{version-4.14.7 =>
version-4.14.8}/getting-started/installation.md (100%)
rename site3/website/versioned_docs/{version-4.14.7 =>
version-4.14.8}/getting-started/run-locally.md (100%)
rename site3/website/versioned_docs/{version-4.14.7 =>
version-4.14.8}/overview/overview.md (97%)
rename site3/website/versioned_docs/{version-4.14.7 =>
version-4.14.8}/reference/cli.md (100%)
rename site3/website/versioned_docs/{version-4.14.7 =>
version-4.14.8}/reference/config.md (100%)
rename site3/website/versioned_docs/{version-4.14.7 =>
version-4.14.8}/reference/metrics.md (100%)
rename site3/website/versioned_docs/{version-4.14.7 =>
version-4.14.8}/security/overview.md (100%)
rename site3/website/versioned_docs/{version-4.14.7 =>
version-4.14.8}/security/sasl.md (100%)
rename site3/website/versioned_docs/{version-4.14.7 =>
version-4.14.8}/security/tls.md (100%)
rename site3/website/versioned_docs/{version-4.14.7 =>
version-4.14.8}/security/zookeeper.md (100%)
rename site3/website/versioned_docs/{version-4.15.3 =>
version-4.15.5}/admin/autorecovery.md (100%)
rename site3/website/versioned_docs/{version-4.15.3 =>
version-4.15.5}/admin/bookies.md (100%)
rename site3/website/versioned_docs/{version-4.15.3 =>
version-4.15.5}/admin/decomission.md (100%)
rename site3/website/versioned_docs/{version-4.15.3 =>
version-4.15.5}/admin/geo-replication.md (100%)
rename site3/website/versioned_docs/{version-4.15.3 =>
version-4.15.5}/admin/http.md (100%)
rename site3/website/versioned_docs/{version-4.15.3 =>
version-4.15.5}/admin/metrics.md (100%)
rename site3/website/versioned_docs/{version-4.15.3 =>
version-4.15.5}/admin/perf.md (100%)
rename site3/website/versioned_docs/{version-4.15.3 =>
version-4.15.5}/admin/placement.md (100%)
rename site3/website/versioned_docs/{version-4.15.3 =>
version-4.15.5}/admin/upgrade.md (100%)
rename site3/website/versioned_docs/{version-4.15.3 =>
version-4.15.5}/api/distributedlog-api.md (100%)
rename site3/website/versioned_docs/{version-4.15.3 =>
version-4.15.5}/api/ledger-adv-api.md (100%)
rename site3/website/versioned_docs/{version-4.15.3 =>
version-4.15.5}/api/ledger-api.md (100%)
rename site3/website/versioned_docs/{version-4.15.3 =>
version-4.15.5}/api/overview.md (100%)
rename site3/website/versioned_docs/{version-4.15.3 =>
version-4.15.5}/deployment/kubernetes.md (100%)
rename site3/website/versioned_docs/{version-4.15.3 =>
version-4.15.5}/deployment/manual.md (100%)
rename site3/website/versioned_docs/{version-4.15.3 =>
version-4.15.5}/development/codebase.md (100%)
rename site3/website/versioned_docs/{version-4.15.3 =>
version-4.15.5}/development/protocol.md (100%)
rename site3/website/versioned_docs/{version-4.15.3 =>
version-4.15.5}/getting-started/concepts.md (100%)
rename site3/website/versioned_docs/{version-4.15.3 =>
version-4.15.5}/getting-started/installation.md (100%)
rename site3/website/versioned_docs/{version-4.15.3 =>
version-4.15.5}/getting-started/run-locally.md (100%)
rename site3/website/versioned_docs/{version-4.15.3 =>
version-4.15.5}/overview/overview.md (99%)
rename site3/website/versioned_docs/{version-4.15.3 =>
version-4.15.5}/reference/cli.md (100%)
rename site3/website/versioned_docs/{version-4.15.3 =>
version-4.15.5}/reference/config.md (100%)
rename site3/website/versioned_docs/{version-4.15.3 =>
version-4.15.5}/security/overview.md (100%)
rename site3/website/versioned_docs/{version-4.15.3 =>
version-4.15.5}/security/sasl.md (100%)
rename site3/website/versioned_docs/{version-4.15.3 =>
version-4.15.5}/security/tls.md (100%)
rename site3/website/versioned_docs/{version-4.15.3 =>
version-4.15.5}/security/zookeeper.md (100%)
copy site3/website/{docs =>
versioned_docs/version-4.16.4}/admin/autorecovery.md (100%)
copy site3/website/{docs => versioned_docs/version-4.16.4}/admin/bookies.md
(100%)
copy site3/website/{docs =>
versioned_docs/version-4.16.4}/admin/decomission.md (100%)
copy site3/website/{docs =>
versioned_docs/version-4.16.4}/admin/geo-replication.md (100%)
copy site3/website/{docs => versioned_docs/version-4.16.4}/admin/http.md (92%)
copy site3/website/versioned_docs/{version-4.13.0 =>
version-4.16.4}/admin/metrics.md (93%)
copy site3/website/{docs => versioned_docs/version-4.16.4}/admin/perf.md (100%)
copy site3/website/{docs => versioned_docs/version-4.16.4}/admin/placement.md
(100%)
copy site3/website/{docs => versioned_docs/version-4.16.4}/admin/upgrade.md
(100%)
copy site3/website/{docs =>
versioned_docs/version-4.16.4}/api/distributedlog-api.md (100%)
copy site3/website/{docs =>
versioned_docs/version-4.16.4}/api/ledger-adv-api.md (100%)
copy site3/website/{docs => versioned_docs/version-4.16.4}/api/ledger-api.md
(99%)
copy site3/website/{docs => versioned_docs/version-4.16.4}/api/overview.md
(100%)
copy site3/website/{docs =>
versioned_docs/version-4.16.4}/deployment/kubernetes.md (100%)
copy site3/website/{docs =>
versioned_docs/version-4.16.4}/deployment/manual.md (100%)
copy site3/website/{docs =>
versioned_docs/version-4.16.4}/development/codebase.md (100%)
copy site3/website/{docs =>
versioned_docs/version-4.16.4}/development/protocol.md (100%)
copy site3/website/{docs =>
versioned_docs/version-4.16.4}/getting-started/concepts.md (100%)
copy site3/website/{docs =>
versioned_docs/version-4.16.4}/getting-started/installation.md (100%)
copy site3/website/{docs =>
versioned_docs/version-4.16.4}/getting-started/run-locally.md (100%)
copy site3/website/{docs =>
versioned_docs/version-4.16.4}/overview/overview.md (94%)
copy site3/website/{docs => versioned_docs/version-4.16.4}/reference/cli.md
(100%)
copy site3/website/{docs => versioned_docs/version-4.16.4}/reference/config.md
(96%)
copy site3/website/{docs =>
versioned_docs/version-4.16.4}/security/overview.md (100%)
copy site3/website/{docs => versioned_docs/version-4.16.4}/security/sasl.md
(100%)
copy site3/website/{docs => versioned_docs/version-4.16.4}/security/tls.md
(100%)
copy site3/website/{docs =>
versioned_docs/version-4.16.4}/security/zookeeper.md (100%)
delete mode 100644
site3/website/versioned_sidebars/version-4.14.7-sidebars.json
copy site3/website/versioned_sidebars/{version-4.11.1-sidebars.json =>
version-4.14.8-sidebars.json} (67%)
rename site3/website/versioned_sidebars/{version-4.15.3-sidebars.json =>
version-4.15.5-sidebars.json} (100%)
copy site3/website/{sidebars.json =>
versioned_sidebars/version-4.16.4-sidebars.json} (68%)
rename src/{apple_m1_aol.properties => aarch64_aol.properties} (58%)
copy stats/bookkeeper-stats-providers/{prometheus-metrics-provider =>
otel-metrics-provider}/pom.xml (55%)
copy
stats/bookkeeper-stats-providers/{prometheus-metrics-provider/src/main/java/org/apache/bookkeeper/stats/prometheus/LongAdderCounter.java
=>
otel-metrics-provider/src/main/java/org/apache/bookkeeper/stats/otel/OtelCounter.java}
(50%)
create mode 100644
stats/bookkeeper-stats-providers/otel-metrics-provider/src/main/java/org/apache/bookkeeper/stats/otel/OtelMetricsProvider.java
create mode 100644
stats/bookkeeper-stats-providers/otel-metrics-provider/src/main/java/org/apache/bookkeeper/stats/otel/OtelOpStatsLogger.java
copy
stats/bookkeeper-stats-providers/{prometheus-metrics-provider/src/main/java/org/apache/bookkeeper/stats/prometheus/PrometheusStatsLogger.java
=>
otel-metrics-provider/src/main/java/org/apache/bookkeeper/stats/otel/OtelStatsLogger.java}
(58%)
copy
bookkeeper-server/src/main/java/org/apache/bookkeeper/versioning/Versioned.java
=>
stats/bookkeeper-stats-providers/otel-metrics-provider/src/main/java/org/apache/bookkeeper/stats/otel/ScopeContext.java
(73%)
copy {bookkeeper-http/http-server/src/main/java/org/apache/bookkeeper/http =>
stats/bookkeeper-stats-providers/otel-metrics-provider/src/main/java/org/apache/bookkeeper/stats/otel}/package-info.java
(88%)
delete mode 100644
stats/bookkeeper-stats-providers/prometheus-metrics-provider/src/test/java/org/apache/bookkeeper/stats/prometheus/PrometheusTextFormatTest.java
copy {docker => stream/clients/python/docker}/Dockerfile (58%)
copy stream/clients/python/{scripts/test.sh => docker/build-local-image.sh}
(62%)
