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 1cc6d71a7ba0ce8bb25e2b128231b4c83307f99d Author: Yaguang Jia <[email protected]> AuthorDate: Mon Aug 25 23:14:01 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 c7c9bada6..45c6e5968 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 final MetricGroup metricGroup; + private transient final MetricGroup metricGroup; private final long startTimeMs = System.currentTimeMillis(); private Map<String, Boolean> splits; private long unfinishedCount;
