From 62712f52dbb5017366e4685899a509f1d8bd7243 Mon Sep 17 00:00:00 2001 From: baoloongmao Date: Mon, 18 Nov 2024 11:01:48 +0800 Subject: [PATCH] fix style --- .../java/org/apache/uniffle/test/SparkClientWithLocalTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/integration-test/spark-common/src/test/java/org/apache/uniffle/test/SparkClientWithLocalTest.java b/integration-test/spark-common/src/test/java/org/apache/uniffle/test/SparkClientWithLocalTest.java index c3e0afad63..ff622b5816 100644 --- a/integration-test/spark-common/src/test/java/org/apache/uniffle/test/SparkClientWithLocalTest.java +++ b/integration-test/spark-common/src/test/java/org/apache/uniffle/test/SparkClientWithLocalTest.java @@ -511,7 +511,6 @@ public void testClientRemoteReadFromMultipleDisk(boolean isNettyMode) { // Send shuffle data Map expectedData = Maps.newHashMap(); Roaring64NavigableMap blockIdBitmap = Roaring64NavigableMap.bitmapOf(); - Roaring64NavigableMap taskIdBitmap = Roaring64NavigableMap.bitmapOf(0); List blocks = createShuffleBlockList(0, 0, 0, 5, 30, blockIdBitmap, expectedData, mockSSI); @@ -533,6 +532,7 @@ public void testClientRemoteReadFromMultipleDisk(boolean isNettyMode) { (LocalStorage) shuffleServer.getStorageManager().selectStorage(readEvent); assertNotEquals(storage1, storage2); + Roaring64NavigableMap taskIdBitmap = Roaring64NavigableMap.bitmapOf(0); // unexpected taskAttemptId should be filtered ShuffleReadClientImpl readClient = baseReadBuilder(isNettyMode)