[flink] branch master updated: [FLINK-23844][hotfix] Fix spelling mistakes for "async" (#16868)

[jark]

This is an automated email from the ASF dual-hosted git repository.

jark pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new d5cdd6f  [FLINK-23844][hotfix] Fix spelling mistakes for "async" 
(#16868)
d5cdd6f is described below

commit d5cdd6f3b207c01b3ff7dd363d07527e0185f347
Author: hapihu <w.gh...@qq.com>
AuthorDate: Wed Aug 18 10:33:59 2021 +0800

    [FLINK-23844][hotfix] Fix spelling mistakes for "async" (#16868)
---
 .../flink/connector/hbase2/source/HBaseRowDataAsyncLookupFunction.java  | 2 +-
 .../flink/streaming/api/operators/async/AsyncWaitOperatorTest.java      | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/flink-connectors/flink-connector-hbase-2.2/src/main/java/org/apache/flink/connector/hbase2/source/HBaseRowDataAsyncLookupFunction.java
 
b/flink-connectors/flink-connector-hbase-2.2/src/main/java/org/apache/flink/connector/hbase2/source/HBaseRowDataAsyncLookupFunction.java
index 01ad378..5ce904d 100644
--- 
a/flink-connectors/flink-connector-hbase-2.2/src/main/java/org/apache/flink/connector/hbase2/source/HBaseRowDataAsyncLookupFunction.java
+++ 
b/flink-connectors/flink-connector-hbase-2.2/src/main/java/org/apache/flink/connector/hbase2/source/HBaseRowDataAsyncLookupFunction.java
@@ -108,7 +108,7 @@ public class HBaseRowDataAsyncLookupFunction extends 
AsyncTableFunction<RowData>
                 Executors.newFixedThreadPool(
                         THREAD_POOL_SIZE,
                         new ExecutorThreadFactory(
-                                "hbase-aysnc-lookup-worker", 
Threads.LOGGING_EXCEPTION_HANDLER));
+                                "hbase-async-lookup-worker", 
Threads.LOGGING_EXCEPTION_HANDLER));
         Configuration config = prepareRuntimeConfiguration();
         CompletableFuture<AsyncConnection> asyncConnectionFuture =
                 ConnectionFactory.createAsyncConnection(config);
diff --git 
a/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperatorTest.java
 
b/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperatorTest.java
index 310ac0b..ea28bce 100644
--- 
a/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperatorTest.java
+++ 
b/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperatorTest.java
@@ -946,7 +946,7 @@ public class AsyncWaitOperatorTest extends TestLogger {
     }
 
     /**
-     * Tests that the AysncWaitOperator can restart if checkpointed queue was 
full.
+     * Tests that the AsyncWaitOperator can restart if checkpointed queue was 
full.
      *
      * <p>See FLINK-7949
      */