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 3ac6a21e5b31438451335444215f723b7fe83ee3 Author: Shimin Huang <[email protected]> AuthorDate: Mon Jun 13 16:01:29 2022 +0800 Update RowDataUpsertOperationMapper.java --- .../connectors/kudu/connector/writer/RowDataUpsertOperationMapper.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) 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 ceb0254..d4f0182 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 @@ -118,8 +118,7 @@ public class RowDataUpsertOperationMapper extends AbstractSingleOperationMapper< if (timestampPrecision < MIN_TIMESTAMP_PRECISION || timestampPrecision > MAX_TIMESTAMP_PRECISION) { throw new UnsupportedOperationException( String.format("The precision %s of TIMESTAMP type is out of the range [%s, %s] supported " + - "by " + - "kudu connector", timestampPrecision, MIN_TIMESTAMP_PRECISION, + "by kudu connector", timestampPrecision, MIN_TIMESTAMP_PRECISION, MAX_TIMESTAMP_PRECISION)); } return input.getTimestamp(i, timestampPrecision).toTimestamp();
