[review] Fixes typo in method name

XComp · XComp · commit ef92f6afded2 · 2024-06-28T16:04:44.000+02:00
diff --git a/flink-tests/src/test/java/org/apache/flink/test/util/RestClientHelper.java b/flink-tests/src/test/java/org/apache/flink/test/util/RestClientHelper.java
@@ -37,7 +37,7 @@ public RestClusterClient<?> getRestClusterClient() {
         return delegate;
     }
 
-    public int getNumberTasksByState(JobID jobId, ExecutionState state) {
+    public int getNumberOfTasksByState(JobID jobId, ExecutionState state) {
         final JobDetailsInfo jobDetailsInfo = delegate.getJobDetails(jobId).join();
         return jobDetailsInfo.getJobVertexInfos().stream()
                 .map(JobDetailsInfo.JobVertexDetailsInfo::getTasksPerState)
@@ -47,7 +47,7 @@ public int getNumberTasksByState(JobID jobId, ExecutionState state) {
     }
 
     public int getNumberOfRunningTasks(JobID jobId) {
-        return getNumberTasksByState(jobId, ExecutionState.RUNNING);
+        return getNumberOfTasksByState(jobId, ExecutionState.RUNNING);
     }
 
     public void waitForRunningTasks(JobID jobId, int expectedNumberOfRunningTasks)

Original file line number	Diff line number	Diff line change
`@@ -37,7 +37,7 @@ public RestClusterClient<?> getRestClusterClient() {`
`37`	`37`	`return delegate;`
`38`	`38`	`}`
`39`	`39`
`40`		`- public int getNumberTasksByState(JobID jobId, ExecutionState state) {`
	`40`	`+ public int getNumberOfTasksByState(JobID jobId, ExecutionState state) {`
`41`	`41`	`final JobDetailsInfo jobDetailsInfo = delegate.getJobDetails(jobId).join();`
`42`	`42`	`return jobDetailsInfo.getJobVertexInfos().stream()`
`43`	`43`	`.map(JobDetailsInfo.JobVertexDetailsInfo::getTasksPerState)`
`@@ -47,7 +47,7 @@ public int getNumberTasksByState(JobID jobId, ExecutionState state) {`
`47`	`47`	`}`
`48`	`48`
`49`	`49`	`public int getNumberOfRunningTasks(JobID jobId) {`
`50`		`- return getNumberTasksByState(jobId, ExecutionState.RUNNING);`
	`50`	`+ return getNumberOfTasksByState(jobId, ExecutionState.RUNNING);`
`51`	`51`	`}`
`52`	`52`
`53`	`53`	`public void waitForRunningTasks(JobID jobId, int expectedNumberOfRunningTasks)`