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%)