This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a change to branch compaction_recover_logger_1017
in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard 6c65947407c complete draft version for inner compaction refactor
add 15824d9a292 Pipe: fix missing `pipeReceiverFileDir` update after
updating `systemDir` during conf initialization (#11318)
add 37a5212f23a [IOTDB-6175] Add TopKNode for `order by time|expression
limit N align by device` query and push down LIMIT value.
add 87a15d2860a [IOTDB-6189] Fix bugs for csv-tools (The output is
incorrect when the import fails. The csv file with bom header can not be
imported. The last line can not be imported) (#11308)
add fd1b9823d8e Refactor/managing dependencies (#11150)
add b029ffffa42 Bump org.xerial.snappy:snappy-java from 1.1.8.4 to
1.1.10.4 (#11216)
add 2eec1fb633e Bump
go.opentelemetry.io/contrib/instrumentation/net/http/httptrace/otelhttptrace
(#11321)
add 3727570a7c6 fixed grafana-plugin compilation failure (#11322)
add 7aaeb22b62c Bump @babel/traverse in /iotdb-connector/grafana-plugin
(#11325)
add 9a25e6c4ba4 Bump org.eclipse.jetty:jetty-http (#11326)
new 2584ef11703 complete draft version for inner compaction refactor
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 (6c65947407c)
\
N -- N -- N refs/heads/compaction_recover_logger_1017
(2584ef11703)
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.
The 1 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:
code-coverage/pom.xml | 72 +-
distribution/pom.xml | 165 +-
example/client-cpp-example/pom.xml | 28 +-
example/flink-sql/pom.xml | 2 +-
example/flink/pom.xml | 22 +-
example/hadoop/pom.xml | 2 +-
example/jdbc/pom.xml | 4 +-
example/pom.xml | 61 +-
example/pulsar/pom.xml | 2 +-
example/rest-java-example/pom.xml | 7 +-
example/rocketmq/pom.xml | 2 +-
example/session/pom.xml | 3 +-
example/trigger/pom.xml | 10 +-
example/udf/pom.xml | 4 +-
integration-test/checkstyle.xml | 2 +-
integration-test/pom.xml | 592 +++--
.../iotdb/it/env/cluster/env/AbstractEnv.java | 12 +-
.../it/env/cluster/node/AbstractNodeWrapper.java | 18 +-
.../iotdb/it/env/remote/env/RemoteServerEnv.java | 7 +-
.../iotdb/it/framework/IoTDBTestConstants.java | 11 +-
.../iotdb/it/framework/IoTDBTestReporter.java | 4 +-
.../apache/iotdb/it/framework/IoTDBTestStat.java | 4 +-
.../IoTDBOrderByLimitOffsetAlignByDeviceIT.java | 102 +
.../IoTDBOrderByWithAlignByDeviceIT.java | 290 ++-
.../db/it/aligned/IoTDBGroupByLevelQueryIT.java | 12 +-
.../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 10 +-
.../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 159 +-
.../db/it/withoutNull/IoTDBWithoutAllNullIT.java | 4 +-
.../iotdb/it/framework/IoTDBTestListener.java | 7 +-
.../apache/iotdb/it/framework/IoTDBTestRunner.java | 0
.../framework/IoTDBTestRunnerWithParameters.java | 0
.../IoTDBTestRunnerWithParametersFactory.java | 0
.../apache/iotdb/libudf/it/anomaly/AnomalyIT.java | 121 +-
.../iotdb/libudf/it/dprofile/DProfileIT.java | 12 +-
.../iotdb/libudf/it/dquality/DQualityIT.java | 2 +
.../apache/iotdb/libudf/it/drepair/DRepairIT.java | 2 +
.../iotdb/libudf/it/frequency/FrequencyIT.java | 2 +
.../iotdb/zeppelin/it/IoTDBInterpreterIT.java | 5 +-
iotdb-api/external-api/pom.xml | 8 +-
iotdb-api/pipe-api/pom.xml | 8 +-
iotdb-api/trigger-api/pom.xml | 14 +-
iotdb-api/udf-api/pom.xml | 6 +-
iotdb-client/cli/pom.xml | 178 +-
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 84 +-
iotdb-client/client-cpp/pom.xml | 61 +-
iotdb-client/client-py/pom.xml | 45 +-
iotdb-client/isession/pom.xml | 21 +-
iotdb-client/jdbc/pom.xml | 128 +-
.../test/java/org/apache/iotdb/jdbc/BatchTest.java | 2 +-
.../org/apache/iotdb/jdbc/IoTDBConnectionTest.java | 2 +-
.../iotdb/jdbc/IoTDBDatabaseMetadataTest.java | 2 +-
.../apache/iotdb/jdbc/IoTDBJDBCResultSetTest.java | 2 +-
.../iotdb/jdbc/IoTDBPreparedStatementTest.java | 2 +-
.../org/apache/iotdb/jdbc/IoTDBStatementTest.java | 2 +-
iotdb-client/service-rpc/pom.xml | 104 +-
iotdb-client/session/pom.xml | 105 +-
iotdb-connector/flink-iotdb-connector/pom.xml | 35 +-
.../iotdb/flink/IoTDBSinkBatchInsertTest.java | 2 +-
.../iotdb/flink/IoTDBSinkBatchTimerTest.java | 2 +-
.../apache/iotdb/flink/IoTDBSinkInsertTest.java | 2 +-
iotdb-connector/flink-sql-iotdb-connector/pom.xml | 72 +-
.../flink/sql/function/IoTDBLookupFunction.java | 4 +-
iotdb-connector/flink-tsfile-connector/pom.xml | 112 +-
.../src/test/resources/log4j.properties | 16 +-
iotdb-connector/grafana-connector/pom.xml | 138 +-
.../iotdb/web/grafana/conf/MyConfiguration.java | 15 +-
.../web/grafana/interceptor/LoginInterceptor.java | 14 +-
iotdb-connector/grafana-plugin/backend-compile.sh | 2 +-
iotdb-connector/grafana-plugin/go.mod | 10 +-
.../grafana-plugin/pkg/plugin/plugin.go | 6 +-
iotdb-connector/grafana-plugin/pom.xml | 6 +-
iotdb-connector/grafana-plugin/yarn.lock | 133 +-
iotdb-connector/hadoop/pom.xml | 105 +-
iotdb-connector/hive-connector/pom.xml | 178 +-
iotdb-connector/pom.xml | 15 +
iotdb-connector/spark-iotdb-connector/pom.xml | 101 +-
.../spark-iotdb-connector/scala_2.11/pom.xml | 5 +-
.../spark-iotdb-connector/scala_2.12/pom.xml | 7 +
iotdb-connector/spark-tsfile/pom.xml | 87 +-
iotdb-connector/zeppelin-interpreter/pom.xml | 38 +-
iotdb-core/antlr/pom.xml | 20 +-
iotdb-core/confignode/pom.xml | 150 +-
iotdb-core/consensus/pom.xml | 140 +-
.../ratis/metrics/IoTDBMetricRegistry.java | 2 +-
iotdb-core/datanode/pom.xml | 567 +++--
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 9 +-
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 5 +
.../protocol/rest/filter/AuthorizationFilter.java | 7 +-
.../execution/operator/process/TopKOperator.java | 323 +++
.../last/AlignedUpdateLastCacheOperator.java | 6 +-
.../db/queryengine/plan/analyze/Analysis.java | 11 +
.../plan/planner/LocalExecutionPlanner.java | 4 +-
.../plan/planner/LogicalPlanBuilder.java | 209 +-
.../plan/planner/LogicalPlanVisitor.java | 31 +-
.../plan/planner/OperatorTreeGenerator.java | 40 +
.../planner/distribution/DistributionPlanner.java | 16 +-
.../planner/distribution/ExchangeNodeAdder.java | 112 +-
.../plan/planner/distribution/SourceRewriter.java | 34 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 10 +
.../plan/planner/plan/node/PlanNodeType.java | 6 +-
.../plan/planner/plan/node/PlanVisitor.java | 5 +
.../process/{MergeSortNode.java => TopKNode.java} | 54 +-
.../planner/plan/node/sink/ShuffleSinkNode.java | 12 +-
.../org/apache/iotdb/db/service/MQTTService.java | 7 +-
.../db/utils/datastructure/MergeSortHeap.java | 4 +
.../iotdb/db/utils/datastructure/MergeSortKey.java | 3 +-
.../apache/iotdb/db/conf/IoTDBDescriptorTest.java | 40 +-
.../execution/operator/MergeSortOperatorTest.java | 163 +-
...SortOperatorTest.java => TopKOperatorTest.java} | 1009 ++-------
.../AlignByDeviceOrderByLimitOffsetTest.java | 278 +++
.../db/utils/datastructure/MergeSortHeapTest.java | 116 +
iotdb-core/metrics/dropwizard-metrics/pom.xml | 14 +-
iotdb-core/metrics/interface/pom.xml | 81 +-
.../iotdb/metrics/AbstractMetricService.java | 1 +
iotdb-core/metrics/micrometer-metrics/pom.xml | 10 +-
iotdb-core/metrics/pom.xml | 6 +-
iotdb-core/mlnode/pom.xml | 74 +-
iotdb-core/node-commons/pom.xml | 299 ++-
iotdb-core/tsfile/pom.xml | 182 +-
.../iotdb/tsfile/read/common/block/TsBlock.java | 46 +
.../iotdb/tsfile/utils/TsFileGeneratorForTest.java | 2 +
iotdb-protocol/openapi/pom.xml | 100 +-
iotdb-protocol/thrift-commons/pom.xml | 14 +-
iotdb-protocol/thrift-confignode/pom.xml | 28 +-
iotdb-protocol/thrift-consensus/pom.xml | 28 +-
iotdb-protocol/thrift-datanode/pom.xml | 46 +-
iotdb-protocol/thrift-mlnode/pom.xml | 28 +-
library-udf/pom.xml | 43 +-
pom.xml | 2376 +++++++++++++++-----
129 files changed, 6669 insertions(+), 3743 deletions(-)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/RpcThrottlingException.java
=>
integration-test/src/main/java/org/apache/iotdb/it/framework/IoTDBTestConstants.java
(83%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/alignbydevice/IoTDBOrderByLimitOffsetAlignByDeviceIT.java
rename integration-test/src/{main =>
test}/java/org/apache/iotdb/it/framework/IoTDBTestListener.java (89%)
rename integration-test/src/{main =>
test}/java/org/apache/iotdb/it/framework/IoTDBTestRunner.java (100%)
rename integration-test/src/{main =>
test}/java/org/apache/iotdb/it/framework/IoTDBTestRunnerWithParameters.java
(100%)
rename integration-test/src/{main =>
test}/java/org/apache/iotdb/it/framework/IoTDBTestRunnerWithParametersFactory.java
(100%)
copy docker/src/main/DockerCompose/start-1c1d.sh =>
iotdb-connector/flink-tsfile-connector/src/test/resources/log4j.properties (70%)
mode change 100755 => 100644
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/TopKOperator.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/process/{MergeSortNode.java
=> TopKNode.java} (71%)
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/{MergeSortOperatorTest.java
=> TopKOperatorTest.java} (60%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/plan/distribution/AlignByDeviceOrderByLimitOffsetTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/datastructure/MergeSortHeapTest.java
