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 8c1090e94b1 [fix][sec][branch-4.0] Upgrade avro to 1.11.5 to address
CVE-2025-33042 (#25788)
new d631d2c3e58 [fix][proxy] Close channel on connection failure (#25770)
new 7a9b5c7233d [fix][broker] Fix PulsarService.closeAsync where
Condition.signalAll was called without holding a lock (#25777)
new c6ecb685542 [improve][build] Upgrade org.apache.kerby:kerb-simplekdc
from 1.1.1 to 2.1.1 (#25785)
new 308aa0f33bf [improve][fn] make built-in connector reload incremental
(#25773)
new 95c8608f05a [refactor][fn] Use Map instead of TreeMap for
connector/function API types (#25790)
new aeda5ca1b28 [improve][broker] Prevent stale replicator pending reads
after termination (#25767)
The 6 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:
pom.xml | 2 +-
.../org/apache/pulsar/broker/PulsarService.java | 9 +-
.../service/persistent/PersistentReplicator.java | 21 ++-
.../pulsar/broker/PulsarServiceCloseTest.java | 28 ++++
.../PersistentReplicatorInflightTaskTest.java | 60 +++++++++
.../org/apache/pulsar/common/nar/FileUtils.java | 31 +++++
.../org/apache/pulsar/common/nar/NarUnpacker.java | 33 +----
.../org/apache/pulsar/functions/LocalRunner.java | 11 +-
.../pulsar/functions/worker/ConnectorsManager.java | 33 +++--
.../pulsar/functions/worker/FunctionsManager.java | 9 +-
.../ConnectorsManagerReloadConnectorsTest.java | 82 ++++++++++++
.../functions/utils/functions/FunctionUtils.java | 3 +-
.../pulsar/functions/utils/io/Connector.java | 26 ++++
.../pulsar/functions/utils/io/ConnectorUtils.java | 80 +++++++++++-
...ckage-info.java => ReloadConnectorsResult.java} | 10 ++
.../utils/io/ConnectorUtilsReloadTest.java | 141 +++++++++++++++++++++
.../pulsar/proxy/server/DirectProxyHandler.java | 4 +
17 files changed, 521 insertions(+), 62 deletions(-)
create mode 100644
pulsar-functions/runtime/src/test/java/org/apache/pulsar/functions/worker/ConnectorsManagerReloadConnectorsTest.java
copy
pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/io/{package-info.java
=> ReloadConnectorsResult.java} (72%)
create mode 100644
pulsar-functions/utils/src/test/java/org/apache/pulsar/functions/utils/io/ConnectorUtilsReloadTest.java
