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 b4cba4b113e6b94b4bd2610980561adf06a88b42 Author: Yaguang Jia <[email protected]> AuthorDate: Tue Aug 26 02:28:37 2025 +0800 fix MixedFormatSourceEnumStateSerializer serialize see flink 1.18 https://github.com/apache/flink/pull/21952/files --- .../org/apache/amoro/flink/read/hybrid/split/TemporalJoinSplits.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/read/hybrid/split/TemporalJoinSplits.java b/amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/read/hybrid/split/TemporalJoinSplits.java index 45c6e5968..6d6d79f84 100644 --- a/amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/read/hybrid/split/TemporalJoinSplits.java +++ b/amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/read/hybrid/split/TemporalJoinSplits.java @@ -44,7 +44,7 @@ public class TemporalJoinSplits implements Serializable { public static final long serialVersionUID = 1L; public static final Logger LOGGER = LoggerFactory.getLogger(TemporalJoinSplits.class); - private transient final MetricGroup metricGroup; + private final transient MetricGroup metricGroup; private final long startTimeMs = System.currentTimeMillis(); private Map<String, Boolean> splits; private long unfinishedCount;
