This is an automated email from the ASF dual-hosted git repository.
xyuanlu pushed a change to branch ApplicationClusterManager
in repository https://gitbox.apache.org/repos/asf/helix.git
discard e7b4c5386 Exclude on-operation instance from computing min active
replica in WAGED. (#2621)
omit 7c312caf7 Add supporting APIs a isEvacuateFinished and
isReadyForPreparingJoiningCluster for evacuation. (#2618)
omit 2ffb58557 Change instance operation orthogonal to instance enable
(#2615)
omit 0237ef29d Add on-demand rebalance API (#2601)
omit 0b5b54f84 Fix NPR error in test for
TestDelayedAutoRebalanceWithRackaware (#2606)
omit 6cf94f539 Add support for node evacuation. (#2604)
omit ec5ba7578 Add CI test config for ApplicationClusterManager branch
(#2605)
omit 85bbe47d1 Instance Evacuation operation sanity check (#2598)
omit 76ef94699 Implement the on-demand rebalance service (#2595)
omit c023a98be Add API for Instance evacuation (#2588)
add 7a180c9d2 Adjusted decrementing the
missingTopStatePartitionsBeyondThresholdGuage when top-state Instance recovers
after the threshold failure. (#2591)
add b6ae480d2 Fix inconsistent map key formatting in helix-rest
maintenance API (#2583)
add c818b6f29 Stabilize TestCardDealingAdjustmentAlgorithmV2 - sequence
all tests (#2597)
add 792f21162 [apache/helix] -- Fixes #2590 Removed resetting of the
missingTopStatePartitionsBeyondThresholdGauge to avoid incorrect accounting.
add ff4c5cadd DataRecord Serializer
add df1eb6ae9 Inline
add b93f89a06 tests for get, create, set, update, and data change listeners
add 1f80503b6 deserialize test
add b45361ba3 refactor, update with dataRecord
add 17f8ab3fd set test iteration count to 500
add 09649b34c [helix/metaclient] ZkMetaClient Stress Tests (Part 2) (#2523)
add 0e917599c MetaClient Distributed Semaphore API and Permit object
(#2520)
add 53f9fa7c3 Add API for getDataAndStat (#2535)
add c7a0d28fc Lattice MetaClient Distributed Semaphore Implementation
(#2515)
add f41a2c606 MetaClient LockClient and Semaphore Creation Edge Cases and
Added Exception(#2550)
add 6aa7c2cce ZkClient - only register one time watcher for read data when
not using persist listener. (#2555)
add 5389b1739 MultiThreading Stress Test Lattice - Puppy Logic and
Skeleton (Part 1) (#2549)
add 36231faeb Metaclient leader election - basics (#2558)
add b1f59e6f8 Multithreading stress test lattice - CRUD puppies and
Listener Tests (#2548)
add 52fe73818 Metaclient - Leader election - Track participants and add
participant info (#2562)
add 4eacde331 Metaclient - Leader election - leader change event
notification (#2560)
add 26f319608 Lattice LockClient LockInfoSerializer Implementation(#2580)
add c3afa7f27 Lattice Puppy Stress Test Race Condition Fix and Code
Cleanup (#2579)
add 7a96d9ba8 Add stress test for Metaclient leader election (#2574)
add 2e53694f7 Leader election client - Proactively send leader gone event
when disconnect from ZK (#2585)
add fbefa6490 Change TopStateHandoffReportStage to be an Async Stage as it
is the slowest stage in the pipeline. It can be run async since it does not add
to ClusterEvent and simply computes and reports metrics. No following stages
depend on it. (#2610)
add d00a37c0d Changed Log level to DEBUG for the top-state metrics logs,
to avoid logging for every partition.(#2611)
add 0e82bd3fd Fix flaky test TestP2PNoDuplicatedMessage (#2587)
add c9402ea1e Fix the 'BadVersion' exception handling in doSet() code
path. (#2614)
add 279c3f39e Bump jackson-databind in /helix-view-aggregator (#2280)
add c607364c8 Fix TestClusterAggregateMetrics (#2602)
add 989c20c4b Add API for Instance evacuation (#2588)
add ba858b2a0 Implement the on-demand rebalance service (#2595)
add 059f1f60c Instance Evacuation operation sanity check (#2598)
add 7fe7d0a30 Add CI test config for ApplicationClusterManager branch
(#2605)
add eb62d1511 Add support for node evacuation. (#2604)
add 7ab07d034 Fix NPR error in test for
TestDelayedAutoRebalanceWithRackaware (#2606)
add a51c587f7 Add on-demand rebalance API (#2601)
add eff214d92 Change instance operation orthogonal to instance enable
(#2615)
add 96cd0d0e3 Add supporting APIs a isEvacuateFinished and
isReadyForPreparingJoiningCluster for evacuation. (#2618)
add 0922e1f2f Add support for providing default Instance Config to be used
with auto-join and auto-reg (#2609)
new e90f4a5ec Exclude on-operation instance from computing min active
replica in WAGED. (#2621)
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (e7b4c5386)
\
N -- N -- N refs/heads/ApplicationClusterManager (e90f4a5ec)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/helix/HelixManagerProperty.java | 21 +-
.../helix/controller/pipeline/AsyncWorkerType.java | 1 +
.../stages/TopStateHandoffReportStage.java | 33 +-
.../helix/manager/zk/ParticipantManager.java | 14 +-
.../helix/manager/zk/ZkBaseDataAccessor.java | 3 +
.../org/apache/helix/model/InstanceConfig.java | 176 +++++++-
.../monitoring/mbeans/ClusterStatusMonitor.java | 8 +
.../helix/monitoring/mbeans/ResourceMonitor.java | 19 +-
.../main/java/org/apache/helix/util/HelixUtil.java | 15 +-
.../java/org/apache/helix/TestConfigAccessor.java | 9 +-
.../org/apache/helix/TestHelixConfigAccessor.java | 21 +-
.../helix/controller/stages/BaseStageTest.java | 11 +-
.../TestCardDealingAdjustmentAlgorithmV2.java | 24 +-
.../manager/MockParticipantManager.java | 13 +-
.../messaging/TestP2PNoDuplicatedMessage.java | 33 +-
.../paticipant/TestInstanceAutoJoin.java | 70 +++-
.../helix/manager/zk/TestZkBaseDataAccessor.java | 31 ++
.../org/apache/helix/model/TestInstanceConfig.java | 24 +-
.../mbeans/TestClusterAggregateMetrics.java | 12 +-
.../mbeans/TestTopStateHandoffMetrics.java | 42 +-
.../test/resources/TestTopStateHandoffMetrics.json | 36 +-
.../server/resources/helix/ClusterAccessor.java | 7 +-
.../helix/rest/server/TestClusterAccessor.java | 7 +-
helix-view-aggregator/pom.xml | 2 +-
.../helix/metaclient/api/MetaClientInterface.java | 19 +-
.../org/apache/helix/metaclient/api/OpResult.java | 2 +-
.../helix/metaclient/datamodel/DataRecord.java | 5 +
...ion.java => MetaClientNodeExistsException.java} | 11 +-
.../helix/metaclient/impl/zk/ZkMetaClient.java | 73 ++--
.../impl/zk/adapter/DataListenerAdapter.java | 1 +
.../metaclient/impl/zk/util/ZkMetaClientUtil.java | 12 +
.../leaderelection/LeaderElectionClient.java | 318 ++++++++++++--
.../LeaderElectionListenerInterface.java | 15 +-
.../LeaderElectionListenerInterfaceAdapter.java | 64 +++
.../recipes/leaderelection/LeaderInfo.java | 34 +-
.../leaderelection/LeaderInfoSerializer.java | 42 ++
.../recipes/lock/DataRecordSerializer.java | 19 +-
.../recipes/lock/DistributedSemaphore.java | 248 +++++++++++
.../helix/metaclient/recipes/lock/LockClient.java | 19 +-
.../helix/metaclient/recipes/lock/LockInfo.java | 30 +-
.../recipes/lock/LockInfoSerializer.java | 26 +-
.../helix/metaclient/recipes/lock/Permit.java | 87 ++++
.../helix/metaclient/MetaClientTestUtil.java | 25 ++
.../zk/TestConnectStateChangeListenerAndRetry.java | 42 +-
.../zk/TestMultiThreadStressTest/CreatePuppy.java | 77 ++++
.../zk/TestMultiThreadStressTest/DeletePuppy.java | 67 +++
.../zk/TestMultiThreadStressTest/GetPuppy.java | 67 +++
.../zk/TestMultiThreadStressTest/SetPuppy.java | 70 ++++
.../TestMultiThreadStressZKClient.java | 350 ++++++++++++++++
.../zk/TestMultiThreadStressTest/UpdatePuppy.java | 73 ++++
.../metaclient/impl/zk/TestStressZkClient.java | 455 ++++++++++++++++++++-
.../apache/helix/metaclient/impl/zk/TestUtil.java | 92 +++++
.../helix/metaclient/impl/zk/TestZkMetaClient.java | 50 +++
.../metaclient/impl/zk/ZkMetaClientTestBase.java | 2 +
.../helix/metaclient/puppy/AbstractPuppy.java | 91 +++++
.../apache/helix/metaclient/puppy/ExecDelay.java | 63 +++
.../helix/metaclient/puppy/PuppyManager.java | 64 +++
.../apache/helix/metaclient/puppy/PuppyMode.java | 10 +-
.../apache/helix/metaclient/puppy/PuppySpec.java | 42 +-
.../leaderelection/LeaderElectionPuppy.java | 92 +++++
.../recipes/leaderelection/TestLeaderElection.java | 361 ++++++++++++++++
.../TestMultiClientLeaderElection.java | 85 ++++
.../recipes/lock/DistributedSemaphoreTest.java | 105 +++++
.../metaclient/recipes/lock/LockClientTest.java | 36 +-
.../datamodel/serializer/ZNRecordSerializer.java | 2 +-
.../apache/helix/zookeeper/zkclient/ZkClient.java | 2 +-
.../zkclient/TestZkClientPersistWatcher.java | 75 ++--
67 files changed, 3670 insertions(+), 385 deletions(-)
copy
meta-client/src/main/java/org/apache/helix/metaclient/exception/{MetaClientTimeoutException.java
=> MetaClientNodeExistsException.java} (75%)
create mode 100644
meta-client/src/main/java/org/apache/helix/metaclient/recipes/leaderelection/LeaderElectionListenerInterfaceAdapter.java
create mode 100644
meta-client/src/main/java/org/apache/helix/metaclient/recipes/leaderelection/LeaderInfoSerializer.java
copy
helix-core/src/main/java/org/apache/helix/healthcheck/ParticipantHealthReportCollector.java
=>
meta-client/src/main/java/org/apache/helix/metaclient/recipes/lock/DataRecordSerializer.java
(70%)
create mode 100644
meta-client/src/main/java/org/apache/helix/metaclient/recipes/lock/DistributedSemaphore.java
copy
helix-core/src/main/java/org/apache/helix/store/ZNRecordJsonSerializer.java =>
meta-client/src/main/java/org/apache/helix/metaclient/recipes/lock/LockInfoSerializer.java
(60%)
create mode 100644
meta-client/src/main/java/org/apache/helix/metaclient/recipes/lock/Permit.java
create mode 100644
meta-client/src/test/java/org/apache/helix/metaclient/MetaClientTestUtil.java
create mode 100644
meta-client/src/test/java/org/apache/helix/metaclient/impl/zk/TestMultiThreadStressTest/CreatePuppy.java
create mode 100644
meta-client/src/test/java/org/apache/helix/metaclient/impl/zk/TestMultiThreadStressTest/DeletePuppy.java
create mode 100644
meta-client/src/test/java/org/apache/helix/metaclient/impl/zk/TestMultiThreadStressTest/GetPuppy.java
create mode 100644
meta-client/src/test/java/org/apache/helix/metaclient/impl/zk/TestMultiThreadStressTest/SetPuppy.java
create mode 100644
meta-client/src/test/java/org/apache/helix/metaclient/impl/zk/TestMultiThreadStressTest/TestMultiThreadStressZKClient.java
create mode 100644
meta-client/src/test/java/org/apache/helix/metaclient/impl/zk/TestMultiThreadStressTest/UpdatePuppy.java
create mode 100644
meta-client/src/test/java/org/apache/helix/metaclient/puppy/AbstractPuppy.java
create mode 100644
meta-client/src/test/java/org/apache/helix/metaclient/puppy/ExecDelay.java
create mode 100644
meta-client/src/test/java/org/apache/helix/metaclient/puppy/PuppyManager.java
copy
helix-core/src/main/java/org/apache/helix/controller/stages/package-info.java
=> meta-client/src/test/java/org/apache/helix/metaclient/puppy/PuppyMode.java
(86%)
copy
helix-core/src/main/java/org/apache/helix/monitoring/StateTransitionDataPoint.java
=> meta-client/src/test/java/org/apache/helix/metaclient/puppy/PuppySpec.java
(54%)
create mode 100644
meta-client/src/test/java/org/apache/helix/metaclient/recipes/leaderelection/LeaderElectionPuppy.java
create mode 100644
meta-client/src/test/java/org/apache/helix/metaclient/recipes/leaderelection/TestLeaderElection.java
create mode 100644
meta-client/src/test/java/org/apache/helix/metaclient/recipes/leaderelection/TestMultiClientLeaderElection.java
create mode 100644
meta-client/src/test/java/org/apache/helix/metaclient/recipes/lock/DistributedSemaphoreTest.java
