This is an automated email from the ASF dual-hosted git repository.
jerrypeng pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from d7e68c0 Allow memory limit to be set for the pulsar client used in
the ThreadRuntime in Pulsar Functions (#9320)
add 1ff1fcd Optimize built-in source/sink startup by eliminating
redundant NAR unpacking and checksum calculation (#9413)
No new revisions were added by this update.
Summary of changes:
.../worker/PulsarFunctionLocalRunTest.java | 66 +++++---
.../apache/pulsar/io/PulsarFunctionE2ETest.java | 68 +++++++-
.../apache/pulsar/common/nar/NarClassLoader.java | 7 +-
.../pulsar/common/util/ClassLoaderUtils.java | 6 +-
.../org/apache/pulsar/functions/LocalRunner.java | 90 +++++++----
.../pulsar/functions/utils/FunctionCommon.java | 180 ++++++++++++++++-----
.../pulsar/functions/utils/SinkConfigUtils.java | 153 ++++++------------
.../pulsar/functions/utils/SourceConfigUtils.java | 135 ++++------------
.../utils/io/{Connectors.java => Connector.java} | 24 ++-
.../pulsar/functions/utils/io/ConnectorUtils.java | 102 ++++++------
.../functions/utils/SinkConfigUtilsTest.java | 29 +++-
.../functions/utils/SourceConfigUtilsTest.java | 24 ++-
.../pulsar/functions/worker/ConnectorsManager.java | 36 +++--
.../pulsar/functions/worker/FunctionActioner.java | 64 ++++----
.../functions/worker/rest/api/ComponentImpl.java | 9 ++
.../functions/worker/rest/api/SinksImpl.java | 35 ++--
.../functions/worker/rest/api/SourcesImpl.java | 37 +++--
.../worker/rest/api/v3/SinkApiV3ResourceTest.java | 21 +--
.../rest/api/v3/SourceApiV3ResourceTest.java | 34 +++-
19 files changed, 634 insertions(+), 486 deletions(-)
rename
pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/io/{Connectors.java
=> Connector.java} (69%)
