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 e6c00178a25acda3b4e619cdb6079cfc5edd5117 Author: Shimin Huang <[email protected]> AuthorDate: Mon Jun 13 15:56:49 2022 +0800 Update RowResultRowDataConvertor.java Change the exception content to English --- .../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 789550e..80140b4 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() + "不支持!"); + throw new IllegalArgumentException("columnName:" + name + ",type:" + type.getName() + "Not Support!"); } }); return values;
