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;