This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a change to branch fix_thrift_out_of_sequence
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
discard 19e28f6 remove logs
discard 805858a fix review
discard ba2649c tmp fix
discard 0dcbad8 fix
add b7e39fd [To rel/0.12][IoTDB-1499] Remove series registeration using
IoTDBSink -> 0.12 (#3575)
add a0fe4e9 [IOTDB-1491] UDTF query supported in cluster mode (#3565)
(#3603)
add 845ad2f [IOTDB-1456] Fix Error occurred while executing delete
timeseries statement (#3474) (#3600)
add 153a4a3 modify NodeTool user to root (#3593)
add c56f71f remove EXCEPTION in IoTDBSink(#3619)
add 822a735 [To rel/0.12][IOTDB-959]Add createStorageGroup Grammar (#3616)
add 2f7c945 [To rel/0.12] [IOTDB-1500] Remove current dynamic query
memory control (#3564)
add 8a1aba5 Fix compile error in assignQueryId(#3628)
add 30e3dad [To rel/0.12] Revert commit bf6d83cd (#3534) and commit
cac70a50 (#3568) (#3634)
add 18f0144 [To rel/0.12] Cherry pick from autoai (#3637)
add 87fb3d9 fix bug in compaction (#3626)
add 9be4d2f replace synchronized with write lock in cross compaction
selection (#3633)
add 2489b6e [IOTDB-1529]Fix mlog recover idx bug and synchronize
setStorageGroup (#3636)
add 0b0577f tmp fix
add af387e6 fix review
add 533781b remove logs
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 (19e28f6)
\
N -- N -- N refs/heads/fix_thrift_out_of_sequence (533781b)
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:
.../antlr4/org/apache/iotdb/db/qp/sql/SqlBase.g4 | 1 +
.../iotdb/cluster/log/applier/BaseApplier.java | 17 +-
.../apache/iotdb/cluster/query/ClusterPlanner.java | 13 +-
.../iotdb/cluster/query/ClusterQueryRouter.java | 40 +++++
.../cluster/query/ClusterUDTFQueryExecutor.java | 12 +-
.../iotdb/cluster/query/LocalQueryExecutor.java | 32 +---
.../cluster/query/manage/ClusterQueryManager.java | 8 +-
.../utils/nodetool/function/NodeToolCmd.java | 2 +-
.../org/apache/iotdb/cluster/common/IoTDBTest.java | 3 +-
.../query/ClusterAggregateExecutorTest.java | 4 +-
.../query/ClusterDataQueryExecutorTest.java | 10 +-
.../cluster/query/ClusterFillExecutorTest.java | 4 +-
.../cluster/query/ClusterPlanExecutorTest.java | 4 +-
.../cluster/query/ClusterQueryRouterTest.java | 45 ++++-
.../query/ClusterUDTFQueryExecutorTest.java | 116 ++++++++++++
.../ClusterGroupByNoVFilterDataSetTest.java | 2 +-
.../groupby/ClusterGroupByVFilterDataSetTest.java | 2 +-
.../query/groupby/MergeGroupByExecutorTest.java | 4 +-
.../query/groupby/RemoteGroupByExecutorTest.java | 4 +-
.../query/manage/ClusterQueryManagerTest.java | 12 +-
.../query/reader/ClusterReaderFactoryTest.java | 2 +-
.../query/reader/ClusterTimeGeneratorTest.java | 4 +-
.../cluster/server/member/DataGroupMemberTest.java | 2 +-
.../cluster/server/member/MetaGroupMemberTest.java | 4 +-
.../UserGuide/Ecosystem Integration/Flink IoTDB.md | 3 +-
.../DDL-Data-Definition-Language.md | 6 +-
.../DDL-Data-Definition-Language.md | 6 +-
.../org/apache/iotdb/flink/FlinkIoTDBSink.java | 1 -
.../org/apache/iotdb/SessionConcurrentExample.java | 198 +++++++++++++++++++++
.../java/org/apache/iotdb/flink/IoTDBSink.java | 19 +-
.../iotdb/flink/options/IoTDBSinkOptions.java | 11 --
.../compaction/CompactionMergeTaskPoolManager.java | 4 +-
.../db/engine/compaction/TsFileManagement.java | 148 +++++++--------
.../level/LevelCompactionTsFileManagement.java | 13 +-
.../db/engine/merge/manage/MergeResource.java | 3 +-
.../merge/selector/MaxFileMergeFileSelector.java | 15 +-
.../db/engine/storagegroup/TsFileProcessor.java | 5 +
.../db/engine/storagegroup/TsFileResource.java | 2 +-
.../exception/query/PathNumOverLimitException.java | 9 +-
.../org/apache/iotdb/db/metadata/MManager.java | 28 ++-
.../java/org/apache/iotdb/db/metadata/MTree.java | 25 +--
.../org/apache/iotdb/db/monitor/StatMonitor.java | 2 +-
.../main/java/org/apache/iotdb/db/qp/Planner.java | 31 +---
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 10 ++
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 18 +-
.../qp/strategy/optimizer/ILogicalOptimizer.java | 3 +-
.../db/query/control/QueryResourceManager.java | 48 +----
.../iotdb/db/query/control/SessionManager.java | 10 +-
.../iotdb/db/rescon/PrimitiveArrayManager.java | 10 +-
.../org/apache/iotdb/db/service/TSServiceImpl.java | 68 +------
.../db/writelog/node/ExclusiveWriteLogNode.java | 81 +++------
.../writelog/recover/TsFileRecoverPerformer.java | 25 ++-
.../compaction/LevelCompactionRecoverTest.java | 1 -
.../db/integration/IoTDBCreateStorageGroupIT.java | 128 +++++++++++++
.../iotdb/db/integration/IoTDBRestartIT.java | 48 +++++
.../db/integration/IoTDBSequenceDataQueryIT.java | 9 +-
.../iotdb/db/integration/IoTDBSeriesReaderIT.java | 11 +-
.../iotdb/db/qp/logical/LogicalPlanSmallTest.java | 2 +-
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 8 +
.../apache/iotdb/db/utils/EnvironmentUtils.java | 2 +-
.../apache/iotdb/spark/db/EnvironmentUtils.java | 111 ++++++------
.../read/expression/util/ExpressionOptimizer.java | 34 ++--
62 files changed, 964 insertions(+), 539 deletions(-)
copy
server/src/main/java/org/apache/iotdb/db/query/executor/UDTFQueryExecutor.java
=>
cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterUDTFQueryExecutor.java
(91%)
create mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterUDTFQueryExecutorTest.java
create mode 100644
example/session/src/main/java/org/apache/iotdb/SessionConcurrentExample.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/integration/IoTDBCreateStorageGroupIT.java
