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 9b178c8 [pulsar-perf] Supports `tlsAllowInsecureConnection` in pulsar-perf produce/consume/read. (#7300) add 8e4906c Implement rebalance mechanism in Pulsar Functions (#7388) No new revisions were added by this update. Summary of changes: .../org/apache/pulsar/broker/admin/v2/Worker.java | 15 +++ .../pulsar/functions/worker/WorkerConfig.java | 14 +-- .../pulsar/functions/worker/SchedulerManager.java | 83 ++++++++++---- .../functions/worker/rest/api/WorkerImpl.java | 30 ++++++ .../worker/rest/api/v2/WorkerApiV2Resource.java | 18 ++++ .../functions/worker/scheduler/IScheduler.java | 18 ++++ .../worker/scheduler/RoundRobinScheduler.java | 120 +++++++++++++++++++++ .../worker/scheduler/RoundRobinSchedulerTest.java | 78 ++++++++++++++ 8 files changed, 351 insertions(+), 25 deletions(-) create mode 100644 pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/scheduler/RoundRobinSchedulerTest.java