Apache IoTDB
This report summarizes scanner evidence for apache/iotdb, a Java project with 6,425 GitHub stars. SynthScan examined 2,059,980 lines of code across 9071 source files, recording 1520 pattern matches distributed across 23 syntactic categories. The legacy adjusted pattern signal is 1.9 (Low pattern signal); it is not an authorship estimate.
Use the findings to ask whether maintainers can explain intent, verify dependencies, simplify unnecessary scaffolding, and focus review effort. Risk Payload v1 adds ownership, supply-chain, over-engineering, and review-effort vectors when available. These are prompts for human verification, not probabilities, security findings, or measured maintenance costs.
Use each vector to guide manual verification of the underlying findings.
Payload schema: 1.0.0 · Engine: 2.0.0 · Scoring: heuristic-density-v1 · Scan date: 2026-10-31.
Can maintainers explain intent, assumptions, and trade-offs? 1150 finding(s).
Are imports declared and package/API names verified? 280 finding(s).
Are wrappers, guards, and repeated structures necessary? 314 finding(s).
Which changes need focused human review? 1520 finding(s).
This chart tracks the legacy adjusted pattern score across scan runs. Changes can reflect source changes, scan coverage, or detector/scoring versions; they do not measure AI adoption or prove that a team refactored code. Compare runs only when their scoring versions are compatible. The dashed line tracks the raw pattern-hit count.
Groups findings by configured severity weight. Severity is not a confidence estimate, security rating, or proof that a package is missing. Verify imports against the project's manifests and inspect each finding in its local design context.
This horizontal bar chart shows where configured pattern scores accumulate across directories. Treat the bars as locations to inspect, not as evidence of authorship or code quality. Use the file-level findings to decide whether a directory needs a focused ownership, dependency, complexity, or review check.
The scanner identified 1520 distinct pattern matches across 23 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.
Reading the findings table: The Severity column indicates the configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL | …n/java/org/apache/iotdb/tool/data/ExportDataTable.java | 527 | .tableSchema(new org.apache.tsfile.file.metadata.TableSchema(task.table(), schemas)) | CODE |
| CRITICAL | …g/apache/iotdb/jdbc/IoTDBAbstractDatabaseMetadata.java | 611 | return org.apache.iotdb.jdbc.IoTDBDriver.class.getName(); | CODE |
| CRITICAL⚡ | …/java/org/apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 395 | if (org.apache.tsfile.external.commons.lang3.StringUtils.isNotEmpty(catalog)) { | CODE |
| CRITICAL⚡ | …/java/org/apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 400 | } else if (org.apache.tsfile.external.commons.lang3.StringUtils.isNotEmpty(schemaPattern)) { | CODE |
| CRITICAL⚡ | …/java/org/apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 406 | if ((org.apache.tsfile.external.commons.lang3.StringUtils.isNotEmpty(catalog) | CODE |
| CRITICAL⚡ | …/java/org/apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 407 | || org.apache.tsfile.external.commons.lang3.StringUtils.isNotEmpty(schemaPattern)) | CODE |
| CRITICAL⚡ | …/java/org/apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 408 | && org.apache.tsfile.external.commons.lang3.StringUtils.isNotEmpty(tableNamePattern)) { | CODE |
| CRITICAL⚡ | …/java/org/apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 415 | if ((org.apache.tsfile.external.commons.lang3.StringUtils.isNotEmpty(catalog) | CODE |
| CRITICAL⚡ | …/java/org/apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 416 | || org.apache.tsfile.external.commons.lang3.StringUtils.isNotEmpty(schemaPattern)) | CODE |
| CRITICAL⚡ | …/java/org/apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 417 | && org.apache.tsfile.external.commons.lang3.StringUtils.isNotEmpty(tableNamePattern) | CODE |
| CRITICAL⚡ | …/java/org/apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 418 | && org.apache.tsfile.external.commons.lang3.StringUtils.isNotEmpty(columnNamePattern)) { | CODE |
| CRITICAL⚡ | …/java/org/apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 425 | if (org.apache.tsfile.external.commons.lang3.StringUtils.isEmpty(catalog) | CODE |
| CRITICAL⚡ | …/java/org/apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 426 | && org.apache.tsfile.external.commons.lang3.StringUtils.isEmpty(schemaPattern) | CODE |
| CRITICAL | …er/base/SubscriptionProviderConnectionTimeoutTest.java | 103 | .transportFactory(new org.apache.iotdb.rpc.TElasticFramedTransport.Factory())); | CODE |
| CRITICAL | …er/base/SubscriptionProviderConnectionTimeoutTest.java | 216 | .transportFactory(new org.apache.iotdb.rpc.TElasticFramedTransport.Factory())); | CODE |
| CRITICAL | …/apache/iotdb/rpc/subscription/config/TopicConfig.java | 394 | // org.apache.iotdb.db.pipe.agent.task.connection.PipeEventCollector.parseAndCollectEvent(org.apache.iotdb.db.pipe.e | COMMENT |
| CRITICAL | …df/src/main/java/org/apache/iotdb/udf/UDAFExample.java | 89 | org.apache.tsfile.read.common.type.Type.fromTsDataType( | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 49 | "CREATE ALIGNED TIMESERIES root.test.table1.shanghai.shanghai.huangpu.d01(s1 INT32, s2 INT64, s3 FLOAT, s4 DOUBL | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 50 | "CREATE ALIGNED TIMESERIES root.test.table1.shanghai.shanghai.huangpu.d02(s1 INT32, s2 INT64, s3 FLOAT, s4 DOUBL | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 51 | "CREATE ALIGNED TIMESERIES root.test.table1.shanghai.shanghai.huangpu.d03(s1 INT32, s2 INT64, s3 FLOAT, s4 DOUBL | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 52 | "CREATE ALIGNED TIMESERIES root.test.table1.shanghai.shanghai.huangpu.d04(s1 INT32, s2 INT64, s3 FLOAT, s4 DOUBL | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 53 | "CREATE ALIGNED TIMESERIES root.test.table1.shanghai.shanghai.pudong.d05(s1 INT32, s2 INT64, s3 FLOAT, s4 DOUBLE | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 54 | "CREATE ALIGNED TIMESERIES root.test.table1.shanghai.shanghai.pudong.d06(s1 INT32, s2 INT64, s3 FLOAT, s4 DOUBLE | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 55 | "CREATE ALIGNED TIMESERIES root.test.table1.shanghai.shanghai.pudong.d07(s1 INT32, s2 INT64, s3 FLOAT, s4 DOUBLE | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 56 | "CREATE ALIGNED TIMESERIES root.test.table1.shanghai.shanghai.pudong.d08(s1 INT32, s2 INT64, s3 FLOAT, s4 DOUBLE | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 57 | "CREATE ALIGNED TIMESERIES root.test.table1.beijing.beijing.chaoyang.d09(s1 INT32, s2 INT64, s3 FLOAT, s4 DOUBLE | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 58 | "CREATE ALIGNED TIMESERIES root.test.table1.beijing.beijing.chaoyang.d10(s1 INT32, s2 INT64, s3 FLOAT, s4 DOUBLE | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 59 | "CREATE ALIGNED TIMESERIES root.test.table1.beijing.beijing.chaoyang.d11(s1 INT32, s2 INT64, s3 FLOAT, s4 DOUBLE | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 60 | "CREATE ALIGNED TIMESERIES root.test.table1.beijing.beijing.chaoyang.d12(s1 INT32, s2 INT64, s3 FLOAT, s4 DOUBLE | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 61 | "CREATE ALIGNED TIMESERIES root.test.table1.beijing.beijing.haidian.d13(s1 INT32, s2 INT64, s3 FLOAT, s4 DOUBLE, | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 62 | "CREATE ALIGNED TIMESERIES root.test.table1.beijing.beijing.haidian.d14(s1 INT32, s2 INT64, s3 FLOAT, s4 DOUBLE, | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 63 | "CREATE ALIGNED TIMESERIES root.test.table1.beijing.beijing.haidian.d15(s1 INT32, s2 INT64, s3 FLOAT, s4 DOUBLE, | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 64 | "CREATE ALIGNED TIMESERIES root.test.table1.beijing.beijing.haidian.d16(s1 INT32, s2 INT64, s3 FLOAT, s4 DOUBLE, | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 65 | "INSERT INTO root.test.table1.shanghai.shanghai.huangpu.d01(time,s1,s3,s6,s8,s9) aligned values (2024-09-24T06:1 | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 66 | "INSERT INTO root.test.table1.shanghai.shanghai.huangpu.d01(time,s2,s3,s4,s6,s7,s9,s10) aligned values (2024-09- | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 67 | "INSERT INTO root.test.table1.shanghai.shanghai.huangpu.d01(time,s1,s3,s5,s7,s9) aligned values (2024-09-24T06:1 | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 68 | "INSERT INTO root.test.table1.shanghai.shanghai.huangpu.d01(time,s2,s5,s9,s10) aligned values (2024-09-24T06:15: | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 69 | "INSERT INTO root.test.table1.shanghai.shanghai.huangpu.d01(time,s1,s4,s8,s9) aligned values (2024-09-24T06:15:5 | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 70 | "INSERT INTO root.test.table1.shanghai.shanghai.huangpu.d02(time,s1,s5,s6,s7,s9) aligned values (2024-09-24T06:1 | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 71 | "INSERT INTO root.test.table1.shanghai.shanghai.huangpu.d02(time,s1,s4,s7,s9,s10) aligned values (2024-09-24T06: | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 72 | "INSERT INTO root.test.table1.shanghai.shanghai.huangpu.d02(time,s2,s7,s8,s9) aligned values (2024-09-24T06:15:5 | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 73 | "INSERT INTO root.test.table1.shanghai.shanghai.huangpu.d03(time,s2,s8,s9) aligned values (2024-09-24T06:15:31.0 | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 74 | "INSERT INTO root.test.table1.shanghai.shanghai.huangpu.d03(time,s1,s4,s7,s9,s10) aligned values (2024-09-24T06: | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 75 | "INSERT INTO root.test.table1.shanghai.shanghai.huangpu.d03(time,s1,s3,s5,s6,s8,s9) aligned values (2024-09-24T0 | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 76 | "INSERT INTO root.test.table1.shanghai.shanghai.huangpu.d03(time,s2,s4,s7,s9) aligned values (2024-09-24T06:15:4 | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 77 | "INSERT INTO root.test.table1.shanghai.shanghai.huangpu.d03(time,s3,s6,s9) aligned values (2024-09-24T06:15:51.0 | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 78 | "INSERT INTO root.test.table1.shanghai.shanghai.huangpu.d04(time,s3,s5,s7,s9,s10) aligned values (2024-09-24T06: | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 79 | "INSERT INTO root.test.table1.shanghai.shanghai.huangpu.d04(time,s2,s9) aligned values (2024-09-24T06:15:40.000+ | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 80 | "INSERT INTO root.test.table1.shanghai.shanghai.huangpu.d04(time,s1,s4,s6,s8,s9) aligned values (2024-09-24T06:1 | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 81 | "INSERT INTO root.test.table1.shanghai.shanghai.pudong.d05(time,s1,s3,s6,s8,s9) aligned values (2024-09-24T06:15 | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 82 | "INSERT INTO root.test.table1.shanghai.shanghai.pudong.d05(time,s2,s3,s4,s6,s7,s9,s10) aligned values (2024-09-2 | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 83 | "INSERT INTO root.test.table1.shanghai.shanghai.pudong.d05(time,s1,s3,s5,s7,s9) aligned values (2024-09-24T06:15 | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 84 | "INSERT INTO root.test.table1.shanghai.shanghai.pudong.d05(time,s2,s5,s9,s10) aligned values (2024-09-24T06:15:5 | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 85 | "INSERT INTO root.test.table1.shanghai.shanghai.pudong.d05(time,s1,s4,s8,s9) aligned values (2024-09-24T06:15:55 | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 86 | "INSERT INTO root.test.table1.shanghai.shanghai.pudong.d06(time,s1,s5,s6,s7,s9) aligned values (2024-09-24T06:15 | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 87 | "INSERT INTO root.test.table1.shanghai.shanghai.pudong.d06(time,s1,s4,s7,s9,s10) aligned values (2024-09-24T06:1 | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 88 | "INSERT INTO root.test.table1.shanghai.shanghai.pudong.d06(time,s2,s7,s8,s9) aligned values (2024-09-24T06:15:50 | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 89 | "INSERT INTO root.test.table1.shanghai.shanghai.pudong.d07(time,s2,s8,s9) aligned values (2024-09-24T06:15:31.00 | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 90 | "INSERT INTO root.test.table1.shanghai.shanghai.pudong.d07(time,s1,s4,s7,s9,s10) aligned values (2024-09-24T06:1 | CODE |
| CRITICAL⚡ | …/it/query/view/recent/IoTDBTableViewAggregationIT.java | 91 | "INSERT INTO root.test.table1.shanghai.shanghai.pudong.d07(time,s1,s3,s5,s6,s8,s9) aligned values (2024-09-24T06 | CODE |
| 173 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | .asf.yaml | 1 | # | COMMENT |
| LOW | codecov.yml | 1 | # | COMMENT |
| LOW | docker/src/main/ainode-entrypoint.sh | 1 | #!/bin/bash | COMMENT |
| LOW | docker/src/main/build-ainode.sh | 1 | #!/bin/bash | COMMENT |
| LOW | …er/src/main/DockerCompose/docker-compose-host-3c3d.yml | 1 | # | COMMENT |
| LOW | …er/src/main/DockerCompose/docker-compose-host-3c3d.yml | 61 | - /etc/hosts:/etc/hosts:ro | COMMENT |
| LOW | docker/src/main/DockerCompose/do-docker-build.sh | 1 | #!/bin/bash | COMMENT |
| LOW | docker/src/main/DockerCompose/start-1c1d.sh | 1 | #!/bin/bash | COMMENT |
| LOW | docker/src/main/DockerCompose/replace-conf-from-env.sh | 1 | #!/bin/bash | COMMENT |
| LOW | …src/main/DockerCompose/docker-compose-cluster-1c2d.yml | 1 | # | COMMENT |
| LOW | …c/main/DockerCompose/docker-compose-cluster-1c1d1a.yml | 1 | # | COMMENT |
| LOW | docker/src/main/DockerCompose/docker-compose-ainode.yml | 1 | # | COMMENT |
| LOW | docker/src/main/DockerCompose/entrypoint.sh | 1 | #!/bin/bash | COMMENT |
| LOW | …r/src/main/DockerCompose/docker-compose-standalone.yml | 1 | # | COMMENT |
| LOW | iotdb-client/client-py/session_example.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | iotdb-client/client-py/requirements.txt | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | iotdb-client/client-py/session_example_date.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | iotdb-client/client-py/table_model_session_example.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | iotdb-client/client-py/release.sh | 1 | #!/bin/bash | COMMENT |
| LOW | …b-client/client-py/table_model_session_pool_example.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | iotdb-client/client-py/session_ssl_example.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …client/client-py/session_aligned_timeseries_example.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | iotdb-client/client-py/session_pool_example.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | iotdb-client/client-py/requirements_dev.txt | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | iotdb-client/client-py/resources/pyproject.toml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | iotdb-client/client-py/tests/__init__.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | iotdb-client/client-py/tests/unit/test_session_ssl.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | iotdb-client/client-py/tests/unit/__init__.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | iotdb-client/client-py/tests/unit/test_session_utils.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …client/client-py/tests/unit/test_session_connection.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | iotdb-client/client-py/tests/unit/test_numpy_tablet.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …b-client/client-py/tests/unit/test_session_node_url.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …-client/client-py/tests/unit/test_session_query_ids.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …client/client-py/tests/integration/test_delete_data.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …client-py/tests/integration/test_relational_session.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …client-py/tests/integration/test_aligned_timeseries.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …tdb-client/client-py/tests/integration/test_session.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | iotdb-client/client-py/tests/integration/test_todf.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …t/client-py/tests/integration/test_tablemodel_query.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | iotdb-client/client-py/tests/integration/__init__.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …lient/client-py/tests/integration/test_session_pool.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …ent/client-py/tests/integration/test_new_data_types.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …-client/client-py/tests/integration/test_one_device.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …-py/tests/integration/tablet_performance_comparison.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …t/client-py/tests/integration/test_treemodel_insert.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | iotdb-client/client-py/tests/integration/test_tablet.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …-client/client-py/tests/integration/iotdb_container.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …/client-py/tests/integration/test_tablemodel_insert.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …b-client/client-py/tests/integration/test_dataframe.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …client-py/tests/integration/sqlalchemy/test_dialect.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …ent/client-py/tests/integration/sqlalchemy/__init__.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …t/client-py/tests/integration/dbapi/test_connection.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …b-client/client-py/tests/integration/dbapi/__init__.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …lient/client-py/tests/integration/dbapi/test_cursor.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | iotdb-client/client-py/iotdb/table_session_pool.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | iotdb-client/client-py/iotdb/Session.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | iotdb-client/client-py/iotdb/__init__.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | iotdb-client/client-py/iotdb/table_session.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | iotdb-client/client-py/iotdb/SessionPool.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …b-client/client-py/iotdb/template/TemplateQueryType.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| 507 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | iotdb-client/client-py/tests/unit/test_session_ssl.py | 80 | def test_session_ssl_loads_client_cert_chain(monkeypatch): | CODE |
| LOW | iotdb-client/client-py/tests/unit/test_session_ssl.py | 104 | def test_session_ssl_requires_client_cert_and_key_together(monkeypatch): | CODE |
| LOW | iotdb-client/client-py/tests/unit/test_session_ssl.py | 118 | def test_dbapi_connection_passes_ssl_options(monkeypatch): | CODE |
| LOW | iotdb-client/client-py/tests/unit/test_session_utils.py | 28 | def test_filter_null_columns_tablet(): | CODE |
| LOW | iotdb-client/client-py/tests/unit/test_session_utils.py | 68 | def test_filter_null_columns_table_model_keeps_tag(): | CODE |
| LOW | iotdb-client/client-py/tests/unit/test_session_utils.py | 84 | def test_filter_null_columns_numpy_tablet(): | CODE |
| LOW | iotdb-client/client-py/tests/unit/test_session_utils.py | 110 | def test_filter_null_columns_numpy_tablet_active_rows(): | CODE |
| LOW | iotdb-client/client-py/tests/unit/test_session_utils.py | 135 | def test_bitmap_is_range_all_marked(): | CODE |
| LOW | …client/client-py/tests/unit/test_session_connection.py | 56 | def test_session_does_not_retry_iotdb_status_error( | CODE |
| LOW | …client/client-py/tests/unit/test_session_connection.py | 90 | def test_session_retries_transport_error(monkeypatch): | CODE |
| LOW | iotdb-client/client-py/tests/unit/test_numpy_tablet.py | 27 | def test_numpy_tablet_serialization(): | CODE |
| LOW | iotdb-client/client-py/tests/unit/test_numpy_tablet.py | 64 | def test_numpy_tablet_with_none_serialization(): | CODE |
| LOW | iotdb-client/client-py/tests/unit/test_numpy_tablet.py | 156 | def test_numpy_tablet_auto_correct_datatype(): | CODE |
| LOW | …b-client/client-py/tests/unit/test_session_node_url.py | 37 | def test_init_from_node_urls_with_hostname(): | CODE |
| LOW | …b-client/client-py/tests/unit/test_session_node_url.py | 84 | def test_not_wildcard_address(host): | CODE |
| LOW | …-client/client-py/tests/unit/test_session_query_ids.py | 63 | def test_query_fetch_and_close_keep_connection_ids( | CODE |
| LOW | …lient/client-py/tests/integration/test_session_pool.py | 82 | def test_session_pool_by_node_urls(): | CODE |
| LOW | …t/client-py/tests/integration/test_treemodel_insert.py | 719 | def test_insert_aligned_tablet(): | CODE |
| LOW | …t/client-py/tests/integration/test_treemodel_insert.py | 2085 | def test_insert_aligned_tablets(): | CODE |
| LOW | …t/client-py/tests/integration/test_treemodel_insert.py | 3005 | def test_insert_aligned_record(): | CODE |
| LOW | …t/client-py/tests/integration/test_treemodel_insert.py | 3967 | def test_insert_aligned_records(): | CODE |
| LOW | …t/client-py/tests/integration/test_treemodel_insert.py | 4412 | def test_insert_records_of_one_device(): | CODE |
| LOW | …t/client-py/tests/integration/test_treemodel_insert.py | 4831 | def test_insert_aligned_records_of_one_device(): | CODE |
| LOW | iotdb-client/client-py/tests/integration/test_tablet.py | 73 | def test_nullable_tablet_insertion(): | CODE |
| LOW | …/client-py/tests/integration/test_tablemodel_insert.py | 620 | def test_insert_relational_tablet_use_numpy_tablet(): | CODE |
| LOW | …/client-py/tests/integration/test_tablemodel_insert.py | 1102 | def test_insert_relational_tablet_auto_create(): | CODE |
| LOW | …b-client/client-py/tests/integration/test_dataframe.py | 71 | def test_stream_query_with_illegal_fetch_size(): | CODE |
| LOW | iotdb-client/client-py/iotdb/Session.py | 467 | def create_aligned_time_series( | CODE |
| LOW | iotdb-client/client-py/iotdb/Session.py | 663 | def insert_aligned_str_record( | CODE |
| LOW | iotdb-client/client-py/iotdb/Session.py | 1036 | def gen_insert_str_record_req( | CODE |
| LOW | iotdb-client/client-py/iotdb/Session.py | 1326 | def insert_records_of_one_device( | CODE |
| LOW | iotdb-client/client-py/iotdb/Session.py | 1342 | def insert_records_of_one_device_sorted( | CODE |
| LOW | iotdb-client/client-py/iotdb/Session.py | 1396 | def insert_aligned_records_of_one_device( | CODE |
| LOW | iotdb-client/client-py/iotdb/Session.py | 1412 | def insert_aligned_records_of_one_device_sorted( | CODE |
| LOW | iotdb-client/client-py/iotdb/Session.py | 1468 | def gen_insert_records_of_one_device_request( | CODE |
| LOW | iotdb-client/client-py/iotdb/Session.py | 1558 | def gen_insert_relational_tablet_req(self, tablet, is_aligned=False): | CODE |
| LOW | iotdb-client/client-py/iotdb/Session.py | 1648 | def execute_non_query_statement(self, sql): | CODE |
| LOW | iotdb-client/client-py/iotdb/Session.py | 1929 | def insert_string_records_of_one_device( | CODE |
| LOW | iotdb-client/client-py/iotdb/Session.py | 1974 | def insert_aligned_string_records_of_one_device( | CODE |
| LOW | iotdb-client/client-py/iotdb/Session.py | 2092 | def gen_insert_string_records_of_one_device_request( | CODE |
| LOW | iotdb-client/client-py/iotdb/Session.py | 2216 | def add_measurements_in_template( | CODE |
| LOW | iotdb-client/client-py/iotdb/Session.py | 2344 | def count_measurements_in_template(self, template_name: str): | CODE |
| LOW | iotdb-client/client-py/iotdb/Session.py | 2374 | def is_measurement_in_template(self, template_name: str, path: str): | CODE |
| LOW | iotdb-client/client-py/iotdb/Session.py | 2407 | def is_path_exist_in_template(self, template_name: str, path: str): | CODE |
| LOW | iotdb-client/client-py/iotdb/Session.py | 2437 | def show_measurements_in_template(self, template_name: str, pattern: str = ""): | CODE |
| LOW | iotdb-client/client-py/iotdb/Session.py | 2500 | def show_paths_template_set_on(self, template_name): | CODE |
| LOW | iotdb-client/client-py/iotdb/Session.py | 2529 | def show_paths_template_using_on(self, template_name): | CODE |
| LOW | iotdb-client/client-py/iotdb/table_session.py | 120 | def execute_non_query_statement(self, sql: str): | CODE |
| LOW | iotdb-client/client-py/iotdb/utils/SessionDataSet.py | 137 | def construct_row_record_from_data_frame(self): | CODE |
| LOW | iotdb-client/client-py/iotdb/utils/iotdb_rpc_dataset.py | 515 | def find_column_name_by_index(self, column_index): | CODE |
| LOW | iotdb-client/client-py/iotdb/utils/rpc_utils.py | 63 | def verify_success_with_redirection(status: TSStatus): | CODE |
| LOW | iotdb-client/client-py/iotdb/utils/rpc_utils.py | 70 | def verify_success_with_redirection_for_multi_devices(status: TSStatus, devices: list): | CODE |
| LOW | iotdb-client/client-py/iotdb/utils/rpc_utils.py | 137 | def _isoformat_from_components(ts: pd.Timestamp, unit: str) -> str: | CODE |
| LOW | iotdb-client/client-py/iotdb/utils/SessionUtils.py | 26 | def _is_column_all_null_bitmap(bitmap: Optional[BitMap], row_number: int) -> bool: | CODE |
| LOW | iotdb-client/client-py/iotdb/utils/SessionUtils.py | 33 | def _is_tablet_column_all_null(tablet: Tablet, column_index: int) -> bool: | CODE |
| LOW | …b-client/client-py/iotdb/tsfile/utils/tsblock_serde.py | 93 | def deserialize_null_indicators(buffer, size): | CODE |
| LOW | …b-client/client-py/iotdb/tsfile/utils/tsblock_serde.py | 169 | def deserialize_from_boolean_array(buffer, size): | CODE |
| LOW | iotdb-client/client-py/iotdb/sqlalchemy/IoTDBDialect.py | 115 | def _dialect_specific_select_one(self): | CODE |
| LOW | iotdb-client/client-py/iotdb/sqlalchemy/IoTDBDialect.py | 120 | def _general_time_column_info(self): | CODE |
| LOW | …dataregion/compaction/settle/SettleRequestHandler.java | 57 | public class SettleRequestHandler { | CODE |
| 136 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 157 | // Step 1: CREATE USER | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 165 | // Step 2: ALTER USER SET PASSWORD | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 202 | // Step 4: LIST USER | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 211 | // Step 6: CREATE ROLE | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 237 | // Step 8: GRANT ROLE to user | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 245 | // Step 9: GRANT SELECT ON TABLE | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 255 | // Step 10: Verify NO INSERT permission (never granted) | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 259 | // Step 11: GRANT INSERT ON TABLE | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 268 | // Step 12: REVOKE INSERT ON TABLE | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 277 | // Step 13: REVOKE SELECT ON TABLE | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 286 | // Step 14: GRANT SYSTEM | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 294 | // Step 15: REVOKE SYSTEM | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 350 | // Step 16: Verify NO WRITE permission | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 354 | // Step 17: GRANT WRITE_DATA ON tree path | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 363 | // Step 18: REVOKE WRITE_DATA ON tree path | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 372 | // Step 19: REVOKE READ_DATA ON tree path | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 425 | // Step 21: REVOKE ROLE | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 433 | // Step 22: DROP ROLE | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 441 | // Step 23: DROP USER renamed_user | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 449 | // Step 24: DROP USER ha_user | COMMENT |
| LOW | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 182 | // Step 3: ALTER USER RENAME TO | COMMENT |
| LOW | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 222 | // Step 6: LIST ROLE OF USER renamed_user | COMMENT |
| LOW | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 339 | // Step 15: GRANT READ_DATA ON tree path | COMMENT |
| LOW⚡ | …iotconsensusv2/IoTDBIoTConsensusV23C3DBasicITBase.java | 244 | // Step 1: Insert data with 3 measurements and flush | COMMENT |
| LOW⚡ | …iotconsensusv2/IoTDBIoTConsensusV23C3DBasicITBase.java | 252 | // Step 2: Insert more data without flush (creates WAL-only entries) | COMMENT |
| LOW⚡ | …iotconsensusv2/IoTDBIoTConsensusV23C3DBasicITBase.java | 256 | // Step 3: Delete one timeseries | COMMENT |
| LOW⚡ | …iotconsensusv2/IoTDBIoTConsensusV23C3DBasicITBase.java | 260 | // Step 4: Flush again to persist the deletion | COMMENT |
| LOW⚡ | …iotconsensusv2/IoTDBIoTConsensusV23C3DBasicITBase.java | 267 | // Step 5: Wait for replication to complete on data region leaders | COMMENT |
| LOW | …iotconsensusv2/IoTDBIoTConsensusV23C3DBasicITBase.java | 283 | // Step 6: Verify schema consistency on each DataNode independently | COMMENT |
| LOW | …iotconsensusv2/IoTDBIoTConsensusV23C3DBasicITBase.java | 309 | // Step 7: Stop each DataNode one by one and verify remaining nodes still consistent | COMMENT |
| LOW⚡ | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 640 | // Step 3: t=10 triggers 9-6=3 new groups (27 replicas total), giving 12 data partitions. | COMMENT |
| LOW⚡ | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 649 | // Step 4: repeating CUSTOM and writing t=20 preserves 9 groups / 6 slots / the same owners. | COMMENT |
| LOW⚡ | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 861 | // Step 2: AUTO database, t=0/10: 6 slots, 1 schema group, 2 data groups, 12 data partitions. | COMMENT |
| LOW⚡ | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 864 | // Step 3: switch both policies, then populate the second database with the same workload. | COMMENT |
| LOW⚡ | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 873 | // Step 4: write the existing AUTO database's six devices at t=20 after the global switch. | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 133 | // Step 1: one database on 1C3D; AUTO starts with minimums of 1 schema group / 2 data groups. | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 166 | // Step 2: t=20 raises the data-partition count to 6 * 3 = 18, still only 6 series slots. | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 187 | // Step 3: hot-reload only the data policy. Schema stays AUTO; no node is restarted. | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 219 | // Step 4: verify ownership, not just the final group count. At rebalance, | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 255 | // Step 5: repeat the reload and write t=40: 6 data groups, 6 slots, 6 * 5 = 30 partitions. | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 326 | // Step 1: 1C3D / one database gives a resource cap of 6, but CUSTOM explicitly limits data to | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 360 | // Step 2: expect the data cap to refresh from 2 to 6 when leaving CUSTOM; groups remain at 2. | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 373 | // Step 3: t=10 adds six data partitions (12 total), but still only six active series slots. | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 427 | // Step 4: data-policy reload leaves schema at 1 group and preserves t=0 mappings and values. | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 450 | // Step 1: CUSTOM creates 8 data groups although six active slots only use six of them. | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 479 | // Step 2: recalculated data cap=max(minimum 2, resource quota 6, existing groups 8)=8. | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 493 | // Step 3: t=10 gives 12 data partitions; all 8 group IDs and all six slot owners stay | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 586 | // Step 1: quota 9 per node gives cap=ceil(9*3/(1*3))=9; PROACTIVE activates only 6 groups. | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 616 | // Step 2: CUSTOM inherits the saved cap of 9; changing the policy alone leaves 6 groups. | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 666 | // Step 5: explicitly raise the CUSTOM cap to 10; t=30 creates one more group (30 replicas). | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 684 | // Step 6: lowering the cap to 2 must fail; check 10 groups remain and all four times are | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 717 | // Step 1: schema CUSTOM cap=1, data AUTO cap=6; six schema slots all belong to one schema | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 756 | // Step 2: reload only the schema policy, then create a seventh device in a seventh slot. | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 775 | // Step 3: verify the original schema mappings and SQL values survive the schema-only change. | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 841 | // Step 1: create both databases before allocating any regions, ensuring the same cap for | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 892 | // Step 5: add distinct slots starting at 6 to the PROACTIVE database only. | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 921 | // Step 6: restart the ConfigNode and rebuild its in-memory allot map from persisted partitions. | COMMENT |
| LOW | …yengine/execution/exchange/SharedTsBlockQueueTest.java | 91 | // Step 1: add() goes into async path — listener is registered on manualFuture. | COMMENT |
| LOW⚡ | …yengine/execution/exchange/SharedTsBlockQueueTest.java | 103 | // Step 2: Abort the queue (simulates upstream FI state change listener calling | COMMENT |
| LOW⚡ | …yengine/execution/exchange/SharedTsBlockQueueTest.java | 110 | // Step 3: Now complete the manualFuture — this triggers the async listener. | COMMENT |
| 60 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 157 | // Step 1: CREATE USER | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 165 | // Step 2: ALTER USER SET PASSWORD | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 202 | // Step 4: LIST USER | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 211 | // Step 6: CREATE ROLE | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 237 | // Step 8: GRANT ROLE to user | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 245 | // Step 9: GRANT SELECT ON TABLE | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 255 | // Step 10: Verify NO INSERT permission (never granted) | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 259 | // Step 11: GRANT INSERT ON TABLE | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 268 | // Step 12: REVOKE INSERT ON TABLE | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 277 | // Step 13: REVOKE SELECT ON TABLE | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 286 | // Step 14: GRANT SYSTEM | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 294 | // Step 15: REVOKE SYSTEM | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 350 | // Step 16: Verify NO WRITE permission | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 354 | // Step 17: GRANT WRITE_DATA ON tree path | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 363 | // Step 18: REVOKE WRITE_DATA ON tree path | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 372 | // Step 19: REVOKE READ_DATA ON tree path | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 425 | // Step 21: REVOKE ROLE | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 433 | // Step 22: DROP ROLE | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 441 | // Step 23: DROP USER renamed_user | COMMENT |
| LOW⚡ | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 449 | // Step 24: DROP USER ha_user | COMMENT |
| LOW | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 182 | // Step 3: ALTER USER RENAME TO | COMMENT |
| LOW | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 222 | // Step 6: LIST ROLE OF USER renamed_user | COMMENT |
| LOW | …che/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java | 339 | // Step 15: GRANT READ_DATA ON tree path | COMMENT |
| LOW⚡ | …iotconsensusv2/IoTDBIoTConsensusV23C3DBasicITBase.java | 244 | // Step 1: Insert data with 3 measurements and flush | COMMENT |
| LOW⚡ | …iotconsensusv2/IoTDBIoTConsensusV23C3DBasicITBase.java | 252 | // Step 2: Insert more data without flush (creates WAL-only entries) | COMMENT |
| LOW⚡ | …iotconsensusv2/IoTDBIoTConsensusV23C3DBasicITBase.java | 256 | // Step 3: Delete one timeseries | COMMENT |
| LOW⚡ | …iotconsensusv2/IoTDBIoTConsensusV23C3DBasicITBase.java | 260 | // Step 4: Flush again to persist the deletion | COMMENT |
| LOW⚡ | …iotconsensusv2/IoTDBIoTConsensusV23C3DBasicITBase.java | 267 | // Step 5: Wait for replication to complete on data region leaders | COMMENT |
| LOW | …iotconsensusv2/IoTDBIoTConsensusV23C3DBasicITBase.java | 283 | // Step 6: Verify schema consistency on each DataNode independently | COMMENT |
| LOW | …iotconsensusv2/IoTDBIoTConsensusV23C3DBasicITBase.java | 309 | // Step 7: Stop each DataNode one by one and verify remaining nodes still consistent | COMMENT |
| LOW⚡ | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 640 | // Step 3: t=10 triggers 9-6=3 new groups (27 replicas total), giving 12 data partitions. | COMMENT |
| LOW⚡ | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 649 | // Step 4: repeating CUSTOM and writing t=20 preserves 9 groups / 6 slots / the same owners. | COMMENT |
| LOW⚡ | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 861 | // Step 2: AUTO database, t=0/10: 6 slots, 1 schema group, 2 data groups, 12 data partitions. | COMMENT |
| LOW⚡ | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 864 | // Step 3: switch both policies, then populate the second database with the same workload. | COMMENT |
| LOW⚡ | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 873 | // Step 4: write the existing AUTO database's six devices at t=20 after the global switch. | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 133 | // Step 1: one database on 1C3D; AUTO starts with minimums of 1 schema group / 2 data groups. | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 166 | // Step 2: t=20 raises the data-partition count to 6 * 3 = 18, still only 6 series slots. | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 187 | // Step 3: hot-reload only the data policy. Schema stays AUTO; no node is restarted. | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 219 | // Step 4: verify ownership, not just the final group count. At rebalance, | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 255 | // Step 5: repeat the reload and write t=40: 6 data groups, 6 slots, 6 * 5 = 30 partitions. | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 326 | // Step 1: 1C3D / one database gives a resource cap of 6, but CUSTOM explicitly limits data to | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 360 | // Step 2: expect the data cap to refresh from 2 to 6 when leaving CUSTOM; groups remain at 2. | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 373 | // Step 3: t=10 adds six data partitions (12 total), but still only six active series slots. | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 427 | // Step 4: data-policy reload leaves schema at 1 group and preserves t=0 mappings and values. | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 450 | // Step 1: CUSTOM creates 8 data groups although six active slots only use six of them. | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 479 | // Step 2: recalculated data cap=max(minimum 2, resource quota 6, existing groups 8)=8. | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 493 | // Step 3: t=10 gives 12 data partitions; all 8 group IDs and all six slot owners stay | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 586 | // Step 1: quota 9 per node gives cap=ceil(9*3/(1*3))=9; PROACTIVE activates only 6 groups. | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 616 | // Step 2: CUSTOM inherits the saved cap of 9; changing the policy alone leaves 6 groups. | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 666 | // Step 5: explicitly raise the CUSTOM cap to 10; t=30 creates one more group (30 replicas). | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 684 | // Step 6: lowering the cap to 2 must fail; check 10 groups remain and all four times are | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 717 | // Step 1: schema CUSTOM cap=1, data AUTO cap=6; six schema slots all belong to one schema | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 756 | // Step 2: reload only the schema policy, then create a seventh device in a seventh slot. | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 775 | // Step 3: verify the original schema mappings and SQL values survive the schema-only change. | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 841 | // Step 1: create both databases before allocating any regions, ensuring the same cap for | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 892 | // Step 5: add distinct slots starting at 6 to the PROACTIVE database only. | COMMENT |
| LOW | …partition/IoTDBProactiveRegionGroupDistributionIT.java | 921 | // Step 6: restart the ConfigNode and rebuild its in-memory allot map from persisted partitions. | COMMENT |
| LOW | …yengine/execution/exchange/SharedTsBlockQueueTest.java | 91 | // Step 1: add() goes into async path — listener is registered on manualFuture. | COMMENT |
| LOW⚡ | …yengine/execution/exchange/SharedTsBlockQueueTest.java | 103 | // Step 2: Abort the queue (simulates upstream FI state change listener calling | COMMENT |
| LOW⚡ | …yengine/execution/exchange/SharedTsBlockQueueTest.java | 110 | // Step 3: Now complete the manualFuture — this triggers the async listener. | COMMENT |
| 58 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | iotdb-client/client-py/iotdb/table_session.py | 136 | Execute a query SQL statement and return the result set. Parameters: sql (str): The SQL qu | STRING |
| HIGH | iotdb-core/ainode/iotdb/ainode/core/config.py | 467 | Parse TEndPoint from a given endpoint url. Args: endpoint_url: an endpoint url, format: host:port or [ipv6]: | STRING |
| HIGH | …b-core/ainode/iotdb/ainode/core/model/model_storage.py | 389 | Get specified model information. Args: model_id (str): Unique identifier for the model. | STRING |
| HIGH | …de/iotdb/ainode/core/model/sundial/pipeline_sundial.py | 34 | Preprocess the input data by converting it to a 2D tensor (Sundial only supports 2D inputs). Parameter | STRING |
| HIGH | …de/iotdb/ainode/core/model/sundial/pipeline_sundial.py | 70 | Generate forecasted outputs using the Sundial model based on the provided inputs. Parameters: | STRING |
| HIGH | …de/iotdb/ainode/core/model/sundial/pipeline_sundial.py | 96 | Postprocess the model's output by averaging across the num_samples dimension and expanding the dimensio | STRING |
| HIGH | …ode/iotdb/ainode/core/model/timer_xl/pipeline_timer.py | 34 | Preprocess the input data by converting it to a 2D tensor (Timer-XL only supports 2D inputs). Paramete | STRING |
| HIGH | …ode/iotdb/ainode/core/model/timer_xl/pipeline_timer.py | 70 | Generate forecasted outputs using the model based on the provided inputs. Parameters: inpu | STRING |
| HIGH | …ode/iotdb/ainode/core/model/timer_xl/pipeline_timer.py | 89 | Postprocess the model's output by expanding its dimensions to match the expected shape. Parameters: | STRING |
| HIGH | …node/iotdb/ainode/core/model/sktime/pipeline_sktime.py | 75 | Generate forecasts from the model for given inputs. Parameters: inputs (list[Series]): A l | STRING |
| HIGH | …node/iotdb/ainode/core/model/sktime/pipeline_sktime.py | 98 | Postprocess the model's outputs. Parameters: outputs (np.ndarray): Model output to be proc | STRING |
| HIGH | …iotdb/ainode/core/inference/pipeline/basic_pipeline.py | 69 | The common preprocess logic for all forecast pipelines, validating the shape and type of the input data | STRING |
| HIGH | …iotdb/ainode/core/inference/pipeline/basic_pipeline.py | 250 | Perform forecasting on the given inputs, which must be implemented by the subclasses. Parameters: | STRING |
| HIGH | …iotdb/ainode/core/inference/pipeline/basic_pipeline.py | 288 | The common postprocess logic for all forecast pipelines. validating the shape of the output data and en | STRING |
| HIGH | …iotdb/ainode/core/inference/pipeline/basic_pipeline.py | 327 | The common preprocess logic for all classification pipelines, validating and preprocess the inputs. | STRING |
| HIGH | …iotdb/ainode/core/inference/pipeline/basic_pipeline.py | 367 | Perform classification on the given inputs, which must be implemented by the subclasses. Parameters: | STRING |
| HIGH | …iotdb/ainode/core/inference/pipeline/basic_pipeline.py | 386 | Optional hook for subclasses to implement custom postprocessing logic. This method is called before the | STRING |
| HIGH | …iotdb/ainode/core/inference/pipeline/basic_pipeline.py | 405 | The common postprocess logic for all classification pipelines, validating the shape of the output data. | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …client-py/tests/integration/test_aligned_timeseries.py | 125 | except Exception: | CODE |
| LOW | …client-py/tests/integration/test_aligned_timeseries.py | 155 | except Exception: | CODE |
| LOW | …client-py/tests/integration/test_aligned_timeseries.py | 174 | except Exception: | CODE |
| LOW | …client-py/tests/integration/test_aligned_timeseries.py | 255 | except Exception: | CODE |
| LOW | …tdb-client/client-py/tests/integration/test_session.py | 90 | except Exception: | CODE |
| LOW | …tdb-client/client-py/tests/integration/test_session.py | 96 | except Exception: | CODE |
| LOW | …tdb-client/client-py/tests/integration/test_session.py | 192 | except Exception: | CODE |
| LOW | …tdb-client/client-py/tests/integration/test_session.py | 230 | except Exception: | CODE |
| LOW | …tdb-client/client-py/tests/integration/test_session.py | 249 | except Exception: | CODE |
| LOW | …tdb-client/client-py/tests/integration/test_session.py | 268 | except Exception: | CODE |
| LOW | …tdb-client/client-py/tests/integration/test_session.py | 287 | except Exception: | CODE |
| LOW | …tdb-client/client-py/tests/integration/test_session.py | 301 | except Exception: | CODE |
| LOW | …tdb-client/client-py/tests/integration/test_session.py | 319 | except Exception: | CODE |
| LOW | …tdb-client/client-py/tests/integration/test_session.py | 342 | except Exception: | CODE |
| LOW | …tdb-client/client-py/tests/integration/test_session.py | 359 | except Exception: | CODE |
| LOW | …tdb-client/client-py/tests/integration/test_session.py | 376 | except Exception: | CODE |
| LOW | …tdb-client/client-py/tests/integration/test_session.py | 408 | except Exception: | CODE |
| LOW | …tdb-client/client-py/tests/integration/test_session.py | 434 | except Exception: | CODE |
| LOW | …tdb-client/client-py/tests/integration/test_session.py | 443 | except Exception: | CODE |
| LOW | iotdb-client/client-py/iotdb/Session.py | 291 | except Exception: | CODE |
| LOW | iotdb-client/client-py/iotdb/Session.py | 1677 | except Exception as e: | CODE |
| LOW | iotdb-client/client-py/iotdb/Session.py | 2085 | except Exception: | CODE |
| LOW | iotdb-client/client-py/iotdb/SessionPool.py | 165 | except Exception as e: | CODE |
| LOW | iotdb-client/client-py/iotdb/dbapi/Connection.py | 64 | except Exception as e: | CODE |
| LOW | iotdb-client/client-py/iotdb/dbapi/Cursor.py | 159 | except Exception: | CODE |
| LOW | iotdb-core/ainode/build_binary.py | 179 | except Exception as e: | CODE |
| MEDIUM | iotdb-core/ainode/build_binary.py | 464 | print(f"Error: Spec file not found: {spec_file}") | CODE |
| LOW | iotdb-core/ainode/iotdb/ainode/core/config.py | 428 | except Exception as e: | CODE |
| LOW | iotdb-core/ainode/iotdb/ainode/core/ai_node.py | 117 | except Exception as e: | CODE |
| LOW | iotdb-core/ainode/iotdb/ainode/core/ai_node.py | 131 | except Exception as e: | CODE |
| LOW | iotdb-core/ainode/iotdb/ainode/core/script.py | 64 | except Exception as e: | CODE |
| LOW⚡ | …b-core/ainode/iotdb/ainode/core/util/batch_executor.py | 115 | except Exception as e: | CODE |
| LOW⚡ | …b-core/ainode/iotdb/ainode/core/util/batch_executor.py | 122 | except Exception as e: | CODE |
| LOW⚡ | …b-core/ainode/iotdb/ainode/core/util/batch_executor.py | 132 | except Exception: | CODE |
| MEDIUM | …b-core/ainode/iotdb/ainode/core/util/batch_executor.py | 129 | def _atexit_close(self) -> None: | CODE |
| LOW | iotdb-core/ainode/iotdb/ainode/core/ingress/iotdb.py | 224 | except Exception as e: | CODE |
| LOW | …core/ainode/iotdb/ainode/core/manager/model_manager.py | 64 | except Exception as e: | CODE |
| LOW | …core/ainode/iotdb/ainode/core/manager/model_manager.py | 80 | except Exception as e: | CODE |
| LOW | …/ainode/iotdb/ainode/core/manager/inference_manager.py | 171 | except Exception as e: | CODE |
| LOW | …/ainode/iotdb/ainode/core/manager/inference_manager.py | 261 | except Exception as e: | CODE |
| LOW | …b-core/ainode/iotdb/ainode/core/model/model_storage.py | 155 | except Exception as e: | CODE |
| LOW | …b-core/ainode/iotdb/ainode/core/model/model_storage.py | 167 | except Exception as e: | CODE |
| LOW | …b-core/ainode/iotdb/ainode/core/model/model_storage.py | 209 | except Exception as e: | CODE |
| LOW | …b-core/ainode/iotdb/ainode/core/model/model_storage.py | 378 | except Exception as e: | CODE |
| LOW | iotdb-core/ainode/iotdb/ainode/core/model/utils.py | 233 | except Exception as e: | CODE |
| LOW | …db-core/ainode/iotdb/ainode/core/model/model_loader.py | 108 | except Exception as e: | CODE |
| LOW | …node/iotdb/ainode/core/model/sktime/modeling_sktime.py | 68 | except Exception as e: | CODE |
| LOW | …node/iotdb/ainode/core/model/sktime/modeling_sktime.py | 84 | except Exception as e: | CODE |
| LOW | …node/iotdb/ainode/core/model/sktime/modeling_sktime.py | 157 | except Exception as e: | CODE |
| LOW | …de/iotdb/ainode/core/model/moirai2/modeling_moirai2.py | 387 | except Exception as e: | CODE |
| LOW | …/ainode/iotdb/ainode/core/inference/pool_controller.py | 198 | except Exception as e: | CODE |
| LOW | …inode/iotdb/ainode/core/device/backend/cuda_backend.py | 56 | except Exception as e: | CODE |
| LOW | iotdb-core/ainode/iotdb/ainode/core/rpc/service.py | 46 | except Exception as x: | CODE |
| LOW | iotdb-core/ainode/iotdb/ainode/core/rpc/service.py | 62 | except Exception as x: | CODE |
| LOW | iotdb-core/ainode/iotdb/ainode/core/rpc/service.py | 125 | except Exception as e: | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | iotdb-client/client-py/tests/integration/test_todf.py | 104 | CODE | |
| LOW | …t/client-py/tests/integration/test_tablemodel_query.py | 33 | CODE | |
| LOW | …-py/tests/integration/tablet_performance_comparison.py | 58 | CODE | |
| LOW | …-py/tests/integration/tablet_performance_comparison.py | 167 | CODE | |
| LOW | …-py/tests/integration/tablet_performance_comparison.py | 74 | CODE | |
| LOW | iotdb-client/client-py/iotdb/Session.py | 214 | CODE | |
| LOW | iotdb-client/client-py/iotdb/Session.py | 750 | CODE | |
| LOW | iotdb-client/client-py/iotdb/Session.py | 881 | CODE | |
| LOW | iotdb-client/client-py/iotdb/Session.py | 1121 | CODE | |
| LOW | iotdb-client/client-py/iotdb/Session.py | 1225 | CODE | |
| LOW | iotdb-client/client-py/iotdb/Session.py | 1648 | CODE | |
| LOW | iotdb-client/client-py/iotdb/Session.py | 1722 | CODE | |
| LOW | iotdb-client/client-py/iotdb/Session.py | 2009 | CODE | |
| LOW | iotdb-client/client-py/iotdb/SessionPool.py | 137 | CODE | |
| LOW | iotdb-client/client-py/iotdb/utils/Field.py | 38 | CODE | |
| LOW | iotdb-client/client-py/iotdb/utils/Field.py | 207 | CODE | |
| LOW | iotdb-client/client-py/iotdb/utils/Tablet.py | 134 | CODE | |
| LOW | iotdb-client/client-py/iotdb/utils/iotdb_rpc_dataset.py | 222 | CODE | |
| LOW | iotdb-client/client-py/iotdb/utils/iotdb_rpc_dataset.py | 370 | CODE | |
| LOW | iotdb-client/client-py/iotdb/utils/iotdb_rpc_dataset.py | 469 | CODE | |
| LOW | iotdb-client/client-py/iotdb/utils/NumpyTablet.py | 130 | CODE | |
| LOW | …nt/client-py/iotdb/tsfile/utils/read_write_io_utils.py | 36 | CODE | |
| LOW | iotdb-client/client-py/iotdb/dbapi/Cursor.py | 96 | CODE | |
| LOW | …db-client/client-cpp/test/scripts/run_cpp_it_phases.py | 59 | CODE | |
| LOW | iotdb-core/ainode/iotdb/ainode/core/config.py | 296 | CODE | |
| LOW | iotdb-core/ainode/iotdb/ainode/core/ai_node.py | 92 | CODE | |
| LOW | iotdb-core/ainode/iotdb/ainode/core/util/serde.py | 125 | CODE | |
| LOW | iotdb-core/ainode/iotdb/ainode/core/util/serde.py | 136 | CODE | |
| LOW | iotdb-core/ainode/iotdb/ainode/core/util/serde.py | 158 | CODE | |
| LOW | iotdb-core/ainode/iotdb/ainode/core/util/cache.py | 25 | CODE | |
| LOW | iotdb-core/ainode/iotdb/ainode/core/ingress/iotdb.py | 35 | CODE | |
| LOW | iotdb-core/ainode/iotdb/ainode/core/ingress/iotdb.py | 109 | CODE | |
| LOW | iotdb-core/ainode/iotdb/ainode/core/ingress/iotdb.py | 287 | CODE | |
| LOW | …/ainode/iotdb/ainode/core/manager/inference_manager.py | 178 | CODE | |
| LOW | …b-core/ainode/iotdb/ainode/core/model/model_storage.py | 98 | CODE | |
| LOW | …b-core/ainode/iotdb/ainode/core/model/model_storage.py | 179 | CODE | |
| LOW | …b-core/ainode/iotdb/ainode/core/model/model_storage.py | 386 | CODE | |
| LOW | iotdb-core/ainode/iotdb/ainode/core/model/utils.py | 144 | CODE | |
| LOW | …de/iotdb/ainode/core/model/sundial/modeling_sundial.py | 477 | CODE | |
| LOW | …iotdb/ainode/core/model/sundial/ts_generation_mixin.py | 86 | CODE | |
| LOW | …ode/iotdb/ainode/core/model/timer_xl/modeling_timer.py | 472 | CODE | |
| LOW | …otdb/ainode/core/model/timer_xl/ts_generation_mixin.py | 81 | CODE | |
| LOW | …iotdb/ainode/core/model/sktime/configuration_sktime.py | 46 | CODE | |
| LOW | …iotdb/ainode/core/model/sktime/configuration_sktime.py | 91 | CODE | |
| LOW | …ainode/iotdb/ainode/core/model/toto/model/attention.py | 105 | CODE | |
| LOW | …ainode/iotdb/ainode/core/model/toto/model/attention.py | 151 | CODE | |
| LOW | …ainode/iotdb/ainode/core/model/toto/model/attention.py | 177 | CODE | |
| LOW | …re/ainode/iotdb/ainode/core/model/toto/model/scaler.py | 100 | CODE | |
| LOW | …-core/ainode/iotdb/ainode/core/model/chronos2/model.py | 315 | CODE | |
| LOW | …ore/ainode/iotdb/ainode/core/model/chronos2/dataset.py | 60 | CODE | |
| LOW | …ore/ainode/iotdb/ainode/core/model/chronos2/dataset.py | 497 | CODE | |
| LOW | …de/iotdb/ainode/core/model/moirai2/modeling_moirai2.py | 749 | CODE | |
| LOW | …de/iotdb/ainode/core/model/moirai2/pipeline_moirai2.py | 72 | CODE | |
| LOW | …/iotdb/ainode/core/inference/inference_request_pool.py | 113 | CODE | |
| LOW | …iotdb/ainode/core/inference/pipeline/basic_pipeline.py | 64 | CODE | |
| LOW | .github/scripts/check-it-selection.py | 77 | CODE | |
| LOW | .github/scripts/check-it-selection.py | 170 | CODE | |
| LOW | .github/scripts/check-it-selection.py | 221 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | iotdb-client/client-py/session_example_date.py | 23 | CODE | |
| LOW | …db-client/client-cpp/test/scripts/run_cpp_it_phases.py | 21 | CODE | |
| LOW | …ient/client-cpp/test/scripts/configure_iotdb_ssl_it.py | 21 | CODE | |
| LOW | …ore/ainode/iotdb/ainode/core/util/huggingface_cache.py | 22 | CODE | |
| LOW | …ore/ainode/iotdb/ainode/core/util/huggingface_cache.py | 26 | CODE | |
| LOW | iotdb-core/ainode/iotdb/ainode/core/util/activation.py | 22 | CODE | |
| LOW | iotdb-core/ainode/iotdb/ainode/core/manager/utils.py | 19 | CODE | |
| LOW | iotdb-core/ainode/iotdb/ainode/core/manager/utils.py | 28 | CODE | |
| LOW | …ainode/iotdb/ainode/core/model/toto/model/attention.py | 29 | CODE | |
| LOW | …ainode/iotdb/ainode/core/model/toto/model/attention.py | 34 | CODE | |
| LOW | …ainode/iotdb/ainode/core/model/toto/model/embedding.py | 22 | CODE | |
| LOW | …core/ainode/iotdb/ainode/core/model/toto/model/util.py | 33 | CODE | |
| LOW | …/ainode/iotdb/ainode/core/model/toto/model/backbone.py | 23 | CODE | |
| LOW | …/ainode/iotdb/ainode/core/model/toto/model/backbone.py | 27 | CODE | |
| LOW | …/ainode/iotdb/ainode/core/model/toto/model/backbone.py | 29 | CODE | |
| LOW | …re/ainode/iotdb/ainode/core/model/toto/model/scaler.py | 26 | CODE | |
| LOW | …node/iotdb/ainode/core/model/toto/model/transformer.py | 23 | CODE | |
| LOW | …node/iotdb/ainode/core/model/toto/model/transformer.py | 28 | CODE | |
| LOW | …core/ainode/iotdb/ainode/core/model/toto/model/toto.py | 25 | CODE | |
| LOW | …core/ainode/iotdb/ainode/core/model/toto/model/toto.py | 26 | CODE | |
| LOW | …core/ainode/iotdb/ainode/core/model/toto/model/toto.py | 26 | CODE | |
| LOW | …core/ainode/iotdb/ainode/core/model/toto/model/toto.py | 26 | CODE | |
| LOW | …b-core/ainode/iotdb/ainode/core/model/chronos2/base.py | 30 | CODE | |
| LOW | …de/iotdb/ainode/core/model/moirai2/modeling_moirai2.py | 311 | CODE | |
| LOW | …tdb/ainode/core/model/moirai2/configuration_moirai2.py | 19 | CODE | |
| LOW | …/ainode/core/model/moirai2/module/position/__init__.py | 24 | CODE | |
| LOW | …/ainode/core/model/moirai2/module/position/__init__.py | 24 | CODE | |
| LOW | …/ainode/core/model/moirai2/module/position/__init__.py | 25 | CODE | |
| LOW | …/ainode/core/model/moirai2/module/position/__init__.py | 25 | CODE | |
| LOW | …/ainode/core/model/moirai2/module/position/__init__.py | 25 | CODE | |
| LOW | …/ainode/core/model/moirai2/module/position/__init__.py | 25 | CODE | |
| LOW | …/ainode/core/model/moirai2/module/position/__init__.py | 31 | CODE | |
| LOW | …/ainode/core/model/moirai2/module/position/__init__.py | 31 | CODE | |
| LOW | …/ainode/core/model/moirai2/module/position/__init__.py | 31 | CODE | |
| LOW | …/ainode/core/model/moirai2/module/position/__init__.py | 31 | CODE | |
| LOW | …/ainode/core/model/moirai2/module/position/__init__.py | 31 | CODE | |
| LOW | …/ainode/iotdb/ainode/core/inference/pool_controller.py | 39 | CODE | |
| LOW | …b-core/ainode/iotdb/ainode/core/device/backend/base.py | 20 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …t/client-py/tests/integration/test_treemodel_insert.py | 343 | # 2、Inserting Numpy Tablet data (No null) | COMMENT |
| HIGH | …t/client-py/tests/integration/test_treemodel_insert.py | 521 | # 3、Inserting Numpy Tablet data (Contains null) | COMMENT |
| HIGH | …t/client-py/tests/integration/test_treemodel_insert.py | 1050 | # 2、Inserting Numpy Tablet data (No null) | COMMENT |
| HIGH | …t/client-py/tests/integration/test_treemodel_insert.py | 1228 | # 3、Inserting Numpy Tablet data (Contains null) | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | iotdb-client/client-cpp/CMakeLists.txt | 18 | # ============================================================================= | COMMENT |
| MEDIUM | iotdb-client/client-cpp/CMakeLists.txt | 20 | # ============================================================================= | COMMENT |
| MEDIUM | iotdb-client/client-cpp/test/CMakeLists.txt | 18 | # ============================================================================= | COMMENT |
| MEDIUM | iotdb-client/client-cpp/test/CMakeLists.txt | 23 | # ============================================================================= | COMMENT |
| MEDIUM | …apache/iotdb/relational/it/db/it/udf/IoTDBLocalIT.java | 109 | // ── compatibility: legacy UDF without IoTDBLocal parameter ───────────────── | COMMENT |
| MEDIUM | …apache/iotdb/relational/it/db/it/udf/IoTDBLocalIT.java | 172 | // ── IoTDBLocal embedded query ─────────────────────────────────────────────── | COMMENT |
| MEDIUM | …apache/iotdb/relational/it/db/it/udf/IoTDBLocalIT.java | 392 | // ── permission inheritance ────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …e/ainode/iotdb/ainode/core/model/toto/modeling_toto.py | 113 | # ── Load config ────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …e/ainode/iotdb/ainode/core/model/toto/modeling_toto.py | 128 | # ── Instantiate model ───────────────────────────────────────────────── | COMMENT |
| MEDIUM | …e/ainode/iotdb/ainode/core/model/toto/modeling_toto.py | 131 | # ── Load safetensors weights ────────────────────────────────────────── | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | docker/src/main/ainode-entrypoint.sh | 92 | # Check if already running | COMMENT |
| LOW | docker/src/main/build-ainode.sh | 116 | # Check if distribution package exists (relative to project root) | COMMENT |
| LOW | docker/src/main/build-ainode.sh | 124 | # Check if data directory exists | COMMENT |
| LOW | docker/src/main/build-ainode.sh | 189 | # Check if .dockerignore exists and might exclude our directory | COMMENT |
| LOW | iotdb-client/client-py/iotdb/utils/SessionDataSet.py | 148 | # Check if buffer has data or if there are more results to fetch | COMMENT |
| LOW | …b-core/ainode/iotdb/ainode/core/model/model_storage.py | 128 | # Check if model already exists and is in a valid state | COMMENT |
| LOW | …/iotdb/ainode/core/model/chronos2/pipeline_chronos2.py | 467 | # Check if 0.5 quantile is available | COMMENT |
| LOW | …de/iotdb/ainode/core/model/moirai2/pipeline_moirai2.py | 159 | # Check if 0.5 quantile is available | COMMENT |
| LOW | …iotdb/ainode/core/inference/pipeline/basic_pipeline.py | 99 | # Check if the dictionary contains the expected keys | COMMENT |
| LOW | …/core/inference/pool_scheduler/basic_pool_scheduler.py | 56 | # Check if the model supports concurrent forecasting | COMMENT |
| LOW | scripts/tools/ops/health_check.sh | 120 | #Check if the port of the remote server is reachable... | COMMENT |
| LOW | scripts/tools/ops/health_check.sh | 190 | #Check if the local port is available.... | COMMENT |
| LOW | scripts/tools/ops/health_check.sh | 209 | # Check if lsof command is available | COMMENT |
| LOW | scripts/tools/ops/health_check.sh | 274 | # Check if the directories exist and are writable or readable | COMMENT |
| LOW | scripts/tools/ops/health_check.sh | 370 | #Check if Swap is enabled | COMMENT |
| LOW | scripts/tools/ops/backup.sh | 93 | # Check if lsof command is available | COMMENT |
| LOW | scripts/conf/datanode-env.sh | 38 | # Set somaxconn to a better value to avoid meaningless connection reset issues when the system is under high load. | COMMENT |
| LOW | scripts/conf/confignode-env.sh | 37 | # Set somaxconn to a better value to avoid meaningless connection reset issues when the system is under high load. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | iotdb-client/client-py/iotdb/table_session_pool.py | 24 | CODE | |
| LOW | iotdb-client/client-py/iotdb/Session.py | 123 | CODE | |
| LOW | iotdb-client/client-py/iotdb/Session.py | 173 | CODE | |
| LOW | iotdb-client/client-py/iotdb/table_session.py | 28 | CODE | |
| LOW | iotdb-client/client-py/iotdb/SessionPool.py | 37 | CODE | |
| LOW | iotdb-client/client-py/iotdb/dbapi/Connection.py | 30 | CODE | |
| LOW | iotdb-core/ainode/iotdb/ainode/core/config.py | 446 | CODE | |
| LOW | …de/iotdb/ainode/core/model/sundial/modeling_sundial.py | 81 | CODE | |
| LOW | …de/iotdb/ainode/core/model/sundial/modeling_sundial.py | 304 | CODE | |
| LOW | …de/iotdb/ainode/core/model/sundial/modeling_sundial.py | 477 | CODE | |
| LOW | …iotdb/ainode/core/model/sundial/ts_generation_mixin.py | 37 | CODE | |
| LOW | …iotdb/ainode/core/model/sundial/ts_generation_mixin.py | 86 | CODE | |
| LOW | …tdb/ainode/core/model/sundial/configuration_sundial.py | 28 | CODE | |
| LOW | …ode/iotdb/ainode/core/model/timer_xl/modeling_timer.py | 298 | CODE | |
| LOW | …ode/iotdb/ainode/core/model/timer_xl/modeling_timer.py | 472 | CODE | |
| LOW | …otdb/ainode/core/model/timer_xl/ts_generation_mixin.py | 38 | CODE | |
| LOW | …otdb/ainode/core/model/timer_xl/ts_generation_mixin.py | 81 | CODE | |
| LOW | …otdb/ainode/core/model/timer_xl/configuration_timer.py | 28 | CODE | |
| LOW | …iotdb/ainode/core/model/moment/configuration_moment.py | 44 | CODE | |
| LOW | …ode/iotdb/ainode/core/model/toto/configuration_toto.py | 38 | CODE | |
| LOW | …core/ainode/iotdb/ainode/core/model/chronos2/config.py | 70 | CODE | |
| LOW | …-core/ainode/iotdb/ainode/core/model/chronos2/model.py | 684 | CODE | |
| LOW | …-core/ainode/iotdb/ainode/core/model/chronos2/model.py | 765 | CODE | |
| LOW | …tdb/ainode/core/model/moirai2/configuration_moirai2.py | 27 | CODE | |
| LOW | …de/iotdb/ainode/core/model/moirai2/module/attention.py | 67 | CODE | |
| LOW | …de/iotdb/ainode/core/model/moirai2/module/attention.py | 317 | CODE | |
| LOW | …de/iotdb/ainode/core/model/moirai2/module/attention.py | 346 | CODE | |
| LOW | …/iotdb/ainode/core/model/moirai2/module/transformer.py | 107 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …b/pipe/consensus/deletion/DeletionResourceManager.java | 244 | // Definitely match. Because upper caller has filtered fileNames. | COMMENT |
| MEDIUM | …b/pipe/consensus/deletion/DeletionResourceManager.java | 269 | // Definitely match. Because upper caller has filtered fileNames. | COMMENT |
| MEDIUM | …tree/impl/pbtree/schemafile/pagemgr/PageIOChannel.java | 56 | // without RATIS, utilize physical logging for integrity | COMMENT |
| MEDIUM | …e/iotdb/db/subscription/broker/SubscriptionBroker.java | 603 | // TODO: consider more robust metadata semantics | COMMENT |
| MEDIUM | …eryengine/plan/relational/planner/SubqueryPlanner.java | 144 | // try to execute un-correlated scalar subqueries in the predicate in advance to utilize | COMMENT |
| MEDIUM | …/db/queryengine/plan/relational/analyzer/Analysis.java | 265 | // independently to utilize predicate pushdown optimization. | COMMENT |
| MEDIUM | …otdb/db/queryengine/plan/execution/QueryExecution.java | 650 | // That we put retry() here is aimed to leverage the ClientRPC thread rather than | COMMENT |
| MEDIUM | …nary/scalar/factory/NumericCodecStrategiesFactory.java | 80 | // for Big Endian writes, leverage ByteBuffer's default order for maximum performance | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | iotdb-client/client-py/iotdb/dbapi/__init__.py | 22 | __all__ = [connect, Error] | CODE |
| LOW⚡ | iotdb-core/ainode/iotdb/ainode/core/config.py | 112 | def set_cluster_name(self, cluster_name: str) -> None: | CODE |
| LOW⚡ | iotdb-core/ainode/iotdb/ainode/core/config.py | 121 | def set_ainode_id(self, ainode_id: int) -> None: | CODE |
| LOW⚡ | iotdb-core/ainode/iotdb/ainode/core/config.py | 127 | def set_build_info(self, build_info: str) -> None: | CODE |
| LOW⚡ | iotdb-core/ainode/iotdb/ainode/core/config.py | 133 | def set_ain_data_cache_size(self, ain_data_cache_size: int) -> None: | CODE |
| LOW⚡ | iotdb-core/ainode/iotdb/ainode/core/config.py | 136 | def set_version_info(self, version_info: str) -> None: | CODE |
| LOW⚡ | iotdb-core/ainode/iotdb/ainode/core/config.py | 142 | def set_ain_rpc_address(self, ain_rpc_address: str) -> None: | CODE |
| LOW⚡ | iotdb-core/ainode/iotdb/ainode/core/config.py | 148 | def set_ain_rpc_port(self, ain_rpc_port: int) -> None: | CODE |
| LOW⚡ | iotdb-core/ainode/iotdb/ainode/core/config.py | 194 | def set_ain_logs_dir(self, ain_logs_dir: str) -> None: | CODE |
| LOW⚡ | iotdb-core/ainode/iotdb/ainode/core/config.py | 200 | def set_ain_models_dir(self, ain_models_dir: str) -> None: | CODE |
| LOW⚡ | iotdb-core/ainode/iotdb/ainode/core/config.py | 206 | def set_ain_models_builtin_dir(self, ain_models_builtin_dir: str) -> None: | CODE |
| LOW⚡ | iotdb-core/ainode/iotdb/ainode/core/config.py | 212 | def set_ain_system_dir(self, ain_system_dir: str) -> None: | CODE |
| LOW⚡ | iotdb-core/ainode/iotdb/ainode/core/config.py | 234 | def set_ain_internal_ssl_enabled(self, ain_internal_ssl_enabled: int) -> None: | CODE |
| LOW⚡ | iotdb-core/ainode/iotdb/ainode/core/config.py | 240 | def set_ain_thrift_ssl_cert_file(self, ain_thrift_ssl_cert_file: str) -> None: | CODE |
| LOW⚡ | iotdb-core/ainode/iotdb/ainode/core/config.py | 246 | def set_ain_thrift_ssl_key_file(self, ain_thrift_ssl_key_file: str) -> None: | CODE |
| LOW⚡ | iotdb-core/ainode/iotdb/ainode/core/config.py | 255 | def set_ain_target_config_node_list(self, ain_target_config_node_list: str) -> None: | CODE |
| LOW⚡ | iotdb-core/ainode/iotdb/ainode/core/config.py | 263 | def set_ain_cluster_ingress_address(self, ain_cluster_ingress_address: str) -> None: | CODE |
| LOW⚡ | iotdb-core/ainode/iotdb/ainode/core/config.py | 269 | def set_ain_cluster_ingress_port(self, ain_cluster_ingress_port: int) -> None: | CODE |
| LOW | …/ainode/core/model/moirai2/module/position/__init__.py | 39 | __all__ = [ | CODE |
| LOW | …inode/iotdb/ainode/core/device/backend/cuda_backend.py | 42 | def set_device(self, index: int) -> None: | CODE |
| LOW | …ainode/iotdb/ainode/core/device/backend/cpu_backend.py | 36 | def set_device(self, index: int) -> None: | CODE |
| LOW | …b-core/ainode/iotdb/ainode/core/device/backend/base.py | 42 | def set_device(self, index: int) -> None: ... | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …b-client/client-py/table_model_session_pool_example.py | 126 | # Create a session pool | COMMENT |
| MEDIUM | iotdb-client/client-py/session_pool_example.py | 129 | # Create a session pool | COMMENT |
| MEDIUM | …node/iotdb/ainode/core/model/moment/modeling_moment.py | 19 | # This file contains code adapted from the MOMENT project | COMMENT |
| MEDIUM | …iotdb/ainode/core/model/moment/configuration_moment.py | 19 | # This file contains code adapted from the MOMENT project | COMMENT |
| MEDIUM | …node/iotdb/ainode/core/model/moment/pipeline_moment.py | 19 | # This file contains code adapted from the MOMENT project | COMMENT |
| MEDIUM | …ore/ainode/iotdb/ainode/core/model/moirai2/__init__.py | 18 | # This file is part of the Apache IoTDB project. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | iotdb-client/client-py/iotdb/dbapi/Cursor.py | 220 | except StopIteration: | CODE |
| HIGH | iotdb-core/ainode/build_binary.py | 303 | except FileNotFoundError: | CODE |
| HIGH | …b-core/ainode/iotdb/ainode/core/util/batch_executor.py | 132 | except Exception: | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …/iotdb/db/it/query/IoTDBAggregationFirstInGroupIT.java | 58 | // Physical 'time' column is kept distinct and out-of-order as requested. | COMMENT |
| HIGH | …confignode/manager/load/cache/node/NodeStatistics.java | 79 | // if the transition output is not the same as requested, it could be Stopped or Removing status | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | scripts/sbin/start-standalone.sh | 42 | # if you have turned on "-XX:+SafepointTimeout" and "-XX:SafepointTimeoutDelay=1000", you can use commands below instead | COMMENT |
| MEDIUM | scripts/conf/datanode-env.sh | 258 | # when the GC time is too long, if there are remaining CPU resources, you can try to turn on and increase options below. | COMMENT |
| MEDIUM | scripts/conf/datanode-env.sh | 273 | # if you want to dump the heap memory while OOM happening, you can use the following command, remember to replace ${heap | COMMENT |
| MEDIUM | scripts/conf/confignode-env.sh | 232 | # if you want to dump the heap memory while OOM happening, you can use the following command, remember to replace ${heap | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …geengine/dataregion/read/control/QueryFileManager.java | 125 | // Although there are no concurrency issues here at the moment, I've implemented thread-safe | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …egion/mtree/impl/pbtree/schemafile/AliasIndexPage.java | 303 | // TODO: implement bulk split further | COMMENT |
| LOW | …egion/mtree/impl/pbtree/schemafile/WrappedSegment.java | 388 | // TODO: implement bulk split further | COMMENT |
| LOW | …redicate/schema/ExtractPredicateColumnNameVisitor.java | 44 | // TODO: implement schema function filter and parse some function call and arithmetic filters | COMMENT |
| LOW | …/ainode/iotdb/ainode/core/inference/pool_controller.py | 100 | # # TODO: implement scale down logic | COMMENT |
| LOW | …/ainode/iotdb/ainode/core/inference/pool_controller.py | 372 | ) # TODO: implement better selection strategy | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …engine/plan/planner/node/PlanGraphJsonPrinterTest.java | 87 | LimitNode placeholder = new LimitNode(new PlanNodeId("placeholder"), null, 0, Optional.empty()); | CODE |
| LOW | …engine/plan/planner/node/PlanGraphJsonPrinterTest.java | 129 | new LimitNode(new PlanNodeId("placeholder"), null, 0, Optional.empty()), | CODE |
| LOW | …engine/plan/planner/node/PlanGraphJsonPrinterTest.java | 146 | new LimitNode(new PlanNodeId("placeholder"), null, 0, Optional.empty()), | CODE |
| LOW | …otdb/rest/protocol/v2/handler/FastLastHandlerTest.java | 80 | newResultMap("s1", "placeholder", "nullValue", "s4"); | CODE |
| LOW | …otdb/rest/protocol/v2/handler/FastLastHandlerTest.java | 109 | if ("placeholder".equals(name)) { | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …node/iotdb/ainode/core/model/moment/pipeline_moment.py | 159 | # Slide context window: append forecast, drop oldest | COMMENT |