This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a commit to branch ml_0729_test_exp1
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/ml_0729_test_exp1 by this push:
new 5cc98fd4c0 fix compilation error
5cc98fd4c0 is described below
commit 5cc98fd4c07f10be8e49aaefb6c5146cb64b2f77
Author: Jinrui.Zhang <[email protected]>
AuthorDate: Mon Aug 1 18:40:27 2022 +0800
fix compilation error
---
.../consensus/statemachine/PartitionRegionStateMachine.java | 8 ++++++++
.../iotdb/consensus/standalone/StandAloneServerImpl.java | 11 +++++++++++
.../java/org/apache/iotdb/consensus/EmptyStateMachine.java | 9 +++++++++
.../iotdb/consensus/multileader/util/TestStateMachine.java | 7 +++++++
.../test/java/org/apache/iotdb/consensus/ratis/TestUtils.java | 7 +++++++
.../iotdb/consensus/standalone/StandAloneConsensusTest.java | 8 ++++++++
6 files changed, 50 insertions(+)
diff --git
a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/statemachine/PartitionRegionStateMachine.java
b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/statemachine/PartitionRegionStateMachine.java
index 4259e5df71..5527737d01 100644
---
a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/statemachine/PartitionRegionStateMachine.java
+++
b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/statemachine/PartitionRegionStateMachine.java
@@ -31,13 +31,17 @@ import org.apache.iotdb.consensus.IStateMachine;
import org.apache.iotdb.consensus.common.DataSet;
import org.apache.iotdb.consensus.common.request.ByteBufferConsensusRequest;
import org.apache.iotdb.consensus.common.request.IConsensusRequest;
+import org.apache.iotdb.consensus.common.request.IndexedConsensusRequest;
+import org.apache.iotdb.consensus.multileader.thrift.TSyncLogRes;
import org.apache.iotdb.rpc.TSStatusCode;
+import org.apache.thrift.async.AsyncMethodCallback;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.File;
import java.io.IOException;
+import java.util.List;
/** Statemachine for PartitionRegion */
public class PartitionRegionStateMachine implements IStateMachine,
IStateMachine.EventApi {
@@ -161,4 +165,8 @@ public class PartitionRegionStateMachine implements
IStateMachine, IStateMachine
public void stop() {
// do nothing
}
+
+ @Override
+ public void multiLeaderWriteAsync(
+ List<IndexedConsensusRequest> requests, AsyncMethodCallback<TSyncLogRes>
resultHandler) {}
}
diff --git
a/consensus/src/main/java/org/apache/iotdb/consensus/standalone/StandAloneServerImpl.java
b/consensus/src/main/java/org/apache/iotdb/consensus/standalone/StandAloneServerImpl.java
index 8438a5fbe4..cd57b252ec 100644
---
a/consensus/src/main/java/org/apache/iotdb/consensus/standalone/StandAloneServerImpl.java
+++
b/consensus/src/main/java/org/apache/iotdb/consensus/standalone/StandAloneServerImpl.java
@@ -24,8 +24,13 @@ import org.apache.iotdb.consensus.IStateMachine;
import org.apache.iotdb.consensus.common.DataSet;
import org.apache.iotdb.consensus.common.Peer;
import org.apache.iotdb.consensus.common.request.IConsensusRequest;
+import org.apache.iotdb.consensus.common.request.IndexedConsensusRequest;
+import org.apache.iotdb.consensus.multileader.thrift.TSyncLogRes;
+
+import org.apache.thrift.async.AsyncMethodCallback;
import java.io.File;
+import java.util.List;
public class StandAloneServerImpl implements IStateMachine {
@@ -57,6 +62,12 @@ public class StandAloneServerImpl implements IStateMachine {
stateMachine.stop();
}
+ @Override
+ public void multiLeaderWriteAsync(
+ List<IndexedConsensusRequest> requests, AsyncMethodCallback<TSyncLogRes>
resultHandler) {
+ throw new UnsupportedOperationException();
+ }
+
@Override
public TSStatus write(IConsensusRequest request) {
return stateMachine.write(request);
diff --git
a/consensus/src/test/java/org/apache/iotdb/consensus/EmptyStateMachine.java
b/consensus/src/test/java/org/apache/iotdb/consensus/EmptyStateMachine.java
index 01992f472f..86aeddd19c 100644
--- a/consensus/src/test/java/org/apache/iotdb/consensus/EmptyStateMachine.java
+++ b/consensus/src/test/java/org/apache/iotdb/consensus/EmptyStateMachine.java
@@ -22,8 +22,13 @@ package org.apache.iotdb.consensus;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
import org.apache.iotdb.consensus.common.DataSet;
import org.apache.iotdb.consensus.common.request.IConsensusRequest;
+import org.apache.iotdb.consensus.common.request.IndexedConsensusRequest;
+import org.apache.iotdb.consensus.multileader.thrift.TSyncLogRes;
+
+import org.apache.thrift.async.AsyncMethodCallback;
import java.io.File;
+import java.util.List;
public class EmptyStateMachine implements IStateMachine,
IStateMachine.EventApi {
@@ -33,6 +38,10 @@ public class EmptyStateMachine implements IStateMachine,
IStateMachine.EventApi
@Override
public void stop() {}
+ @Override
+ public void multiLeaderWriteAsync(
+ List<IndexedConsensusRequest> requests, AsyncMethodCallback<TSyncLogRes>
resultHandler) {}
+
@Override
public TSStatus write(IConsensusRequest IConsensusRequest) {
return new TSStatus(0);
diff --git
a/consensus/src/test/java/org/apache/iotdb/consensus/multileader/util/TestStateMachine.java
b/consensus/src/test/java/org/apache/iotdb/consensus/multileader/util/TestStateMachine.java
index eab940cf87..dc7b31f831 100644
---
a/consensus/src/test/java/org/apache/iotdb/consensus/multileader/util/TestStateMachine.java
+++
b/consensus/src/test/java/org/apache/iotdb/consensus/multileader/util/TestStateMachine.java
@@ -25,11 +25,14 @@ import org.apache.iotdb.consensus.common.DataSet;
import org.apache.iotdb.consensus.common.Peer;
import org.apache.iotdb.consensus.common.request.IConsensusRequest;
import org.apache.iotdb.consensus.common.request.IndexedConsensusRequest;
+import org.apache.iotdb.consensus.multileader.thrift.TSyncLogRes;
import org.apache.iotdb.consensus.multileader.wal.ConsensusReqReader;
import org.apache.iotdb.consensus.multileader.wal.GetConsensusReqReaderPlan;
import org.apache.iotdb.rpc.RpcUtils;
import org.apache.iotdb.rpc.TSStatusCode;
+import org.apache.thrift.async.AsyncMethodCallback;
+
import java.io.File;
import java.nio.ByteBuffer;
import java.util.ArrayList;
@@ -65,6 +68,10 @@ public class TestStateMachine implements IStateMachine,
IStateMachine.EventApi {
@Override
public void stop() {}
+ @Override
+ public void multiLeaderWriteAsync(
+ List<IndexedConsensusRequest> requests, AsyncMethodCallback<TSyncLogRes>
resultHandler) {}
+
@Override
public TSStatus write(IConsensusRequest request) {
synchronized (requestSets) {
diff --git
a/consensus/src/test/java/org/apache/iotdb/consensus/ratis/TestUtils.java
b/consensus/src/test/java/org/apache/iotdb/consensus/ratis/TestUtils.java
index d383fe902b..72e741e6c9 100644
--- a/consensus/src/test/java/org/apache/iotdb/consensus/ratis/TestUtils.java
+++ b/consensus/src/test/java/org/apache/iotdb/consensus/ratis/TestUtils.java
@@ -27,7 +27,10 @@ import org.apache.iotdb.consensus.common.DataSet;
import org.apache.iotdb.consensus.common.Peer;
import org.apache.iotdb.consensus.common.request.ByteBufferConsensusRequest;
import org.apache.iotdb.consensus.common.request.IConsensusRequest;
+import org.apache.iotdb.consensus.common.request.IndexedConsensusRequest;
+import org.apache.iotdb.consensus.multileader.thrift.TSyncLogRes;
+import org.apache.thrift.async.AsyncMethodCallback;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -86,6 +89,10 @@ public class TestUtils {
@Override
public void stop() {}
+ @Override
+ public void multiLeaderWriteAsync(
+ List<IndexedConsensusRequest> requests,
AsyncMethodCallback<TSyncLogRes> resultHandler) {}
+
@Override
public TSStatus write(IConsensusRequest request) {
TestRequest testRequest;
diff --git
a/consensus/src/test/java/org/apache/iotdb/consensus/standalone/StandAloneConsensusTest.java
b/consensus/src/test/java/org/apache/iotdb/consensus/standalone/StandAloneConsensusTest.java
index 9e0e13be6d..b9438177f5 100644
---
a/consensus/src/test/java/org/apache/iotdb/consensus/standalone/StandAloneConsensusTest.java
+++
b/consensus/src/test/java/org/apache/iotdb/consensus/standalone/StandAloneConsensusTest.java
@@ -33,6 +33,7 @@ import org.apache.iotdb.consensus.common.DataSet;
import org.apache.iotdb.consensus.common.Peer;
import org.apache.iotdb.consensus.common.request.ByteBufferConsensusRequest;
import org.apache.iotdb.consensus.common.request.IConsensusRequest;
+import org.apache.iotdb.consensus.common.request.IndexedConsensusRequest;
import org.apache.iotdb.consensus.common.response.ConsensusGenericResponse;
import org.apache.iotdb.consensus.common.response.ConsensusWriteResponse;
import org.apache.iotdb.consensus.config.ConsensusConfig;
@@ -40,8 +41,10 @@ import
org.apache.iotdb.consensus.exception.ConsensusGroupAlreadyExistException;
import org.apache.iotdb.consensus.exception.ConsensusGroupNotExistException;
import org.apache.iotdb.consensus.exception.IllegalPeerEndpointException;
import org.apache.iotdb.consensus.exception.IllegalPeerNumException;
+import org.apache.iotdb.consensus.multileader.thrift.TSyncLogRes;
import org.apache.ratis.util.FileUtils;
+import org.apache.thrift.async.AsyncMethodCallback;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
@@ -50,6 +53,7 @@ import java.io.File;
import java.nio.ByteBuffer;
import java.util.Arrays;
import java.util.Collections;
+import java.util.List;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertFalse;
@@ -97,6 +101,10 @@ public class StandAloneConsensusTest {
@Override
public void stop() {}
+ @Override
+ public void multiLeaderWriteAsync(
+ List<IndexedConsensusRequest> requests,
AsyncMethodCallback<TSyncLogRes> resultHandler) {}
+
@Override
public TSStatus write(IConsensusRequest request) {
if (request instanceof ByteBufferConsensusRequest) {
