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 a36999b520de14bfdd0571cc0c1dc44f80a33d00 Author: Shimin Huang <[email protected]> AuthorDate: Mon Jun 13 16:00:40 2022 +0800 Update RowResultRowDataConvertor.java --- .../connectors/kudu/connector/convertor/RowResultRowDataConvertor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/convertor/RowResultRowDataConvertor.java b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/convertor/RowResultRowDataConvertor.java index 80140b4..b7dc702 100644 --- a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/convertor/RowResultRowDataConvertor.java +++ b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/convertor/RowResultRowDataConvertor.java @@ -80,7 +80,7 @@ public class RowResultRowDataConvertor implements RowResultConvertor<RowData> { values.setField(pos, row.getBoolean(name)); break; default: - throw new IllegalArgumentException("columnName:" + name + ",type:" + type.getName() + "Not Support!"); + throw new IllegalArgumentException("columnName:" + name + ",type:" + type.getName() + "not support!"); } }); return values;
