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 085b751 fix an NPE and pullTimeseriesSchema to pullMeasurementSchema
new 487a467 async applier refine
new 52ff188 fix the async log applier bug
new 6602e8e add UT
new f794745 remove useless thread pool
new 0d2fbbe support flush plan when do snapshot
new ae1540f refine syncCloseOneProcessor method in StorageGroupProcessor
new ecb1a52 change the log msg
new 1101cfb fix the license
new 3833718 fix the check applir log index
new 7d1fa0d fix checkAppliedLogIndex
new f1071bd fix flushPlan bug
new 261dbfe fix flushPlan bug
new 4e8e25d add more log message
new 162edfb make
new 9624981 Delete the extra blank lines
new 7ae9f80 fix flushplan serialize bug
new 5187c10 fix flushplan serialize bug
new e299193 add flushPlan test
new 4027bba Delete the extra blank lines
new 94b5a10 move syncFlushAllProcessor out of synchronized (logmanager) in
new 5c3f239 make the applyEntries in one seperate thread
new 5ac7bf3 flush the partitions belong to the datagroup and fix some UT
new 8fda671 Merge pull request #1635 from
neuyilan/apache_cluster_new_0819_async_applier
The 4884 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../iotdb/cluster/ClusterFileFlushPolicy.java | 13 +-
.../cluster/log/applier/AsyncDataLogApplier.java | 4 +-
.../iotdb/cluster/log/applier/BaseApplier.java | 8 +-
.../iotdb/cluster/log/applier/DataLogApplier.java | 4 +-
.../iotdb/cluster/log/catchup/CatchUpTask.java | 1 -
.../iotdb/cluster/log/catchup/LogCatchUpTask.java | 10 +-
.../cluster/log/catchup/SnapshotCatchUpTask.java | 2 -
.../cluster/log/logtypes/PhysicalPlanLog.java | 1 -
.../cluster/log/manage/CommittedEntryManager.java | 47 ++--
.../manage/FilePartitionedSnapshotLogManager.java | 47 +++-
.../log/manage/MetaSingleSnapshotLogManager.java | 10 +-
.../log/manage/PartitionedSnapshotLogManager.java | 7 +-
.../iotdb/cluster/log/manage/RaftLogManager.java | 267 +++++++++++++++++++--
.../cluster/server/member/DataGroupMember.java | 58 ++++-
.../cluster/server/member/MetaGroupMember.java | 9 +-
.../iotdb/cluster/common/TestLogApplier.java | 4 +-
.../cluster/common/TestPartitionedLogManager.java | 5 +-
.../iotdb/cluster/log/catchup/CatchUpTaskTest.java | 2 +
.../FilePartitionedSnapshotLogManagerTest.java | 20 +-
.../manage/MetaSingleSnapshotLogManagerTest.java | 1 +
.../cluster/log/manage/RaftLogManagerTest.java | 150 +++++++++++-
.../cluster/server/member/DataGroupMemberTest.java | 54 +++--
.../iotdb/cluster/server/member/MemberTest.java | 25 +-
.../cluster/server/member/MetaGroupMemberTest.java | 55 ++++-
.../org/apache/iotdb/db/engine/StorageEngine.java | 114 +++++++--
.../iotdb/db/engine/flush/TsFileFlushPolicy.java | 2 +-
.../engine/storagegroup/StorageGroupProcessor.java | 26 +-
.../org/apache/iotdb/db/metadata/MManager.java | 6 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 26 +-
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 7 +-
.../apache/iotdb/db/qp/physical/sys/FlushPlan.java | 168 ++++++++++++-
.../apache/iotdb/db/qp/plan/PhysicalPlanTest.java | 34 +--
.../apache/iotdb/db/qp/plan/SerializationTest.java | 68 +++++-
33 files changed, 1069 insertions(+), 186 deletions(-)
