This is an automated email from the ASF dual-hosted git repository.
shuwenwei pushed a change to branch skipNotSatisfiedTimeRange
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 11e63cba392 optimize nextBatch
add 72c3e915f70 Fixed the failure of IoTDBDistinctTagIT
add e188287645f fix: Handle NaN results in approx_percentile evaluation
add 9a25d725313 fix login locked error message (#16550)
add 76852612417 User userId to check whether the user is admin in
ConfigNode (#16554)
add db28f95e901 Add method to convert author type
add 26aa85378f5 Fix NPE for audit func. (#16556)
add a7e042fae03 fix: count device operation
add a3116f46591 Fix initial old password not encrypted & bump TsFile
Version (#16557)
add d6c2719f95a Fix that quotes cannot be passed to start-cli-table.bat
(#16558)
add 36f98a99910 encrypt audit log (#16551)
add 4256d38070d Add keystore truststore expire check and avoid unnecessary
error log printed (#16552)
add 38793052091 Fix UserLockInfo concurrency (#16559)
add 7110f166d64 Update keystore truststore for tests (#16561)
add 558839f3d59 Fix audit log for list user, role and privilege (#16562)
add 18964f41cda Patch for AUDIT privilege authentication on table model
(#16563)
add 2df8710feef Pipe: Cleaned some questionable parameters & Fixed
unstable testPipeAfterDataRegionLeaderStop (#16555)
add ea7e2a68b92 Fix cast of TimeColumn after deserialize
add d65fa92f563 Fix author type conversion (#16560)
add 5621279d5e2 Audit SQL 'COUNT DATABASE' (#16569)
add 629860ade15 fix: Updated TSFile version to fix Load failure in
creating aligned time series (#16502)
add e22a54f44b2 Pipe: Fixed the potential memory shortage may lead to
forever blocking (#16570)
add 006b6fc57d4 enable_grant_option first start take effect (#16572)
add 2a8707b6138 Merge branch 'iotdb_master' into skipNotSatisfiedTimeRange
add 5e939bbe3d8 fix npe
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/db/it/audit/AuditLogSet.java | 87 +
.../iotdb/db/it/audit/IoTDBAuditLogBasicIT.java | 3337 +++++++++++++-------
.../org/apache/iotdb/db/it/auth/IoTDBAuthIT.java | 14 +
.../apache/iotdb/db/it/auth/IoTDBUserRenameIT.java | 15 +-
.../iotdb/db/it/schema/IoTDBCountDeviceIT.java | 268 ++
.../IoTDBUDFIntermediateBlockSerdeIT.java} | 30 +-
.../manual/enhanced/IoTDBPipeClusterIT.java | 342 +-
.../IoTDBPipeTypeConversionISessionIT.java | 114 +-
.../manual/IoTDBPipeTypeConversionISessionIT.java | 91 +-
.../it/query/recent/IoTDBDistinctTagIT.java | 2 +
.../it/query/recent/IoTDBTableAggregationIT.java | 36 +-
.../it/session/IoTDBSessionRelationalIT.java | 44 +-
.../session/it/IoTDBSessionSchemaTemplateIT.java | 4 -
integration-test/src/test/resources/test-keystore | Bin 2429 -> 2710 bytes
.../src/test/resources/test-truststore | Bin 1149 -> 1238 bytes
.../apache/iotdb/rpc/BaseRpcTransportFactory.java | 12 +-
.../iotdb/rpc/NettyTNonblockingTransport.java | 23 +-
.../apache/iotdb/rpc/TElasticFramedTransport.java | 10 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 2 +
.../iotdb/confignode/manager/node/NodeManager.java | 1 +
.../confignode/persistence/auth/AuthorInfo.java | 55 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 50 +-
.../org/apache/iotdb/db/audit/DNAuditLogger.java | 66 +-
.../org/apache/iotdb/db/auth/LoginLockManager.java | 13 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 25 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 58 +-
.../metadata/AlignedTimeseriesException.java | 33 -
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 4 +-
.../agent/task/subtask/sink/PipeSinkSubtask.java | 3 +
.../scan/TsFileInsertionEventScanParser.java | 3 +-
.../table/TsFileInsertionEventTableParser.java | 2 +-
.../visitor/PipeStatementTSStatusVisitor.java | 5 -
.../db/pipe/resource/memory/PipeMemoryManager.java | 6 -
.../iotdb/db/protocol/session/SessionManager.java | 8 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 2 +-
.../operator/schema/SchemaCountOperator.java | 54 +-
.../operator/schema/source/DeviceSchemaSource.java | 8 +
.../operator/schema/source/ISchemaSource.java | 4 +
.../execution/operator/source/SeriesScanUtil.java | 7 +
.../AbstractApproxPercentileAccumulator.java | 13 +-
...AbstractGroupedApproxPercentileAccumulator.java | 13 +-
.../execution/operator/window/SessionWindow.java | 13 +-
.../execution/operator/window/TimeWindow.java | 9 +-
.../analyze/load/LoadTsFileTableSchemaCache.java | 3 +-
.../relational/security/AccessControlImpl.java | 52 +-
.../relational/security/ITableAuthCheckerImpl.java | 39 +-
.../security/TreeAccessCheckVisitor.java | 55 +-
.../plan/relational/type/AuthorRType.java | 5 +
.../db/queryengine/plan/statement/AuthorType.java | 106 +-
.../dag/intermediate/MultiInputLayer.java | 35 +-
.../SingleInputMultiReferenceLayer.java | 27 +-
.../SingleInputSingleReferenceLayer.java | 27 +-
.../transformation/dag/udf/UDTFExecutor.java | 2 +-
.../transformation/dag/util/LayerCacheUtils.java | 5 +-
.../transformation/datastructure/TVColumns.java | 7 +-
.../tv/ElasticSerializableBinaryTVList.java | 3 +-
.../datastructure/tv/SerializableTVList.java | 6 +-
.../org/apache/iotdb/db/service/RestService.java | 2 +-
.../db/storageengine/dataregion/DataRegion.java | 9 +-
.../constant/CrossCompactionPerformer.java | 16 +
.../constant/InnerSeqCompactionPerformer.java | 16 +
.../constant/InnerUnseqCompactionPerformer.java | 16 +
.../performer/impl/FastCompactionPerformer.java | 42 +-
.../impl/ReadChunkCompactionPerformer.java | 48 +-
.../impl/ReadPointCompactionPerformer.java | 53 +-
.../RepairUnsortedFileCompactionPerformer.java | 14 +-
.../task/RepairUnsortedFileCompactionTask.java | 7 +-
.../task/subtask/ReadPointPerformerSubTask.java | 8 +-
...BatchedFastAlignedSeriesCompactionExecutor.java | 8 +-
...edReadChunkAlignedSeriesCompactionExecutor.java | 9 +-
.../FirstBatchCompactionAlignedChunkWriter.java | 51 +-
...FollowingBatchCompactionAlignedChunkWriter.java | 16 +-
.../fast/FastAlignedSeriesCompactionExecutor.java | 6 +-
.../FastNonAlignedSeriesCompactionExecutor.java | 8 +-
.../readchunk/AlignedSeriesCompactionExecutor.java | 5 +-
.../ReadChunkAlignedSeriesCompactionExecutor.java | 4 +-
.../readchunk/SingleSeriesCompactionExecutor.java | 9 +-
.../utils/writer/AbstractCompactionWriter.java | 5 +
.../writer/AbstractCrossCompactionWriter.java | 23 +-
.../writer/AbstractInnerCompactionWriter.java | 30 +-
.../utils/writer/FastCrossCompactionWriter.java | 16 +-
.../utils/writer/FastInnerCompactionWriter.java | 20 +-
.../writer/ReadPointCrossCompactionWriter.java | 14 +-
.../writer/ReadPointInnerCompactionWriter.java | 20 +-
.../writer/RepairUnsortedFileCompactionWriter.java | 12 +-
.../compaction/io/CompactionTsFileWriter.java | 19 +-
.../schedule/CompactionScheduleContext.java | 23 +-
.../compaction/schedule/CompactionScheduler.java | 7 +-
.../utils/CrossSpaceCompactionCandidate.java | 1 +
.../compaction/settle/SettleRequestHandler.java | 13 +-
.../compaction/tool/TsFileStatisticReader.java | 6 +-
.../dataregion/memtable/AbstractMemTable.java | 10 +-
.../memtable/AbstractWritableMemChunk.java | 4 +
.../memtable/AlignedWritableMemChunk.java | 36 +-
.../memtable/AlignedWritableMemChunkGroup.java | 9 +
.../dataregion/memtable/IWritableMemChunk.java | 3 +
.../memtable/IWritableMemChunkGroup.java | 3 +
.../dataregion/memtable/TsFileProcessor.java | 7 +-
.../dataregion/memtable/WritableMemChunk.java | 25 +-
.../dataregion/memtable/WritableMemChunkGroup.java | 19 +-
.../dataregion/read/control/FileReaderManager.java | 13 +-
.../read/reader/chunk/MemAlignedPageReader.java | 3 +
.../read/reader/chunk/MemPageReader.java | 3 +
.../dataregion/utils/TsFileResourceUtils.java | 6 +-
.../file/AbstractTsFileRecoverPerformer.java | 19 +-
.../iotdb/db/tools/utils/TsFileSequenceScan.java | 7 +-
.../apache/iotdb/db/utils/DataNodeAuthUtils.java | 6 +-
.../org/apache/iotdb/db/utils/EncryptDBUtils.java | 86 +
.../apache/iotdb/db/auth/LoginLockManagerTest.java | 33 +
.../auth/authorizer/LocalFileAuthorizerTest.java | 2 +-
.../load/TimeseriesMetadataIteratorTest.java | 173 +
.../commons/auth/authorizer/BasicAuthorizer.java | 26 +-
.../iotdb/commons/auth/authorizer/IAuthorizer.java | 2 -
.../auth/authorizer/LocalFileAuthorizer.java | 5 -
.../commons/auth/authorizer/OpenIdAuthorizer.java | 1 -
.../iotdb/commons/auth/user/BasicUserManager.java | 9 +
.../apache/iotdb/commons/conf/CommonConfig.java | 63 +-
.../iotdb/commons/conf/CommonDescriptor.java | 3 +-
.../exception/pipe/PipeNonReportException.java | 6 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 53 +-
.../iotdb/commons/pipe/config/PipeDescriptor.java | 20 +-
.../pipe/receiver/PipeReceiverStatusHandler.java | 4 +-
.../service/AbstractThriftServiceThread.java | 45 +-
.../db/relational/grammar/sql/RelationalSql.g4 | 16 +-
.../src/main/thrift/confignode.thrift | 11 +-
pom.xml | 2 +-
scripts/sbin/windows/start-cli-table.bat | 12 +-
127 files changed, 4541 insertions(+), 2018 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/audit/AuditLogSet.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBCountDeviceIT.java
copy
integration-test/src/test/java/org/apache/iotdb/db/it/{query/IoTDBArithmeticDivAndModWithoutDoubleIT.java
=> udf/IoTDBUDFIntermediateBlockSerdeIT.java} (67%)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/metadata/AlignedTimeseriesException.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/EncryptDBUtils.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/analyze/load/TimeseriesMetadataIteratorTest.java
copy
iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/exception/PipeParameterNotValidException.java
=>
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/pipe/PipeNonReportException.java
(82%)
