You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@amoro.apache.org by ji...@apache.org on 2025/09/08 11:31:46 UTC
(amoro) 03/05: fix checkstyle
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 <ya...@tencent.com>
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();