Addressed the spotbug issue

linkedin · Apr 22, 2024 · 8ad4090 · 8ad4090
1 parent d459c76
commit 8ad4090
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...src/test/java/com/linkedin/davinci/kafka/consumer/ActiveActiveStoreIngestionTaskTest.java b/...src/test/java/com/linkedin/davinci/kafka/consumer/ActiveActiveStoreIngestionTaskTest.java
@@ -93,6 +93,7 @@
 import java.nio.ByteBuffer;
 import java.util.ArrayList;
 import java.util.Arrays;
+import java.util.List;
 import java.util.Objects;
 import java.util.Optional;
 import java.util.Properties;
@@ -496,7 +497,9 @@ public void testReadingChunkedRmdFromStorage() {
 
     when(storageEngine.getReplicationMetadata(subPartition, topLevelKey2)).thenReturn(chunkedManifestWithSchemaBytes);
     when(storageEngine.getReplicationMetadata(subPartition, chunkedKey1InKey2)).thenReturn(chunkedValue1);
-    when(storageEngine.multiGetReplicationMetadata(eq(subPartition), any())).thenReturn(Arrays.asList(chunkedValue1));
+    List<byte[]> chunkedValues = new ArrayList<>(1);
+    chunkedValues.add(chunkedValue1);
+    when(storageEngine.multiGetReplicationMetadata(eq(subPartition), any())).thenReturn(chunkedValues);
     byte[] result2 = ingestionTask.getRmdWithValueSchemaByteBufferFromStorage(subPartition, key2, container, 0L);
     Assert.assertNotNull(result2);
     Assert.assertNotNull(container.getManifest());