This is an automated email from the ASF dual-hosted git repository.
szetszwo pushed a commit to branch HDDS-4454
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/HDDS-4454 by this push:
new e3af42a Revert "[HDDS-5452] Add link method to ContainerStateMachine
for Ratis streaming (#2422)" (#2427)
e3af42a is described below
commit e3af42a17e6e77a7c948c73f3ab65c96a4902543
Author: Tsz-Wo Nicholas Sze <[email protected]>
AuthorDate: Sun Jul 18 12:19:21 2021 +0800
Revert "[HDDS-5452] Add link method to ContainerStateMachine for Ratis
streaming (#2422)" (#2427)
This reverts commit af10e0e643ff3753535843c2bc47b9ea44548764.
---
.../transport/server/ratis/ContainerStateMachine.java | 17 -----------------
1 file changed, 17 deletions(-)
diff --git
a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/ContainerStateMachine.java
b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/ContainerStateMachine.java
index 05c93af..1cfb771 100644
---
a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/ContainerStateMachine.java
+++
b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/ContainerStateMachine.java
@@ -89,7 +89,6 @@ import
org.apache.ratis.thirdparty.com.google.protobuf.InvalidProtocolBufferExce
import org.apache.ratis.thirdparty.com.google.protobuf.TextFormat;
import org.apache.ratis.util.TaskQueue;
import org.apache.ratis.util.function.CheckedSupplier;
-import org.apache.ratis.util.JavaUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -520,22 +519,6 @@ public class ContainerStateMachine extends
BaseStateMachine {
}, executor);
}
- public CompletableFuture<?> link(DataStream stream, LogEntryProto entry) {
- return CompletableFuture.supplyAsync(() -> {
- if (stream == null) {
- return JavaUtils.completeExceptionally(
- new IllegalStateException("DataStream is null"));
- }
- if (stream.getDataChannel().isOpen()) {
- return JavaUtils.completeExceptionally(
- new IllegalStateException(
- "DataStream: " + stream + " is not closed properly"));
- } else {
- return CompletableFuture.completedFuture(null);
- }
- }, executor);
- }
-
private ExecutorService getChunkExecutor(WriteChunkRequestProto req) {
int hash = Objects.hashCode(req.getBlockID());
if (hash == Integer.MIN_VALUE) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
