[hotfix] Fix typo in MiniCluster class

This closes apache#14211
blacktooth · Nov 26, 2020 · 1820a2e · 1820a2e
1 parent c008907
commit 1820a2e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java b/flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java
@@ -374,10 +374,10 @@ public void start() throws Exception {
 	}
 
 	@GuardedBy("lock")
-	private void setupDispatcherResourceManagerComponents(Configuration configuration, RpcServiceFactory dispatcherResourceManagreComponentRpcServiceFactory, MetricQueryServiceRetriever metricQueryServiceRetriever) throws Exception {
+	private void setupDispatcherResourceManagerComponents(Configuration configuration, RpcServiceFactory dispatcherResourceManagerComponentRpcServiceFactory, MetricQueryServiceRetriever metricQueryServiceRetriever) throws Exception {
 		dispatcherResourceManagerComponents.addAll(createDispatcherResourceManagerComponents(
 			configuration,
-			dispatcherResourceManagreComponentRpcServiceFactory,
+			dispatcherResourceManagerComponentRpcServiceFactory,
 			haServices,
 			blobServer,
 			heartbeatServices,