This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a change to branch fix-audit-logger
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 87bbb4bdf77 missing-fix
add bfa71e00e76 Active Load: Add cleanup for active load listening
directories on DataNode first startup (#16854)
add 4a481f02bf8 Remove the code check port is occupied and resolve the
problem that can't rename file successfully (#16889)
add 5d1efef31da Remove the code check port is occupied, and resolve the
problem that can't rename file successfully. (#16893)
add 94461b06509 Support system table current_queries and
queries_costs_histogram (#16890)
add c722aaf6c8d [AINode] More accurate exception for model management
(#16895)
add 9abac5c2d76 Fix the config 'query_cost_stat_window' cannot be hot
loaded #16896
add fad9bdedada Hotfix concurrent connect error (#16900)
add 7c7b2a6c091 [AINode] More strict concurrent inference IT (#16898)
add 48bd352fb00 Delete audit implementation (#16899)
add 44409934426 Avoid CN OOM by Pulling User/Roles to DN When Cache
Misses. (#16888)
add b71401a4227 fix showQueries (#16855)
add 2710cb3db65 Add state predicate push down for system table
current_queries (#16904)
add c77bb57cb2e Optimized the error message & prevented stack printing of
information_schema selection when the cluster is closing (#16905)
add 1bf79ca4713 Fix folderManager NPE issue in WALNode when starting iotdb
in a disk-full state (#16869)
add 79e10af5fd1 Fixed the warn log of internal/MQTT session's close
session method (#16909)
add c663477e82a Fix queryCostStatWindow process of current queries (#16912)
add 02e3517c536 Fix the issue of SQL conversion in export tool (#16913)
add 664f485ddf8 Add datanode_id column for queries_costs_histogram table
and add memory usage metric for Coordinator (#16918)
add 7b5e52aed4a Merge branch 'master' of https://github.com/apache/iotdb
into fix-audit-logger
No new revisions were added by this update.
Summary of changes:
.../it/env/cluster/config/MppDataNodeConfig.java | 6 +
.../it/env/remote/config/RemoteDataNodeConfig.java | 5 +
.../apache/iotdb/itbase/env/DataNodeConfig.java | 2 +
.../iotdb/ainode/it/AINodeClusterConfigIT.java | 3 -
.../ainode/it/AINodeConcurrentForecastIT.java | 2 +-
.../iotdb/ainode/it/AINodeModelManageIT.java | 4 +-
.../apache/iotdb/ainode/utils/AINodeTestUtils.java | 17 +-
.../iotdb/db/it/audit/IoTDBAuditLogBasicIT.java | 2 +
.../informationschema/IoTDBCurrentQueriesIT.java | 263 ++++++++++++++
.../relational/it/schema/IoTDBDatabaseIT.java | 6 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 6 +
.../iotdb/session/it/IoTDBConnectionsIT.java | 6 +-
.../org/apache/iotdb/tool/data/ExportData.java | 5 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 21 +-
iotdb-core/ainode/iotdb/ainode/core/config.py | 8 +-
iotdb-core/ainode/iotdb/ainode/core/constant.py | 33 +-
iotdb-core/ainode/iotdb/ainode/core/exception.py | 108 +++---
.../core/inference/dispatcher/basic_dispatcher.py | 6 +-
.../core/inference/inference_request_pool.py | 4 +-
.../iotdb/ainode/core/inference/pool_controller.py | 4 +-
.../iotdb/ainode/core/inference/pool_group.py | 6 +-
.../pool_scheduler/basic_pool_scheduler.py | 4 +-
.../iotdb/ainode/core/manager/inference_manager.py | 4 +-
.../iotdb/ainode/core/manager/model_manager.py | 43 +--
.../ainode/iotdb/ainode/core/manager/utils.py | 4 +-
.../iotdb/ainode/core/model/model_constants.py | 7 -
.../ainode/iotdb/ainode/core/model/model_loader.py | 4 +-
.../iotdb/ainode/core/model/model_storage.py | 158 +++-----
.../core/model/sktime/configuration_sktime.py | 36 +-
.../ainode/core/model/sktime/modeling_sktime.py | 12 +-
.../ainode/core/model/sundial/pipeline_sundial.py | 4 +-
.../ainode/core/model/timer_xl/pipeline_timer.py | 4 +-
iotdb-core/ainode/iotdb/ainode/core/model/utils.py | 53 ++-
iotdb-core/ainode/iotdb/ainode/core/rpc/handler.py | 48 +--
iotdb-core/ainode/iotdb/ainode/core/util/serde.py | 6 +-
.../iotdb/confignode/audit/CNAuditLogger.java | 50 +--
.../org/apache/iotdb/db/audit/DNAuditLogger.java | 398 +--------------------
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 59 ++-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 11 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 11 +
.../db/exception/ainode/GetModelInfoException.java | 2 +-
.../exception/ainode/ModelNotFoundException.java | 28 --
.../sink/protocol/writeback/WriteBackSink.java | 4 +-
.../iotdb/db/protocol/client/an/AINodeClient.java | 6 +-
.../protocol/rest/v2/impl/RestApiServiceImpl.java | 16 +-
.../iotdb/db/protocol/session/IClientSession.java | 3 +-
.../db/protocol/session/InternalClientSession.java | 4 +-
.../db/protocol/session/MqttClientSession.java | 3 +-
.../iotdb/db/protocol/session/SessionManager.java | 13 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 16 +-
.../iotdb/db/queryengine/common/QueryId.java | 7 +
.../InformationSchemaContentSupplierFactory.java | 171 ++++++++-
.../iotdb/db/queryengine/plan/Coordinator.java | 334 ++++++++++++++++-
.../plan/execution/IQueryExecution.java | 2 +
.../queryengine/plan/execution/QueryExecution.java | 5 +
.../plan/execution/config/ConfigExecution.java | 5 +
.../execution/config/TableConfigTaskVisitor.java | 4 +-
.../execution/config/TreeConfigTaskVisitor.java | 4 +-
.../config/executor/ClusterConfigTaskExecutor.java | 10 +-
.../config/executor/IConfigTaskExecutor.java | 2 +-
...eateTrainingTask.java => CreateTuningTask.java} | 8 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 22 +-
.../plan/planner/TableOperatorGenerator.java | 1 +
.../planner/distribution/ExchangeNodeAdder.java | 6 +-
.../planner/plan/node/source/ShowQueriesNode.java | 2 +-
.../distribute/TableDistributedPlanGenerator.java | 8 +-
.../DataNodeLocationSupplierFactory.java | 2 +
.../optimizations/PushPredicateIntoTableScan.java | 100 ++++++
.../plan/statement/component/OrderByComponent.java | 6 +
.../FragmentInstanceStatisticsDrawer.java | 2 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 3 +
.../metrics/memory/QueryEngineMemoryMetrics.java | 12 +-
.../allocation/AbstractNodeAllocationStrategy.java | 21 +-
.../storageengine/load/active/ActiveLoadAgent.java | 90 +++++
.../operator/MergeTreeSortOperatorTest.java | 5 +
.../plan/parser/StatementGeneratorTest.java | 33 ++
...NodeSerdeTest.java => SourceNodeSerdeTest.java} | 20 +-
.../plan/relational/planner/PlanTester.java | 2 +
.../planner/assertions/ColumnReference.java | 10 +-
.../planner/assertions/PlanMatchPattern.java | 20 +-
.../informationschema/CurrentQueriesTest.java | 184 ++++++++++
.../informationschema}/ShowQueriesTest.java | 8 +-
.../wal/allocation/FirstCreateStrategyTest.java | 81 +++++
.../conf/iotdb-system.properties.template | 6 +
.../iotdb/commons/audit/AbstractAuditLogger.java | 77 +---
.../iotdb/commons/concurrent/ThreadName.java | 1 +
.../commons/file/SystemPropertiesHandler.java | 13 +-
.../schema/column/ColumnHeaderConstant.java | 12 +-
.../commons/schema/table/InformationSchema.java | 43 ++-
.../thrift-ainode/src/main/thrift/ainode.thrift | 17 +-
scripts/sbin/windows/start-confignode.bat | 28 --
scripts/sbin/windows/start-datanode.bat | 48 ---
92 files changed, 1868 insertions(+), 1095 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/informationschema/IoTDBCurrentQueriesIT.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/ainode/ModelNotFoundException.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ai/{CreateTrainingTask.java
=> CreateTuningTask.java} (93%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/node/source/{LastQueryScanNodeSerdeTest.java
=> SourceNodeSerdeTest.java} (76%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/informationschema/CurrentQueriesTest.java
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/{analyzer
=> planner/informationschema}/ShowQueriesTest.java (94%)
