[pulsar] branch master updated (0ef7baa -> 4cbfa70)

[xy...@apache.org]

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

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


    from 0ef7baa  Fix switchBackDelayNs failure problem in class of  AutoClusterFailover (#14442)
     add 4cbfa70  [CheckStyle]Enable pulsar-functions-worker checkstyle (#14351)

No new revisions were added by this update.

Summary of changes:
 pulsar-functions/worker/pom.xml                    |  22 +-
 .../worker/ClusterServiceCoordinator.java          |   9 +-
 .../pulsar/functions/worker/ErrorNotifier.java     |   6 +-
 .../pulsar/functions/worker/FunctionActioner.java  | 107 +++--
 .../functions/worker/FunctionAssignmentTailer.java |   9 +-
 .../functions/worker/FunctionMetaDataManager.java  |  16 +-
 .../worker/FunctionMetaDataTopicTailer.java        |   3 +-
 .../functions/worker/FunctionRuntimeManager.java   | 162 ++++---
 .../pulsar/functions/worker/FunctionsManager.java  |   2 +-
 .../functions/worker/FunctionsStatsGenerator.java  |  15 +-
 .../pulsar/functions/worker/LeaderService.java     |  15 +-
 .../pulsar/functions/worker/MembershipManager.java |  31 +-
 .../pulsar/functions/worker/MetricsGenerator.java  |   1 -
 .../functions/worker/PulsarWorkerService.java      |   2 +-
 .../pulsar/functions/worker/SchedulerManager.java  |  55 ++-
 .../org/apache/pulsar/functions/worker/Worker.java |   5 +-
 .../functions/worker/WorkerStatsManager.java       |  65 ++-
 .../pulsar/functions/worker/WorkerUtils.java       |  77 ++--
 .../functions/worker/dlog/DLInputStream.java       |   5 +-
 .../functions/worker/dlog/DLOutputStream.java      |   5 +-
 .../functions/worker/dlog}/package-info.java       |   2 +-
 .../pulsar/functions/worker}/package-info.java     |   2 +-
 .../worker/rest/ConfigurationResource.java         |   1 -
 .../functions/worker/rest/FunctionApiResource.java |   1 -
 .../pulsar/functions/worker/rest/Resources.java    |   9 +-
 .../pulsar/functions/worker/rest/RestUtils.java    |   5 +-
 .../worker/rest/WorkerReadinessResource.java       |   6 +-
 .../pulsar/functions/worker/rest/WorkerServer.java |  16 +-
 .../functions/worker/rest/api/ComponentImpl.java   | 507 +++++++++++++--------
 .../functions/worker/rest/api/FunctionsImpl.java   | 235 ++++++----
 .../functions/worker/rest/api/FunctionsImplV2.java |  54 ++-
 .../worker/rest/api/FunctionsMetricsResource.java  |  15 +-
 .../functions/worker/rest/api/SinksImpl.java       | 176 ++++---
 .../functions/worker/rest/api/SourcesImpl.java     | 222 +++++----
 .../functions/worker/rest/api/WorkerImpl.java      |  40 +-
 .../functions/worker/rest/api}/package-info.java   |   2 +-
 .../worker/rest/api/v2/FunctionsApiV2Resource.java |  53 ++-
 .../worker/rest/api/v2/WorkerApiV2Resource.java    |  14 +-
 .../rest/api/v2/WorkerStatsApiV2Resource.java      |  15 +-
 .../worker/rest/api/v2}/package-info.java          |   2 +-
 .../worker/rest/api/v3/FunctionsApiV3Resource.java |  53 ++-
 .../worker/rest/api/v3/SinkApiV3Resource.java      |   1 -
 .../worker/rest/api/v3/SinksApiV3Resource.java     |  58 +--
 .../worker/rest/api/v3/SourceApiV3Resource.java    |   1 -
 .../worker/rest/api/v3/SourcesApiV3Resource.java   |  59 +--
 .../worker/rest/api/v3}/package-info.java          |   2 +-
 .../functions/worker/rest}/package-info.java       |   2 +-
 .../functions/worker/scheduler/IScheduler.java     |  16 +-
 .../worker/scheduler/RoundRobinScheduler.java      |  26 +-
 .../functions/worker/scheduler}/package-info.java  |   2 +-
 .../worker/service/WorkerServiceLoader.java        |   1 -
 .../functions/worker/service/api/Component.java    | 199 ++++----
 .../functions/worker/service/api/Functions.java    |  72 +--
 .../functions/worker/service/api/FunctionsV2.java  |  14 +-
 .../pulsar/functions/worker/service/api/Sinks.java |  64 +--
 .../functions/worker/service/api/Sources.java      |  64 +--
 .../functions/worker/service/api/Workers.java      |  11 +-
 .../functions/worker/service/api/package-info.java |   2 +-
 .../functions/worker/service/package-info.java     |   2 +-
 .../worker/ClusterServiceCoordinatorTest.java      |   6 +-
 .../functions/worker/FunctionActionerTest.java     |  20 +-
 .../worker/FunctionAssignmentTailerTest.java       |  49 +-
 .../worker/FunctionMetaDataManagerTest.java        |   8 +-
 .../worker/FunctionRuntimeManagerTest.java         | 111 +++--
 .../pulsar/functions/worker/LeaderServiceTest.java |  15 +-
 .../functions/worker/MembershipManagerTest.java    |  22 +-
 .../functions/worker/SchedulerManagerTest.java     |  44 +-
 .../pulsar/functions/worker/WorkerUtilsTest.java   |  32 +-
 .../functions/worker/dlog/DLInputStreamTest.java   |   1 -
 .../functions/worker/dlog/DLOutputStreamTest.java  |   1 -
 .../functions/worker/executor/MockClockTest.java   |   1 -
 .../worker/executor/MockExecutorController.java    |   1 -
 .../executor/MockExecutorControllerTest.java       |   1 -
 .../worker/rest/api/FunctionsImplTest.java         |  79 ++--
 .../rest/api/v2/FunctionApiV2ResourceTest.java     |  59 ++-
 .../rest/api/v3/FunctionApiV3ResourceTest.java     |  48 +-
 .../worker/rest/api/v3/SinkApiV3ResourceTest.java  |  15 +-
 .../rest/api/v3/SourceApiV3ResourceTest.java       |  28 +-
 .../worker/scheduler/RoundRobinSchedulerTest.java  |   9 +-
 79 files changed, 1788 insertions(+), 1400 deletions(-)
 copy {managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl => pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/dlog}/package-info.java (94%)
 copy {managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl => pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker}/package-info.java (94%)
 copy {managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl => pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api}/package-info.java (93%)
 copy {managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl => pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v2}/package-info.java (93%)
 copy {managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl => pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v3}/package-info.java (93%)
 copy {managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl => pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest}/package-info.java (94%)
 copy {managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl => pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/scheduler}/package-info.java (93%)