You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bahir.apache.org by es...@apache.org on 2022/07/17 12:29:32 UTC
[bahir-flink] 11/16: Update RowResultRowDataConvertor.java
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 <40...@users.noreply.github.com>
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;