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
