diff --git a/storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileReader.java b/storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileReader.java index b72987d983..6b9c22803c 100644 --- a/storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileReader.java +++ b/storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileReader.java @@ -30,7 +30,7 @@ public class LocalFileReader implements FileReader, Closeable { - private static final Logger LOG = LoggerFactory.getLogger(HdfsFileReader.class); + private static final Logger LOG = LoggerFactory.getLogger(LocalFileReader.class); private String path; private DataInputStream dataInputStream; diff --git a/storage/src/main/java/org/apache/uniffle/storage/handler/impl/MemoryClientReadHandler.java b/storage/src/main/java/org/apache/uniffle/storage/handler/impl/MemoryClientReadHandler.java index a179aa2f1f..5f0db19b19 100644 --- a/storage/src/main/java/org/apache/uniffle/storage/handler/impl/MemoryClientReadHandler.java +++ b/storage/src/main/java/org/apache/uniffle/storage/handler/impl/MemoryClientReadHandler.java @@ -32,7 +32,7 @@ public class MemoryClientReadHandler extends AbstractClientReadHandler { - private static final Logger LOG = LoggerFactory.getLogger(MemoryQuorumClientReadHandler.class); + private static final Logger LOG = LoggerFactory.getLogger(MemoryClientReadHandler.class); private long lastBlockId = Constants.INVALID_BLOCK_ID; private ShuffleServerClient shuffleServerClient;