revert changes

Alluxio · Nov 29, 2023 · b7bec81 · b7bec81
1 parent 8b22649
commit b7bec81
Showing 1 changed file with 4 additions and 5 deletions.
diff --git a/dora/core/client/fs/src/main/java/alluxio/client/file/FileSystemContext.java b/dora/core/client/fs/src/main/java/alluxio/client/file/FileSystemContext.java
@@ -58,7 +58,6 @@
 import com.google.common.base.Preconditions;
 import io.netty.bootstrap.Bootstrap;
 import io.netty.channel.Channel;
-import org.apache.curator.shaded.com.google.common.collect.Streams;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -902,7 +901,7 @@ public List<BlockWorkerInfo> getLiveWorkers() throws IOException {
     try (ReinitBlockerResource r = blockReinit()) {
       // Use membership mgr
       if (mMembershipManager != null && !(mMembershipManager instanceof MasterMembershipManager)) {
-        return Streams.stream(mMembershipManager.getLiveMembers())
+        return mMembershipManager.getLiveMembers().stream()
             .map(w -> new BlockWorkerInfo(w.getIdentity(), w.getAddress(), w.getCapacityBytes(),
                 w.getUsedBytes(), true)).collect(toList());
       }
@@ -927,7 +926,7 @@ public List<BlockWorkerInfo> getLostWorkers() throws IOException {
     try (ReinitBlockerResource r = blockReinit()) {
       // Use membership mgr
       if (mMembershipManager != null && !(mMembershipManager instanceof MasterMembershipManager)) {
-        return Streams.stream(mMembershipManager.getFailedMembers())
+        return mMembershipManager.getFailedMembers().stream()
             .map(w -> new BlockWorkerInfo(w.getIdentity(), w.getAddress(), w.getCapacityBytes(),
                 w.getUsedBytes(), false)).collect(toList());
       }
@@ -954,10 +953,10 @@ public List<BlockWorkerInfo> getAllWorkers() throws IOException {
     try (ReinitBlockerResource r = blockReinit()) {
       // Use membership mgr
       if (mMembershipManager != null && !(mMembershipManager instanceof MasterMembershipManager)) {
-        List<BlockWorkerInfo> liveWorkers = Streams.stream(mMembershipManager.getLiveMembers())
+        List<BlockWorkerInfo> liveWorkers = mMembershipManager.getLiveMembers().stream()
             .map(w -> new BlockWorkerInfo(w.getIdentity(), w.getAddress(), w.getCapacityBytes(),
                 w.getUsedBytes(), true)).collect(toList());
-        List<BlockWorkerInfo> lostWorkers = Streams.stream(mMembershipManager.getFailedMembers())
+        List<BlockWorkerInfo> lostWorkers = mMembershipManager.getFailedMembers().stream()
             .map(w -> new BlockWorkerInfo(
                 w.getIdentity(), w.getAddress(), w.getCapacityBytes(), w.getUsedBytes(),
                 false)).collect(toList());