From 5de2b54cb95435d2b208457bb74335a63fb6c9a5 Mon Sep 17 00:00:00 2001
From: Bowen Ding <6999708+dbw9580@users.noreply.github.com>
Date: Tue, 7 Nov 2023 14:22:30 +0800
Subject: [PATCH] fix empty block location

---
 .../main/java/alluxio/worker/page/PagedBlockStore.java | 10 +---------
 1 file changed, 1 insertion(+), 9 deletions(-)

diff --git a/core/server/worker/src/main/java/alluxio/worker/page/PagedBlockStore.java b/core/server/worker/src/main/java/alluxio/worker/page/PagedBlockStore.java
index 59ac5af9daeb..7fd540fb63f7 100644
--- a/core/server/worker/src/main/java/alluxio/worker/page/PagedBlockStore.java
+++ b/core/server/worker/src/main/java/alluxio/worker/page/PagedBlockStore.java
@@ -389,15 +389,7 @@ public CacheManager.State getCacheManagerState() {
   public void moveBlock(long sessionId, long blockId, AllocateOptions moveOptions)
       throws IOException {
     // TODO(bowen): implement actual move and replace placeholder values
-    int dirIndex = getDirIndexOfBlock(blockId);
-    BlockStoreLocation srcLocation = new BlockStoreLocation(DEFAULT_TIER, dirIndex);
-    BlockStoreLocation destLocation = moveOptions.getLocation();
-    for (BlockStoreEventListener listener : mBlockStoreEventListeners) {
-      synchronized (listener) {
-        listener.onMoveBlockByClient(blockId, srcLocation, destLocation);
-      }
-    }
-    throw new UnsupportedOperationException();
+    throw new UnsupportedOperationException("moveBlock");
   }
 
   @Override