This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch force_ci/object_type
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 2bdba56dcb9 Added name check to avoid directory attack (#16720)
new 12325d91d9a Pipe: Ignore logging when `returnSelf` is called in the
event of an exception in `AsyncClient`. (#16827)
new 6e5bc59717f Fixed the schema cache calculation 2 & The potential NPE
caused by concurrent invalidate and update (#16834)
new 41736a5f3bf Fix the check of grant option for tree model (#16845)
new 4057642badd Pipe: Fixed the bug that lower version tablet may cause
NPE when sent to 2.x version & The temporary exception may be wrongly reported
(#16843)
new 57348f53aad Pipe: Fixed the auth implementation error (#16847)
new 21c64b0607a Fix NPE during compaction when disk space is insufficient
(#16841)
new 42dfbd2bbb6 PipePlugin: Optimized the errorCode && Fixed the
case-sensitive semantic (#16851)
new fa96e457096 Pipe: Fix NullPointerException in concurrent event access
(#16849)
new d882a8b34ee may-c (#16859)
new 4b562e66db5 Pipe: Prevent duplicate error logging in
AsyncPipeDataTransferServiceClient (#16856)
new f116081b3ff perf: Optimize TypeManager allocation in StatementAnalyzer
(#16870)
new 6cdd5be446d Add system table named connections to resolve the idle
session can be found (#16846)
new 03cee809f16 Switch to at.yawk.lz4:lz4-java:1.10.0 (#16871)
new c646f3b636a Bump at.yawk.lz4:lz4-java from 1.10.0 to 1.10.1 (#16874)
new aff27d12221 Bump tsfile version to 2.2.0-251208-SNAPSHOT
new 5e29706c509 Fix compile error caused by `perf: Use enum types for
compression and encoding instead of strings (#640)`
new 0d64d51c818 Fix compile error
The 17 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:
LICENSE-binary | 4 +-
dependencies.json | 2 +-
.../org/apache/iotdb/db/it/auth/IoTDBAuthIT.java | 14 +
.../treemodel/auto/basic/IoTDBPipeSyntaxIT.java | 61 ++++
.../pipe/it/single/IoTDBPipePermissionIT.java | 27 +-
.../relational/it/schema/IoTDBDatabaseIT.java | 12 +-
.../iotdb/session/it/IoTDBConnectionsIT.java | 364 +++++++++++++++++++++
iotdb-client/session/pom.xml | 14 +
.../java/org/apache/iotdb/session/Session.java | 7 +-
iotdb-core/datanode/pom.xml | 2 +-
.../subtask/processor/PipeProcessorSubtask.java | 7 +
.../agent/task/subtask/sink/PipeSinkSubtask.java | 7 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 73 +++--
.../common/tsfile/PipeTsFileInsertionEvent.java | 2 +-
.../handler/PipeTransferTrackableHandler.java | 16 +-
.../async/handler/PipeTransferTsFileHandler.java | 15 +-
.../sink/util/sorter/PipeTabletEventSorter.java | 5 +
.../iotdb/db/protocol/session/IClientSession.java | 16 +
.../iotdb/db/protocol/session/SessionManager.java | 14 +
.../db/queryengine/common/ConnectionInfo.java | 64 ++++
.../InformationSchemaContentSupplierFactory.java | 47 ++-
.../iotdb/db/queryengine/plan/Coordinator.java | 17 +-
.../dualkeycache/impl/CacheEntryGroupImpl.java | 6 +
.../schema/dualkeycache/impl/DualKeyCacheImpl.java | 61 ++--
.../schema/dualkeycache/impl/ICacheEntryGroup.java | 3 +
.../execution/config/TableConfigTaskVisitor.java | 10 +-
.../config/executor/ClusterConfigTaskExecutor.java | 12 +-
.../relational/analyzer/StatementAnalyzer.java | 9 +-
.../analyzer/StatementAnalyzerFactory.java | 17 +-
.../fetcher/cache/TableDeviceCacheEntry.java | 8 +-
.../fetcher/cache/TableDeviceLastCache.java | 56 ++--
.../fetcher/cache/TableDeviceSchemaCache.java | 6 +-
.../fetcher/cache/TreeDeviceNormalSchema.java | 4 +-
.../plan/relational/planner/TableModelPlanner.java | 9 +-
.../DataNodeLocationSupplierFactory.java | 1 +
.../security/TreeAccessCheckVisitor.java | 15 +-
.../plan/statement/crud/InsertTabletStatement.java | 7 +-
.../execute/task/InnerSpaceCompactionTask.java | 3 +
.../execute/utils/MultiTsFileDeviceIterator.java | 7 +-
.../compaction/repair/RepairDataFileScanUtil.java | 2 +-
.../org/apache/iotdb/db/auth/TreeAccessTest.java | 84 +++++
.../cache/TreeDeviceSchemaCacheManagerTest.java | 14 +
.../plan/relational/analyzer/AnalyzerTest.java | 7 +-
.../plan/relational/analyzer/AuthTest.java | 10 +-
.../analyzer/RowPatternRecognitionTest.java | 4 +-
.../fetcher/cache/TableDeviceSchemaCacheTest.java | 9 +
.../plan/relational/planner/PlanTester.java | 4 +-
.../inner/InnerSpaceCompactionExceptionTest.java | 16 +
.../apache/iotdb/commons/client/ClientManager.java | 25 ++
.../async/AsyncPipeDataTransferServiceClient.java | 21 +-
.../pipe/receiver/PipeReceiverStatusHandler.java | 6 +-
.../schema/column/ColumnHeaderConstant.java | 8 +
.../commons/schema/table/InformationSchema.java | 17 +
.../apache/iotdb/commons/utils/JVMCommonUtils.java | 7 +-
pom.xml | 18 +-
55 files changed, 1092 insertions(+), 184 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBConnectionsIT.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/common/ConnectionInfo.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/auth/TreeAccessTest.java
