This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a commit to branch ml_0729_test_exp1_no_write
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/ml_0729_test_exp1_no_write by
this push:
new 8b826739a2 spotless
8b826739a2 is described below
commit 8b826739a251c7b6be7d806e47a0276b66cf0795
Author: Jinrui.Zhang <[email protected]>
AuthorDate: Fri Aug 5 16:34:22 2022 +0800
spotless
---
.../org/apache/iotdb/consensus/multileader/MultiLeaderServerImpl.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/MultiLeaderServerImpl.java
b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/MultiLeaderServerImpl.java
index fca6971b3d..2460e43444 100644
---
a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/MultiLeaderServerImpl.java
+++
b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/MultiLeaderServerImpl.java
@@ -126,7 +126,7 @@ public class MultiLeaderServerImpl {
}
// TODO wal and memtable
TSStatus result = stateMachine.write(indexedConsensusRequest);
-// TSStatus result = new
TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode());
+ // TSStatus result = new
TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode());
StepTracker.trace("stateMachineWrite", startTimeAfterLock,
System.nanoTime());
long offerStartTime = System.nanoTime();
if (result.getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
@@ -162,7 +162,7 @@ public class MultiLeaderServerImpl {
public void persistConfiguration() {
try (PublicBAOS publicBAOS = new PublicBAOS();
- DataOutputStream outputStream = new DataOutputStream(publicBAOS)) {
+ DataOutputStream outputStream = new DataOutputStream(publicBAOS)) {
outputStream.writeInt(configuration.size());
for (Peer peer : configuration) {
peer.serialize(outputStream);