This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch IOTDB-3337
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from fae9e89e08 [IOTDB-3337] return error which insert wrong type of data
add 31e5893900 [IOTDB-3315] Make unset of ttl in cluster mode same as
0.13.0 version. (#6061)
add 23bb94e2e5 [IOTDB-3271] Wrong multi IP for one sender in receiver
(#6037)
add bb1a88540d [ISSUES-6057] Add a method(getAllDataRegionID) to
StorageEngineV2 (#6059)
add fcb27a8449 [IOTDB-3228] UDF Management in MPP Cluster: DROP FUNCTION
(#6064)
add 4f101d8acf [IOTDB-3246]Improve Validation tool (#6066)
add e1dfec58e3 [IOTDB-3320] Don't return data which are not satisfied with
time filter in last query (#6068)
add 88426aa3e3 [IOTDB-3319] fix IndexOutOfBoundsException when executing
linear fill in group by query (#6070)
add 8500eb9cd1 Fix aligned data in memory query bug (#6065)
add c84095d093 [IOTDB-3325] Thrown an exception when using group by in raw
data query (#6077)
add c01b1e1504 [IOTDB-3335] Redundant data recovered by wal in
multi-leader consensus (#6076)
add 7fcb1044e7 [IOTDB-3306] Use rpc port check to avoid starting same
IoTDB twice (#6069)
add 88adfbea69 [IOTDB-3229] Field is 0 rather than null when query two
series in one device (#6071)
add b343478a41 [IOTDB-3339] Fix index out of bound while doing raw query
(#6079)
add 48256e44f3 [IOTDB-3341] Fix timeseries id is not right while doing
last query (#6082)
new 6f2c3bfa57 [IOTDB-3337] return error which insert wrong type of data
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:
.../confignode/client/AsyncDataNodeClientPool.java | 19 +++-
...Handler.java => FunctionManagementHandler.java} | 6 +-
.../consensus/request/ConfigRequest.java | 4 +
.../consensus/request/ConfigRequestType.java | 1 +
...eleteProcedureReq.java => DropFunctionReq.java} | 38 +++----
.../iotdb/confignode/manager/ConfigManager.java | 8 ++
.../apache/iotdb/confignode/manager/Manager.java | 2 +
.../iotdb/confignode/manager/UDFManager.java | 59 +++++++++--
.../iotdb/confignode/persistence/UDFInfo.java | 25 ++++-
.../executor/ConfigRequestExecutor.java | 3 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 6 ++
.../db/integration/sync/IoTDBSyncReceiverIT.java | 5 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 1 -
.../service/AbstractThriftServiceThread.java | 38 +------
.../udf/service/UDFRegistrationService.java | 8 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 17 ++++
.../apache/iotdb/db/engine/StorageEngineV2.java | 11 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 7 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 5 +-
.../db/engine/storagegroup/TsFileProcessor.java | 2 +-
.../SmoothQueueSlidingWindowAggregator.java | 1 +
.../iotdb/db/mpp/common/header/HeaderConstant.java | 4 +-
.../execution/operator/process/FilterOperator.java | 80 +++++++--------
.../operator/process/LinearFillOperator.java | 3 +-
.../operator/process/TransformOperator.java | 70 +++++++------
.../operator/process/UpdateLastCacheOperator.java | 5 +
.../operator/process/merge/SingleColumnMerger.java | 4 +-
.../plan/execution/config/ConfigTaskVisitor.java | 7 ++
...eateFunctionTask.java => DropFunctionTask.java} | 38 ++-----
.../execution/config/ShowStorageGroupTask.java | 7 +-
.../db/mpp/plan/execution/config/ShowTTLTask.java | 5 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 8 ++
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 6 +-
.../db/mpp/plan/statement/StatementVisitor.java | 5 +
.../db/mpp/plan/statement/crud/QueryStatement.java | 4 +
...onStatement.java => DropFunctionStatement.java} | 21 +---
.../query/reader/chunk/MemAlignedPageReader.java | 10 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 9 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 9 +-
.../thrift/impl/DataNodeTSIServiceImpl.java | 24 ++---
.../service/thrift/impl/InternalServiceImpl.java | 12 +++
.../db/sync/sender/service/TransportHandler.java | 5 +-
.../db/sync/transport/client/TransportClient.java | 21 ++--
.../db/tools/validate/TsFileValidationTool.java | 13 ++-
.../java/org/apache/iotdb/db/wal/WALManager.java | 15 ++-
.../allocation/AbstractNodeAllocationStrategy.java | 9 ++
.../db/wal/allocation/FirstCreateStrategy.java | 4 +-
.../iotdb/db/wal/buffer/AbstractWALBuffer.java | 4 +-
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 7 +-
.../iotdb/db/wal/checkpoint/CheckpointManager.java | 40 +++++---
.../iotdb/db/wal/checkpoint/MemTableInfo.java | 1 -
.../apache/iotdb/db/wal/io/CheckpointReader.java | 22 ++--
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 7 +-
.../db/wal/recover/CheckpointRecoverUtils.java | 32 +++++-
.../iotdb/db/wal/recover/WALNodeRecoverTask.java | 34 ++++++-
.../iotdb/db/wal/utils/CheckpointFileUtils.java | 3 +-
.../apache/iotdb/db/wal/utils/WALFileUtils.java | 30 +++---
.../iotdb/db/engine/StorageEngineV2Test.java | 71 +++++++++++++
.../execution/operator/LinearFillOperatorTest.java | 113 ++++++++++++++++++++-
.../db/sync/transport/TransportServiceTest.java | 8 +-
.../db/wal/allocation/FirstCreateStrategyTest.java | 2 +-
.../db/wal/checkpoint/CheckpointManagerTest.java | 6 +-
.../apache/iotdb/db/wal/io/CheckpointFileTest.java | 12 ++-
.../iotdb/db/wal/node/ConsensusReqReaderTest.java | 14 +--
.../org/apache/iotdb/db/wal/node/WALNodeTest.java | 2 +-
.../src/main/thrift/confignode.thrift | 8 +-
thrift/src/main/thrift/mpp.thrift | 11 ++
.../iotdb/tsfile/read/common/block/TsBlock.java | 3 +-
68 files changed, 739 insertions(+), 355 deletions(-)
rename
confignode/src/main/java/org/apache/iotdb/confignode/client/handlers/{CreateFunctionHandler.java
=> FunctionManagementHandler.java} (89%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{DeleteProcedureReq.java
=> DropFunctionReq.java} (62%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{CreateFunctionTask.java
=> DropFunctionTask.java} (69%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{CreateFunctionStatement.java
=> DropFunctionStatement.java} (76%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/StorageEngineV2Test.java
