This is an automated email from the ASF dual-hosted git repository.
junkaixue pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/helix.git
The following commit(s) were added to refs/heads/master by this push:
new 57940415c Fix typos in TaskDriver Javadoc and test methods (#3201)
57940415c is described below
commit 57940415cb74ea65dc5dfeb064b6e2a7593009e8
Author: Mohd Irshad <[email protected]>
AuthorDate: Thu Nov 5 23:52:10 2026 +0530
Fix typos in TaskDriver Javadoc and test methods (#3201)
Fix minor typos:
compatability -> compatibility in TaskDriver Javadoc
occurenceSet -> occurrenceSet in TestEspressoStorageClusterIdealState
pollForMBeanExistance -> pollForMBeanExistence in TestDisableResourceMbean
Signed-off-by: siddiqueirshad <[email protected]>
---
helix-core/src/main/java/org/apache/helix/task/TaskDriver.java | 2 +-
.../org/apache/helix/TestEspressoStorageClusterIdealState.java | 6 +++---
.../apache/helix/monitoring/mbeans/TestDisableResourceMbean.java | 8 ++++----
3 files changed, 8 insertions(+), 8 deletions(-)
diff --git a/helix-core/src/main/java/org/apache/helix/task/TaskDriver.java
b/helix-core/src/main/java/org/apache/helix/task/TaskDriver.java
index 0e1b9b1d9..66a25e52a 100644
--- a/helix-core/src/main/java/org/apache/helix/task/TaskDriver.java
+++ b/helix-core/src/main/java/org/apache/helix/task/TaskDriver.java
@@ -994,7 +994,7 @@ public class TaskDriver {
/**
* TODO: IdealStates are no longer used by Task Framework. This function
deletes IdealStates for
- * TODO: backward compatability purpose; this behavior will be removed later.
+ * TODO: backward compatibility purpose; this behavior will be removed later.
* Public synchronized method to wait for a delete operation to fully
complete with timeout.
* When this method returns, it means that a queue (workflow) has been
completely deleted, meaning
* its IdealState, WorkflowConfig, and WorkflowContext have all been deleted.
diff --git
a/helix-core/src/test/java/org/apache/helix/TestEspressoStorageClusterIdealState.java
b/helix-core/src/test/java/org/apache/helix/TestEspressoStorageClusterIdealState.java
index 8eb0e00c5..0bc27f4fe 100644
---
a/helix-core/src/test/java/org/apache/helix/TestEspressoStorageClusterIdealState.java
+++
b/helix-core/src/test/java/org/apache/helix/TestEspressoStorageClusterIdealState.java
@@ -183,12 +183,12 @@ public class TestEspressoStorageClusterIdealState {
int minSlaves = Integer.MAX_VALUE, maxSlaves = Integer.MIN_VALUE;
for (String hostInstance : slaveAssignmentMap.keySet()) {
List<Integer> slaveAssignment = slaveAssignmentMap.get(hostInstance);
- Set<Integer> occurenceSet = new HashSet<Integer>();
+ Set<Integer> occurrenceSet = new HashSet<Integer>();
// Each slave should occur only once in the list, since the list is
per-node slaves
for (Integer slavePartition : slaveAssignment) {
- AssertJUnit.assertTrue(!occurenceSet.contains(slavePartition));
- occurenceSet.add(slavePartition);
+ AssertJUnit.assertTrue(!occurrenceSet.contains(slavePartition));
+ occurrenceSet.add(slavePartition);
slaveCountMap.put(slavePartition, slaveCountMap.get(slavePartition)
+ 1);
}
diff --git
a/helix-core/src/test/java/org/apache/helix/monitoring/mbeans/TestDisableResourceMbean.java
b/helix-core/src/test/java/org/apache/helix/monitoring/mbeans/TestDisableResourceMbean.java
index 63e1a81b0..ab69c40c6 100644
---
a/helix-core/src/test/java/org/apache/helix/monitoring/mbeans/TestDisableResourceMbean.java
+++
b/helix-core/src/test/java/org/apache/helix/monitoring/mbeans/TestDisableResourceMbean.java
@@ -91,9 +91,9 @@ public class TestDisableResourceMbean extends ZkUnitTestBase {
Assert.assertTrue(clusterVerifier.verifyByPolling());
// Verify the bean was created for TestDB0, but not for TestDB1.
- pollForMBeanExistance(getMbeanName("TestDB0", clusterName), true);
- pollForMBeanExistance(getMbeanName("TestDB1", clusterName), false);
- pollForMBeanExistance(getMbeanName("TestDB2", clusterName), true);
+ pollForMBeanExistence(getMbeanName("TestDB0", clusterName), true);
+ pollForMBeanExistence(getMbeanName("TestDB1", clusterName), false);
+ pollForMBeanExistence(getMbeanName("TestDB2", clusterName), true);
controller.syncStop();
for (MockParticipantManager participant : participants) {
@@ -103,7 +103,7 @@ public class TestDisableResourceMbean extends
ZkUnitTestBase {
System.out.println("END " + clusterName + " at " + new
Date(System.currentTimeMillis()));
}
- private void pollForMBeanExistance(final ObjectName objectName, boolean
expectation)
+ private void pollForMBeanExistence(final ObjectName objectName, boolean
expectation)
throws Exception {
boolean result = TestHelper.verify(new TestHelper.Verifier() {
@Override