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 aa992e8 fix(functions): missing runtime set in GoInstanceConfig
(#13031)
add 6e3b736 Integration tests for function-worker rebalance and drain
operations. (#13058)
No new revisions were added by this update.
Summary of changes:
... => PulsarWorkerRebalanceDrainProcessTest.java} | 5 +-
.../java/PulsarWorkerRebalanceDrainTest.java | 393 +++++++++++++++++++++
...a => PulsarWorkerRebalanceDrainThreadTest.java} | 4 +-
.../integration/topologies/PulsarCluster.java | 21 ++
.../src/test/resources/pulsar-process.xml | 2 +
.../src/test/resources/pulsar-thread.xml | 2 +
6 files changed, 422 insertions(+), 5 deletions(-)
copy
tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/java/{PulsarFunctionsJavaProcessTest.java
=> PulsarWorkerRebalanceDrainProcessTest.java} (87%)
create mode 100644
tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/java/PulsarWorkerRebalanceDrainTest.java
copy
tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/java/{PulsarFunctionsJavaThreadTest.java
=> PulsarWorkerRebalanceDrainThreadTest.java} (87%)