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 <[email protected]> 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:
