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 ef5cef5c9d5 Two Implementation of Object File Path (#16858)
new 8f1235835ae Throw exception while readObject column is not OBJECT type
new bc9418a8af3 [AINode] More accurate exception for model management
(#16895)
new 2d3c19a5656 Fix the config 'query_cost_stat_window' cannot be hot
loaded #16896
new 75e8579e600 Hotfix concurrent connect error (#16900)
new 191edf13094 [AINode] More strict concurrent inference IT (#16898)
new a5c3b4387bb Delete audit implementation (#16899)
new 900ff029b1f Avoid CN OOM by Pulling User/Roles to DN When Cache
Misses. (#16888)
new 36cb21f4fd6 fix showQueries (#16855)
new bd677fb9954 Add state predicate push down for system table
current_queries (#16904)
new 3bc6101a93d Optimized the error message & prevented stack printing of
information_schema selection when the cluster is closing (#16905)
The 10 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:
.../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 | 11 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 6 +
.../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 ++-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 6 +
.../db/exception/ainode/GetModelInfoException.java | 2 +-
.../exception/ainode/ModelNotFoundException.java | 28 --
.../iotdb/db/protocol/client/an/AINodeClient.java | 6 +-
.../iotdb/db/protocol/session/IClientSession.java | 3 +-
.../iotdb/db/protocol/session/SessionManager.java | 4 +-
.../operator/process/function/partition/Slice.java | 3 +
.../InformationSchemaContentSupplierFactory.java | 30 +-
.../relational/aggregation/RecordIterator.java | 3 +
.../iotdb/db/queryengine/plan/Coordinator.java | 33 ++
.../plan/execution/config/ConfigExecution.java | 1 +
.../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 +-
.../optimizations/PushPredicateIntoTableScan.java | 100 ++++++
.../plan/statement/component/OrderByComponent.java | 6 +
.../FragmentInstanceStatisticsDrawer.java | 2 +-
.../plan/parser/StatementGeneratorTest.java | 33 ++
...NodeSerdeTest.java => SourceNodeSerdeTest.java} | 20 +-
.../planner/assertions/ColumnReference.java | 10 +-
.../planner/assertions/PlanMatchPattern.java | 20 +-
.../informationschema/CurrentQueriesTest.java | 77 ++++
.../iotdb/commons/audit/AbstractAuditLogger.java | 77 +---
.../thrift-ainode/src/main/thrift/ainode.thrift | 17 +-
63 files changed, 708 insertions(+), 969 deletions(-)
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%)
