You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by er...@apache.org on 2022/04/20 03:33:15 UTC
[iotdb] branch feature/mpp-sche-clean updated (e61bffb4d2 -> d51efa9d20)
This is an automated email from the ASF dual-hosted git repository.
ericpai pushed a change to branch feature/mpp-sche-clean
in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard e61bffb4d2 Add Driver.failed() call in FragmentInstanceScheduler
add 3d93a7764f Optimize dependencies management to reduce the lib size (#5582)
add f52beecbde Add input location for TimeJoinNode (#5585)
add ac51b0802a [IOTDB-2873] Apache IoTDB Dashboard: Grafana Metrics Template (#5587)
add 4d34f363af [IOTDB-2925]Add Schema File sketch tool (#5570)
add 2be90fe96d Rename thrift EndPoint to TEndPoint (#5590)
add e891a68c13 [IOTDB-2917] Fix flush operation has one residual wal file (#5560)
add eba44b18df [IOTDB-2954] fix influxdb protocol bug found in benchmark test of verificationQueryMode (#5594)
add 79b22a2799 Add UTs for new insert framework and fix insertRowNode memControl (#5576)
add 3bc4955429 [IOTDB-2887][IOTDB-2930][IOTDB-2932] Fix recover test error in CI & Fix NPE while concurrent createTimeseries & Add config check for schema engine mode (#5601)
add 1d0b0ec288 Fix some issues in MPP framework (#5596)
add d51efa9d20 Add Driver.failed() call in FragmentInstanceScheduler
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (e61bffb4d2)
\
N -- N -- N refs/heads/feature/mpp-sche-clean (d51efa9d20)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
LICENSE | 1 +
.../iotdb/cluster/coordinator/Coordinator.java | 6 +-
.../cluster/server/member/DataGroupMember.java | 11 +-
.../cluster/server/member/MetaGroupMember.java | 6 +-
.../cluster/server/service/BaseAsyncService.java | 4 +-
.../apache/iotdb/cluster/utils/StatusUtils.java | 6 +-
.../consensus/response/DataNodesInfoDataSet.java | 4 +-
.../confignode/consensus/RatisConsensusDemo.java | 6 +-
.../manager/ConfigManagerManualTest.java | 6 +-
.../server/ConfigNodeRPCServerProcessorTest.java | 26 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 4 +-
cross-tests/pom.xml | 2 +
distribution/src/assembly/all.xml | 4 +
distribution/src/assembly/server.xml | 4 +
docs/UserGuide/Maintenance-Tools/Metric-Tool.md | 12 +-
...MLogParser-Tool.md => SchemaFileSketch-Tool.md} | 12 +-
docs/zh/UserGuide/Maintenance-Tools/Metric-Tool.md | 12 +-
...MLogParser-Tool.md => SchemaFileSketch-Tool.md} | 14 +-
.../Apache IoTDB Dashboard v0.13.1.json | 1527 ++++++++++++++++++++
.../Apache IoTDB Dashboard v0.14.0.json | 1527 ++++++++++++++++++++
influxdb-protocol/pom.xml | 2 +-
.../iotdb/influxdb/protocol/dto/SessionPoint.java | 8 +-
.../iotdb/influxdb/session/InfluxDBSession.java | 6 +-
.../influxdb/integration/IoTDBInfluxDBIT.java | 4 +-
.../iotdb/commons/partition/DataPartition.java | 17 +-
.../{PartitionInfo.java => Partition.java} | 27 +-
.../iotdb/commons/partition/RegionReplicaSet.java | 6 +-
.../iotdb/commons/partition/SchemaPartition.java | 17 +-
server/pom.xml | 1 +
.../SchemaFileSketcher.bat} | 4 +-
.../SchemaFileSketcher.sh} | 4 +-
.../tools/{mlog => schema}/mLogParser.bat | 2 +-
.../resources/tools/{mlog => schema}/mLogParser.sh | 0
.../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 8 +
.../db/engine/storagegroup/TsFileProcessor.java | 214 ++-
.../apache/iotdb/db/metadata/LocalConfigNode.java | 2 +-
.../db/metadata/LocalSchemaPartitionTable.java | 6 +
.../mtree/store/disk/MTreeFlushTaskManager.java | 2 +-
.../mtree/store/disk/MTreeReleaseTaskManager.java | 2 +-
.../mtree/store/disk/schemafile/ISegment.java | 2 +
.../mtree/store/disk/schemafile/RecordUtils.java | 24 +-
.../mtree/store/disk/schemafile/SchemaFile.java | 37 +-
.../mtree/store/disk/schemafile/SchemaPage.java | 9 +-
.../mtree/store/disk/schemafile/Segment.java | 51 +
.../iotdb/db/mpp/buffer/DataBlockManager.java | 14 +-
.../org/apache/iotdb/db/mpp/buffer/SinkHandle.java | 10 +-
.../apache/iotdb/db/mpp/buffer/SourceHandle.java | 27 +-
.../apache/iotdb/db/mpp/execution/Coordinator.java | 16 +-
.../iotdb/db/mpp/execution/IQueryExecution.java | 2 +
.../iotdb/db/mpp/execution/QueryExecution.java | 43 +-
.../iotdb/db/mpp/execution/QueryStateMachine.java | 14 +-
.../db/mpp/execution/config/ConfigExecution.java | 58 +-
...ampleConfigTask.java => ConfigTaskVisitor.java} | 30 +-
.../iotdb/db/mpp/execution/config/IConfigTask.java | 2 +-
.../mpp/execution/scheduler/ClusterScheduler.java | 31 +-
.../mpp/execution/scheduler/IQueryTerminator.java | 4 +-
.../scheduler/SimpleFragInstanceDispatcher.java | 51 +-
.../execution/scheduler/SimpleQueryTerminator.java | 50 +-
.../db/mpp/operator/source/SeriesScanOperator.java | 2 +-
.../db/mpp/schedule/FragmentInstanceScheduler.java | 6 +-
.../db/mpp/schedule/queue/L1PriorityQueue.java | 37 +-
.../db/mpp/schedule/queue/L2PriorityQueue.java | 66 +-
.../mpp/schedule/task/FragmentInstanceTaskID.java | 10 +-
.../db/mpp/sql/analyze/ClusterSchemaFetcher.java | 4 +-
.../db/mpp/sql/planner/DistributionPlanner.java | 20 +
.../{IOutputPlanNode.java => InputLocation.java} | 25 +-
.../db/mpp/sql/planner/plan/OutputColumn.java | 55 +
.../planner/plan/node/process/TimeJoinNode.java | 10 +
.../db/mpp/sql/statement/ConfigStatement.java | 8 +-
.../db/mpp/sql/statement/StatementVisitor.java | 5 +
.../metadata/SetStorageGroupStatement.java | 10 +-
.../db/protocol/influxdb/handler/QueryHandler.java | 4 +-
.../util/{CommonUtils.java => JacksonUtils.java} | 38 +-
.../db/protocol/influxdb/util/StringUtils.java | 3 +-
.../iotdb/db/query/control/SessionManager.java | 7 +-
.../db/query/dataset/AlignByDeviceDataSet.java | 4 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 4 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 2 +-
.../thrift/impl/DataNodeTSIServiceImpl.java | 11 +-
.../service/thrift/impl/InternalServiceImpl.java | 6 +-
.../db/service/thrift/impl/TSServiceImpl.java | 47 +-
.../db/tools/{mlog => schema}/MLogParser.java | 2 +-
.../db/tools/schema/SchemaFileSketchTool.java | 165 +++
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 2 +-
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 49 +-
...GroupProcessorTest.java => DataRegionTest.java} | 439 +++---
.../engine/storagegroup/TsFileProcessorTest.java | 17 +
...ocessorTest.java => TsFileProcessorV2Test.java} | 104 +-
.../iotdb/db/mpp/buffer/SourceHandleTest.java | 6 +-
.../db/mpp/execution/ConfigExecutionTest.java | 125 ++
.../db/mpp/schedule/queue/L1PriorityQueueTest.java | 22 +
.../db/mpp/schedule/queue/L2PriorityQueueTest.java | 27 +
.../db/mpp/sql/plan/DistributionPlannerTest.java | 39 +
.../org/apache/iotdb/db/tools/MLogParserTest.java | 2 +-
.../iotdb/db/tools/SchemaFileSketchTest.java | 158 ++
.../apache/iotdb/db/utils/EnvironmentUtils.java | 0
.../org/apache/iotdb/db/utils/SchemaTestUtils.java | 0
.../org/apache/iotdb/rpc/RedirectException.java | 14 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 4 +-
.../java/org/apache/iotdb/session/Session.java | 52 +-
.../apache/iotdb/session/SessionConnection.java | 16 +-
.../apache/iotdb/session/util/SessionUtils.java | 12 +-
.../apache/iotdb/session/SessionCacheLeaderUT.java | 28 +-
.../src/main/thrift/confignode.thrift | 4 +-
thrift/src/main/thrift/common.thrift | 6 +-
.../iotdb/tsfile/encoding/decoder/FreqDecoder.java | 26 +-
.../iotdb/tsfile/encoding/encoder/FreqEncoder.java | 26 +-
.../apache/iotdb/tsfile/utils/BitConstructor.java | 30 +-
108 files changed, 4877 insertions(+), 883 deletions(-)
copy docs/UserGuide/Maintenance-Tools/{MLogParser-Tool.md => SchemaFileSketch-Tool.md} (66%)
copy docs/zh/UserGuide/Maintenance-Tools/{MLogParser-Tool.md => SchemaFileSketch-Tool.md} (67%)
create mode 100644 grafana-metrics-example/Apache IoTDB Dashboard v0.13.1.json
create mode 100644 grafana-metrics-example/Apache IoTDB Dashboard v0.14.0.json
rename node-commons/src/main/java/org/apache/iotdb/commons/partition/{PartitionInfo.java => Partition.java} (55%)
copy server/src/assembly/resources/tools/{mlog/mLogParser.bat => schema/SchemaFileSketcher.bat} (95%)
copy server/src/assembly/resources/tools/{tsfileToolSet/print-tsfile-sketch.sh => schema/SchemaFileSketcher.sh} (91%)
mode change 100755 => 100644
rename server/src/assembly/resources/tools/{mlog => schema}/mLogParser.bat (98%)
rename server/src/assembly/resources/tools/{mlog => schema}/mLogParser.sh (100%)
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/config/{SampleConfigTask.java => ConfigTaskVisitor.java} (58%)
copy server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/{IOutputPlanNode.java => InputLocation.java} (65%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/OutputColumn.java
copy cluster/src/main/java/org/apache/iotdb/cluster/server/member/package-info.java => server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/ConfigStatement.java (74%)
copy server/src/main/java/org/apache/iotdb/db/protocol/influxdb/util/{CommonUtils.java => JacksonUtils.java} (59%)
rename server/src/main/java/org/apache/iotdb/db/tools/{mlog => schema}/MLogParser.java (99%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/tools/schema/SchemaFileSketchTool.java
copy server/src/test/java/org/apache/iotdb/db/engine/storagegroup/{StorageGroupProcessorTest.java => DataRegionTest.java} (68%)
copy server/src/test/java/org/apache/iotdb/db/engine/storagegroup/{TsFileProcessorTest.java => TsFileProcessorV2Test.java} (84%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/ConfigExecutionTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/tools/SchemaFileSketchTest.java
rename server/src/{main => test}/java/org/apache/iotdb/db/utils/EnvironmentUtils.java (100%)
rename server/src/{main => test}/java/org/apache/iotdb/db/utils/SchemaTestUtils.java (100%)