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 <[email protected]> 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;
