[bahir-flink] 15/16: Update AbstractKuduInputFormat.java

[es...@apache.org]

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

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

commit 7b2563eac785bd07a7cafd8002a991b8faeff2cd
Author: Shimin Huang <40...@users.noreply.github.com>
AuthorDate: Mon Jun 13 16:02:12 2022 +0800

    Update AbstractKuduInputFormat.java
---
 .../apache/flink/connectors/kudu/format/AbstractKuduInputFormat.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/format/AbstractKuduInputFormat.java b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/format/AbstractKuduInputFormat.java
index 44da9c8..0cdf570 100644
--- a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/format/AbstractKuduInputFormat.java
+++ b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/format/AbstractKuduInputFormat.java
@@ -78,7 +78,7 @@ public abstract class AbstractKuduInputFormat<T> extends RichInputFormat<T, Kudu
                                    List<String> tableProjections) {
 
         this.readerConfig = checkNotNull(readerConfig, "readerConfig could not be null");
-        this.rowResultConvertor = checkNotNull(rowResultConvertor, "readerConfig could not be null");
+        this.rowResultConvertor = checkNotNull(rowResultConvertor, "rowResultConvertor could not be null");
         this.tableInfo = checkNotNull(tableInfo, "tableInfo could not be null");
         this.tableFilters = checkNotNull(tableFilters, "tableFilters could not be null");
         this.tableProjections = tableProjections;