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 */