This is an automated email from the ASF dual-hosted git repository.
technoboy pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from d0d626be8f5 [improve][cli] Allow pulser-client consume create a
replicated subscription (#20316)
add 43a989862f5 [improve][fn] Use functions classloader in
TopicSchema.newSchemaInstance() to fix ClassNotFoundException when using custom
SerDe classes. (targeted for master) (#20115)
No new revisions were added by this update.
Summary of changes:
.../org/apache/pulsar/functions/instance/ContextImpl.java | 2 +-
.../java/org/apache/pulsar/functions/sink/PulsarSink.java | 2 +-
.../org/apache/pulsar/functions/source/PulsarSource.java | 6 +++---
.../functions/source/SingleConsumerPulsarSource.java | 11 ++++-------
.../org/apache/pulsar/functions/source/TopicSchema.java | 15 ++++++++++++---
.../apache/pulsar/functions/source/TopicSchemaTest.java | 8 +++++---
.../tests/integration/functions/PulsarFunctionsTest.java | 8 ++++----
.../integration/functions/PulsarFunctionsTestBase.java | 2 +-
.../functions/java/PulsarFunctionsJavaTest.java | 11 +++++++----
.../functions/java/PulsarWorkerRebalanceDrainTest.java | 15 +++++++++------
.../integration/functions/utils/CommandGenerator.java | 10 +++++-----
11 files changed, 52 insertions(+), 38 deletions(-)
