This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch cluster_new
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from d988b1c fix session IT
add 376cb32 fix sonar issues
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/iotdb/cluster/ClientMain.java | 4 +-
.../java/org/apache/iotdb/cluster/ClusterMain.java | 1 +
.../apache/iotdb/cluster/RemoteTsFileResource.java | 16 ---
.../cluster/client/async/AsyncDataClient.java | 2 +-
.../client/async/AsyncDataHeartbeatClient.java | 4 -
.../cluster/client/async/AsyncMetaClient.java | 2 +-
.../cluster/client/sync/SyncClientAdaptor.java | 2 +-
.../apache/iotdb/cluster/log/LogDispatcher.java | 62 +++++++++---
.../iotdb/cluster/log/applier/DataLogApplier.java | 30 ++----
.../iotdb/cluster/log/applier/MetaLogApplier.java | 2 +-
.../iotdb/cluster/log/catchup/LogCatchUpTask.java | 26 +++--
.../cluster/log/manage/CommittedEntryManager.java | 2 +-
.../manage/FilePartitionedSnapshotLogManager.java | 2 +-
.../log/manage/PartitionedSnapshotLogManager.java | 4 +-
.../serializable/SyncLogDequeSerializer.java | 1 -
.../cluster/log/snapshot/PullSnapshotTask.java | 4 +-
.../iotdb/cluster/log/snapshot/SimpleSnapshot.java | 11 ---
.../apache/iotdb/cluster/metadata/MetaPuller.java | 2 +-
.../cluster/partition/slot/SlotPartitionTable.java | 16 ++-
.../iotdb/cluster/query/ClusterPlanExecutor.java | 38 ++------
.../cluster/query/fill/ClusterLinearFill.java | 12 +--
.../iotdb/cluster/query/filter/SlotSgFilter.java | 2 +-
.../cluster/query/filter/SlotTsFileFilter.java | 3 +-
.../apache/iotdb/cluster/server/ClientServer.java | 2 +-
.../iotdb/cluster/server/DataClusterServer.java | 8 +-
.../iotdb/cluster/server/MetaClusterServer.java | 2 +-
.../apache/iotdb/cluster/server/RaftServer.java | 27 +-----
.../server/handlers/caller/ElectionHandler.java | 4 +-
.../caller/GetChildNodeNextLevelPathHandler.java | 2 +-
.../handlers/caller/GetNodesListHandler.java | 2 +-
.../caller/GetTimeseriesSchemaHandler.java | 2 +-
.../server/handlers/caller/HeartbeatHandler.java | 92 +++++++++---------
.../server/handlers/caller/JoinClusterHandler.java | 2 +-
.../server/handlers/caller/LogCatchUpHandler.java | 4 +
.../handlers/forwarder/GenericForwardHandler.java | 41 --------
.../server/heartbeat/DataHeartbeatServer.java | 2 +-
.../cluster/server/heartbeat/HeartbeatServer.java | 27 +-----
.../server/heartbeat/MetaHeartbeatServer.java | 2 +-
.../cluster/server/member/DataGroupMember.java | 51 +++++-----
.../cluster/server/member/MetaGroupMember.java | 107 ++++++++++-----------
.../iotdb/cluster/server/member/RaftMember.java | 32 +++---
.../cluster/server/service/DataAsyncService.java | 5 +-
.../cluster/server/service/DataSyncService.java | 2 +-
.../cluster/server/service/MetaAsyncService.java | 4 +-
.../apache/iotdb/cluster/utils/ClusterUtils.java | 41 ++++++++
.../apache/iotdb/cluster/utils/PartitionUtils.java | 3 +-
.../apache/iotdb/cluster/utils/PlanSerializer.java | 20 +++-
.../cluster/log/applier/DataLogApplierTest.java | 3 +-
.../FilePartitionedSnapshotLogManagerTest.java | 2 +-
.../cluster/partition/SlotPartitionTableTest.java | 2 +
.../forwarder/GenericForwardHandlerTest.java | 70 --------------
.../iotdb/cluster/server/member/MemberTest.java | 2 +-
.../cluster/server/member/MetaGroupMemberTest.java | 2 +-
.../engine/storagegroup/StorageGroupProcessor.java | 1 +
.../iotdb/db/qp/physical/crud/InsertPlan.java | 6 +-
.../iotdb/db/qp/physical/crud/InsertRowPlan.java | 5 +
.../iotdb/db/query/executor/fill/LinearFill.java | 7 +-
.../storagegroup/StorageGroupProcessorTest.java | 2 +-
58 files changed, 358 insertions(+), 476 deletions(-)
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/forwarder/GenericForwardHandler.java
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/forwarder/GenericForwardHandlerTest.java
