This is an automated email from the ASF dual-hosted git repository. arvid pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit eb58aa1ab7bdbbcbf07de9726b4c8a81d8e5ab0e Author: qianchutao <[email protected]> AuthorDate: Mon Sep 27 23:52:31 2021 +0800 [hotfix] Fix typo multiple word mistakes --- docs/content.zh/docs/deployment/elastic_scaling.md | 2 +- docs/content.zh/docs/ops/debugging/debugging_classloading.md | 2 +- .../docs/deployment/resource-providers/standalone/overview.md | 4 ++-- docs/content/docs/ops/debugging/debugging_classloading.md | 2 +- .../kubeclient/decorators/InitJobManagerDecoratorAccountTest.java | 6 +++--- flink-python/pyflink/datastream/state_backend.py | 2 +- .../main/java/org/apache/flink/runtime/minicluster/MiniCluster.java | 2 +- .../runtime/resourcemanager/slotmanager/FineGrainedSlotManager.java | 6 +++--- .../runtime/taskexecutor/TaskExecutorRegistrationRejection.java | 2 +- .../apache/flink/runtime/taskexecutor/slot/TaskSlotTableImpl.java | 2 +- .../java/org/apache/flink/runtime/dispatcher/DispatcherTest.java | 6 +++--- 11 files changed, 18 insertions(+), 18 deletions(-) diff --git a/docs/content.zh/docs/deployment/elastic_scaling.md b/docs/content.zh/docs/deployment/elastic_scaling.md index 24a6517..062cd7b 100644 --- a/docs/content.zh/docs/deployment/elastic_scaling.md +++ b/docs/content.zh/docs/deployment/elastic_scaling.md @@ -127,7 +127,7 @@ Adaptive 调度器可以基于现有的 Slot 调整 Job 的并行度。它会在 你也可以不使用 Reactive 模式而仅使用 Adaptive 调度器，但这种情况会有如下的局限性： - 如果你在 Session 集群上使用 Adaptive 调度器，在这个集群中运行的多个 Job，他们间 Slot 的分布是无法保证的。 -相比默认的调度器，Adaptive 调度器其中一个优势在于，它能够优雅地处理 TaskManger 丢失所造成的问题，因为对它来说就仅仅是缩容。 +相比默认的调度器，Adaptive 调度器其中一个优势在于，它能够优雅地处理 TaskManager 丢失所造成的问题，因为对它来说就仅仅是缩容。 ### 用法 diff --git a/docs/content.zh/docs/ops/debugging/debugging_classloading.md b/docs/content.zh/docs/ops/debugging/debugging_classloading.md index 177f92e..e2c0512 100644 --- a/docs/content.zh/docs/ops/debugging/debugging_classloading.md +++ b/docs/content.zh/docs/ops/debugging/debugging_classloading.md @@ -108,7 +108,7 @@ To add new packages to be *parent-first* loaded, please set the `classloader.par ## Avoiding Dynamic Classloading for User Code -All components (JobManger, TaskManager, Client, ApplicationMaster, ...) log their classpath setting on startup. +All components (JobManager, TaskManager, Client, ApplicationMaster, ...) log their classpath setting on startup. They can be found as part of the environment information at the beginning of the log. When running a setup where the JobManager and TaskManagers are exclusive to one particular job, one can put user code JAR files diff --git a/docs/content/docs/deployment/resource-providers/standalone/overview.md b/docs/content/docs/deployment/resource-providers/standalone/overview.md index fb9393f..4ccab51 100644 --- a/docs/content/docs/deployment/resource-providers/standalone/overview.md +++ b/docs/content/docs/deployment/resource-providers/standalone/overview.md @@ -36,7 +36,7 @@ under the License. ## Getting Started -This *Getting Started* section guides you through the local setup (on one machine, but in separate processes) of a Flink cluster. This can easily be expanded to set up a distributed standalone cluster, which we describe in the [reference section](#example-2-start-a-distributed-cluster-jobmangers). +This *Getting Started* section guides you through the local setup (on one machine, but in separate processes) of a Flink cluster. This can easily be expanded to set up a distributed standalone cluster, which we describe in the [reference section](#example-2-start-a-distributed-cluster-jobmanagers). ### Introduction @@ -156,7 +156,7 @@ localhost localhost ``` -##### Example 2: Start a distributed cluster JobMangers +##### Example 2: Start a distributed cluster JobManagers This assumes a cluster with 4 machines (`master1, worker1, worker2, worker3`), which all can reach each other over the network. diff --git a/docs/content/docs/ops/debugging/debugging_classloading.md b/docs/content/docs/ops/debugging/debugging_classloading.md index 50898bf..0bb26b2 100644 --- a/docs/content/docs/ops/debugging/debugging_classloading.md +++ b/docs/content/docs/ops/debugging/debugging_classloading.md @@ -108,7 +108,7 @@ To add new packages to be *parent-first* loaded, please set the `classloader.par ## Avoiding Dynamic Classloading for User Code -All components (JobManger, TaskManager, Client, ApplicationMaster, ...) log their classpath setting on startup. +All components (JobManager, TaskManager, Client, ApplicationMaster, ...) log their classpath setting on startup. They can be found as part of the environment information at the beginning of the log. When running a setup where the JobManager and TaskManagers are exclusive to one particular job, one can put user code JAR files diff --git a/flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/decorators/InitJobManagerDecoratorAccountTest.java b/flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/decorators/InitJobManagerDecoratorAccountTest.java index 04c8bbc..a123226 100644 --- a/flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/decorators/InitJobManagerDecoratorAccountTest.java +++ b/flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/decorators/InitJobManagerDecoratorAccountTest.java @@ -32,7 +32,7 @@ import static org.hamcrest.Matchers.is; public class InitJobManagerDecoratorAccountTest extends KubernetesJobManagerTestBase { private static final String SERVICE_ACCOUNT_NAME = "service-test"; - private static final String JOB_MANGER_SERVICE_ACCOUNT_NAME = "jm-service-test"; + private static final String JOB_MANAGER_SERVICE_ACCOUNT_NAME = "jm-service-test"; private Pod resultPod; @@ -44,7 +44,7 @@ public class InitJobManagerDecoratorAccountTest extends KubernetesJobManagerTest KubernetesConfigOptions.KUBERNETES_SERVICE_ACCOUNT, SERVICE_ACCOUNT_NAME); this.flinkConfig.set( KubernetesConfigOptions.JOB_MANAGER_SERVICE_ACCOUNT, - JOB_MANGER_SERVICE_ACCOUNT_NAME); + JOB_MANAGER_SERVICE_ACCOUNT_NAME); } @Override @@ -62,6 +62,6 @@ public class InitJobManagerDecoratorAccountTest extends KubernetesJobManagerTest public void testPodServiceAccountName() { assertThat( this.resultPod.getSpec().getServiceAccountName(), - is(JOB_MANGER_SERVICE_ACCOUNT_NAME)); + is(JOB_MANAGER_SERVICE_ACCOUNT_NAME)); } } diff --git a/flink-python/pyflink/datastream/state_backend.py b/flink-python/pyflink/datastream/state_backend.py index 59cd445..d61523f 100644 --- a/flink-python/pyflink/datastream/state_backend.py +++ b/flink-python/pyflink/datastream/state_backend.py @@ -83,7 +83,7 @@ class StateBackend(object, metaclass=ABCMeta): The :class:`EmbeddedRocksDBStateBackend` stores working state in an embedded `RocksDB <http://rocksdb.org/>`_, instance and is able to scale working state to many - terrabytes in size, only limited by available disk space across all task amangers. + terrabytes in size, only limited by available disk space across all task managers. **Raw Bytes Storage and Backends** 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 index db782c9..6272198 100644 --- 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 @@ -615,7 +615,7 @@ public class MiniCluster implements AutoCloseableAsync { private void startTaskManagers() throws Exception { final int numTaskManagers = miniClusterConfiguration.getNumTaskManagers(); - LOG.info("Starting {} TaskManger(s)", numTaskManagers); + LOG.info("Starting {} TaskManager(s)", numTaskManagers); for (int i = 0; i < numTaskManagers; i++) { startTaskManager(); diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedSlotManager.java b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedSlotManager.java index 09b8d52..8872d8c 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedSlotManager.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedSlotManager.java @@ -670,11 +670,11 @@ public class FineGrainedSlotManager implements SlotManager { // --------------------------------------------------------------------------------------------- private void checkTaskManagerTimeouts() { - for (TaskManagerInfo timeoutTaskManger : getTimeOutTaskManagers()) { + for (TaskManagerInfo timeoutTaskManager : getTimeOutTaskManagers()) { if (waitResultConsumedBeforeRelease) { - releaseIdleTaskExecutorIfPossible(timeoutTaskManger); + releaseIdleTaskExecutorIfPossible(timeoutTaskManager); } else { - releaseIdleTaskExecutor(timeoutTaskManger.getInstanceId()); + releaseIdleTaskExecutor(timeoutTaskManager.getInstanceId()); } } } diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorRegistrationRejection.java b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorRegistrationRejection.java index 40da671..6f113be 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorRegistrationRejection.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorRegistrationRejection.java @@ -37,6 +37,6 @@ public class TaskExecutorRegistrationRejection extends RegistrationResponse.Reje @Override public String toString() { - return "Rejected TaskExecutor registration at the ResourceManger because: " + reason; + return "Rejected TaskExecutor registration at the ResourceManager because: " + reason; } } diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlotTableImpl.java b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlotTableImpl.java index ef6b3ec..747766a 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlotTableImpl.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlotTableImpl.java @@ -289,7 +289,7 @@ public class TaskSlotTableImpl<T extends TaskSlotPayload> implements TaskSlotTab Preconditions.checkArgument(requestedIndex < numberSlots); - // The negative requestIndex indicate that the SlotManger allocate a dynamic slot, we + // The negative requestIndex indicate that the SlotManager allocate a dynamic slot, we // transfer the index to an increasing number not less than the numberSlots. int index = requestedIndex < 0 ? nextDynamicSlotIndex() : requestedIndex; ResourceProfile effectiveResourceProfile = diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java index 2daacd2..10dcbe9 100755 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java @@ -1052,7 +1052,7 @@ public class DispatcherTest extends AbstractDispatcherTest { FatalErrorHandler fatalErrorHandler, long initializationTimestamp) throws Exception { - return new BlockingTerminationJobMangerService( + return new BlockingTerminationJobManagerService( jobIdToBlock, future, new DefaultJobMasterServiceProcessFactory( @@ -1075,13 +1075,13 @@ public class DispatcherTest extends AbstractDispatcherTest { } } - private static final class BlockingTerminationJobMangerService + private static final class BlockingTerminationJobManagerService extends JobMasterServiceLeadershipRunner { private final JobID jobIdToBlock; private final CompletableFuture<Void> future; - public BlockingTerminationJobMangerService( + public BlockingTerminationJobManagerService( JobID jobIdToBlock, CompletableFuture<Void> future, JobMasterServiceProcessFactory jobMasterServiceProcessFactory,
