This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 53985112c21 [improve][misc] Upgrade Netty to 4.1.134 (#25870)
new 6fb674d3d4c [fix][fn] Fix Go function runtime to continue after user
exceptions and add neg-ack tests (#25867)
new 76620546bdc [fix][test] Fix flaky ProducerCleanupTest timer cleanup
(#25864)
new 3c3c403c607 [fix][test] Fix flaky
PulsarFunctionTlsTest.testFunctionsCreation() test (#25889)
new a7cb7e8f373 [fix][broker] Fix compaction cursor reset may lose
mark-delete properties (#25862)
new edc242da6a9 Return 400 for invalid reader messageId query parameter
(#25865)
new a71f7e80bbd [fix][broker] Fix PersistentMessageExpiryMonitor
findEntryComplete() method may lose mark-delete properties in race condition
(#25803)
new 6ea447244e5 [fix][bk] Fix NPE in IsolatedBookieEnsemblePlacementPolicy
when policy class does not match (#25825)
new b34fff7a19b [fix][broker] Fix non-batched null-value messages not
removed during topic compaction (#25817)
The 8 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 2 +-
.../bookkeeper/mledger/impl/ManagedCursorTest.java | 84 +++++++++++++
.../IsolatedBookieEnsemblePlacementPolicy.java | 28 +++--
.../IsolatedBookieEnsemblePlacementPolicyTest.java | 136 +++++++++++++++++++++
.../persistent/PersistentMessageExpiryMonitor.java | 3 +-
.../compaction/AbstractTwoPhaseCompactor.java | 20 ++-
.../pulsar/compaction/EventTimeOrderCompactor.java | 14 +--
.../service/PersistentMessageFinderTest.java | 58 +++++++++
.../pulsar/client/api/ProducerCleanupTest.java | 6 +-
.../apache/pulsar/compaction/CompactionTest.java | 74 +++++++++++
.../functions/worker/PulsarFunctionTlsTest.java | 35 +++---
pulsar-function-go/pf/instance.go | 41 +++++--
pulsar-function-go/pf/instance_test.go | 32 +++++
.../org/apache/pulsar/websocket/ReaderHandler.java | 36 ++++--
.../apache/pulsar/websocket/ReaderHandlerTest.java | 97 ++++++++++++++-
.../docker-images/latest-version-image/Dockerfile | 1 +
.../go-examples/exceptionFunc/exceptionFunc.go | 11 +-
.../integration/functions/PulsarFunctionsTest.java | 4 +
.../functions/PulsarFunctionsTestBase.java | 1 +
.../functions/go/PulsarFunctionsGoTest.java | 5 +
20 files changed, 613 insertions(+), 75 deletions(-)
copy pulsar-function-go/examples/exclamationFunc/exclamationFunc.go =>
tests/docker-images/latest-version-image/go-examples/exceptionFunc/exceptionFunc.go
(84%)
