You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@pulsar.apache.org by pe...@apache.org on 2020/06/09 01:05:35 UTC

[pulsar] branch master updated (2add228d -> 70d584c)

This is an automated email from the ASF dual-hosted git repository.

penghui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.


    from 2add228d [pulsar-client-cpp] Support Seek on Partitioned Topic by Time (#7198)
     add 70d584c  Fatal errors in worker service should shutdown broker as well (#7212)

No new revisions were added by this update.

Summary of changes:
 .../broker/MessagingServiceShutdownHook.java       |  1 -
 .../org/apache/pulsar/broker/PulsarService.java    |  6 ++-
 .../pulsar/broker/service/BrokerService.java       |  2 +
 .../worker/PulsarWorkerAssignmentTest.java         |  2 +-
 .../pulsar/functions/worker/ErrorNotifier.java     | 41 ++++++-------------
 .../{ErrorNotifier.java => ErrorNotifierImpl.java} | 47 +++++++++++-----------
 .../worker/ErrorNotifierShutdownServiceImpl.java   | 29 +++++++------
 .../functions/worker/FunctionAssignmentTailer.java |  2 +-
 .../org/apache/pulsar/functions/worker/Worker.java |  2 +-
 .../worker/FunctionRuntimeManagerTest.java         |  2 +-
 10 files changed, 63 insertions(+), 71 deletions(-)
 copy pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/{ErrorNotifier.java => ErrorNotifierImpl.java} (55%)
 copy pulsar-io/batch-data-generator/src/main/java/org/apache/pulsar/io/batchdatagenerator/BatchDataGeneratorPrintSink.java => pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/ErrorNotifierShutdownServiceImpl.java (55%)