diff --git a/oap-storage/oap-storage/src/main/java/oap/storage/TransactionLog.java b/oap-storage/oap-storage/src/main/java/oap/storage/TransactionLog.java index 28e527867..c5344af8b 100644 --- a/oap-storage/oap-storage/src/main/java/oap/storage/TransactionLog.java +++ b/oap-storage/oap-storage/src/main/java/oap/storage/TransactionLog.java @@ -5,6 +5,7 @@ import java.io.Serial; import java.io.Serializable; import java.util.Collection; +import java.util.List; import java.util.Map; import java.util.Set; @@ -49,7 +50,7 @@ class ReplicationResult implements Serializable { public final ReplicationStatusType type; public final Collection> data; - public ReplicationResult( long timestamp, long hash, ReplicationStatusType type, Collection> data ) { + public ReplicationResult( long timestamp, long hash, ReplicationStatusType type, List> data ) { this.timestamp = timestamp; this.hash = hash; this.type = type; diff --git a/oap-storage/oap-storage/src/main/java/oap/storage/TransactionLogImpl.java b/oap-storage/oap-storage/src/main/java/oap/storage/TransactionLogImpl.java index d177d64fe..0505f91dd 100644 --- a/oap-storage/oap-storage/src/main/java/oap/storage/TransactionLogImpl.java +++ b/oap-storage/oap-storage/src/main/java/oap/storage/TransactionLogImpl.java @@ -5,6 +5,7 @@ import org.joda.time.DateTimeUtils; import org.jspecify.annotations.NonNull; +import java.util.ArrayList; import java.util.Iterator; import java.util.LinkedHashMap; import java.util.List; @@ -83,7 +84,7 @@ public ReplicationResult> updatedSince( long timestamp, long has } } - return new ReplicationResult<>( this.timestamp.longValue(), this.hash, ReplicationResult.ReplicationStatusType.CHANGES, list.values() ); + return new ReplicationResult<>( this.timestamp.longValue(), this.hash, ReplicationResult.ReplicationStatusType.CHANGES, new ArrayList<>( list.values() ) ); } finally { lock.unlock(); } diff --git a/pom.xml b/pom.xml index 52ae63948..b569d5083 100644 --- a/pom.xml +++ b/pom.xml @@ -57,7 +57,7 @@ - 25.1.2 + 25.1.3 25.0.0 25.0.0