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 306cf99 Fix NPE in ClientCnx (#9761) add 86daf60 Issue-9402: [functions] Added ImmediateTrigger class and unit tests (#9727) No new revisions were added by this update. Summary of changes: pulsar-broker/pom.xml | 16 ++ .../apache/pulsar/io/PulsarFunctionE2ETest.java | 202 ++++++++++++++++++++- .../io/batchdiscovery/ImmediateTriggerer.java} | 45 +++-- pulsar-io/pom.xml | 1 + 4 files changed, 238 insertions(+), 26 deletions(-) copy pulsar-io/{data-generator/src/main/java/org/apache/pulsar/io/datagenerator/DataGeneratorPrintSink.java => batch-discovery-triggerers/src/main/java/org/apache/pulsar/io/batchdiscovery/ImmediateTriggerer.java} (60%)