This is an automated email from the ASF dual-hosted git repository. jinsongzhou pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/amoro.git
commit 3993f1309c2f0324ca033a0f1ec8361f5dadcb63 Author: Yaguang Jia <[email protected]> AuthorDate: Wed Aug 20 19:27:03 2025 +0800 fix checkstyle --- .../main/java/org/apache/iceberg/flink/source/ScanContext.java | 8 ++++---- .../apache/amoro/flink/read/source/MixedFormatScanContext.java | 2 +- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common-iceberg-bridge/src/main/java/org/apache/iceberg/flink/source/ScanContext.java b/amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common-iceberg-bridge/src/main/java/org/apache/iceberg/flink/source/ScanContext.java index a5f8b15ec..c3ff9bea6 100644 --- a/amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common-iceberg-bridge/src/main/java/org/apache/iceberg/flink/source/ScanContext.java +++ b/amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common-iceberg-bridge/src/main/java/org/apache/iceberg/flink/source/ScanContext.java @@ -265,11 +265,11 @@ public class ScanContext implements Serializable { tag == null, String.format("Cannot scan table using ref %s configured for streaming reader", tag)); Preconditions.checkArgument( - snapshotId == null, "Cannot set snapshot-id option for streaming reader"); + snapshotId == null, "Cannot set snapshot-id option for streaming reader"); Preconditions.checkArgument( - asOfTimestamp == null, "Cannot set as-of-timestamp option for streaming reader"); + asOfTimestamp == null, "Cannot set as-of-timestamp option for streaming reader"); Preconditions.checkArgument( - endSnapshotId == null, "Cannot set end-snapshot-id option for streaming reader"); + endSnapshotId == null, "Cannot set end-snapshot-id option for streaming reader"); Preconditions.checkArgument(endTag == null, "Cannot set end-tag option for streaming reader"); } Preconditions.checkArgument( @@ -498,7 +498,7 @@ public class ScanContext implements Serializable { FlinkReadOptions.MAX_ALLOWED_PLANNING_FAILURES_OPTION.defaultValue(); private String watermarkColumn = FlinkReadOptions.WATERMARK_COLUMN_OPTION.defaultValue(); private TimeUnit watermarkColumnTimeUnit = - FlinkReadOptions.WATERMARK_COLUMN_TIME_UNIT_OPTION.defaultValue(); + FlinkReadOptions.WATERMARK_COLUMN_TIME_UNIT_OPTION.defaultValue(); private Builder() {} diff --git a/amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/read/source/MixedFormatScanContext.java b/amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/read/source/MixedFormatScanContext.java index a0afc9571..a00e75821 100644 --- a/amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/read/source/MixedFormatScanContext.java +++ b/amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/read/source/MixedFormatScanContext.java @@ -181,7 +181,7 @@ public class MixedFormatScanContext extends ScanContext implements Serializable FlinkReadOptions.MAX_ALLOWED_PLANNING_FAILURES_OPTION.defaultValue(); private String watermarkColumn = FlinkReadOptions.WATERMARK_COLUMN_OPTION.defaultValue(); private TimeUnit watermarkColumnTimeUnit = - FlinkReadOptions.WATERMARK_COLUMN_TIME_UNIT_OPTION.defaultValue(); + FlinkReadOptions.WATERMARK_COLUMN_TIME_UNIT_OPTION.defaultValue(); private String branch = FlinkReadOptions.BRANCH.defaultValue(); private String tag = FlinkReadOptions.TAG.defaultValue();
