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:33 UTC
[bahir-flink] 12/16: Update RowDataUpsertOperationMapper.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 ebb9085036cc0c083d103f2fbfad0501c2dbc9c2
Author: Shimin Huang <40...@users.noreply.github.com>
AuthorDate: Mon Jun 13 15:58:46 2022 +0800
Update RowDataUpsertOperationMapper.java
fix: update exception content
---
.../connectors/kudu/connector/writer/RowDataUpsertOperationMapper.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer/RowDataUpsertOperationMapper.java b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer/RowDataUpsertOperationMapper.java
index 362710e..ceb0254 100644
--- a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer/RowDataUpsertOperationMapper.java
+++ b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer/RowDataUpsertOperationMapper.java
@@ -102,7 +102,7 @@ public class RowDataUpsertOperationMapper extends AbstractSingleOperationMapper<
if (timePrecision < MIN_TIME_PRECISION || timePrecision > MAX_TIME_PRECISION) {
throw new UnsupportedOperationException(
String.format("The precision %s of TIME type is out of the range [%s, %s] supported by " +
- "HBase connector", timePrecision, MIN_TIME_PRECISION, MAX_TIME_PRECISION));
+ "kudu connector", timePrecision, MIN_TIME_PRECISION, MAX_TIME_PRECISION));
}
return input.getInt(i);
case BIGINT: