OceanBase is the unified distributed database for the AI era — open-source, multi-model, one engine for your most demanding workloads.
This report summarizes scanner evidence for oceanbase/oceanbase, a C++ project with 10,360 GitHub stars. SynthScan examined 6,582,509 lines of code across 14623 source files, recording 6739 pattern matches distributed across 17 syntactic categories. The legacy adjusted pattern signal is 1.5 (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? 6048 finding(s).
Are imports declared and package/API names verified? 287 finding(s).
Are wrappers, guards, and repeated structures necessary? 609 finding(s).
Which changes need focused human review? 6739 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 6739 distinct pattern matches across 17 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 |
|---|---|---|---|---|
| LOW | unittest/pl/test_dbms_xmldom.cpp | 21 | #ifdef OB_BUILD_ORACLE_PL | COMMENT |
| LOW | unittest/pl/test_pl_utils.h | 1 | /** | COMMENT |
| LOW | unittest/archive/test_archive_overwrite.cpp | 1 | /** | COMMENT |
| LOW | unittest/logminer/ob_log_miner_test_utils.h | 61 | #endif | COMMENT |
| LOW | unittest/rootserver/test_ls_balance_helper.cpp | 1 | /** | COMMENT |
| LOW | unittest/rootserver/test_ls_balance_helper.cpp | 561 | } | COMMENT |
| LOW | unittest/rootserver/test_freeze_info_manager.cpp | 1 | /** | COMMENT |
| LOW | unittest/rootserver/test_server_manager.cpp | 1 | /** | COMMENT |
| LOW | unittest/rootserver/test_server_manager.cpp | 601 | // lq.zone_ = "2"; | COMMENT |
| LOW | unittest/rootserver/test_server_manager.cpp | 621 | // ASSERT_EQ(OB_SERVER_ZONE_NOT_MATCH, server_manager_.start_server(lq.server_, "5")); | COMMENT |
| LOW | unittest/rootserver/test_server_manager.cpp | 641 | // | COMMENT |
| LOW | unittest/rootserver/test_server_manager.cpp | 661 | // ASSERT_EQ(OB_SERVER_ZONE_NOT_MATCH, server_manager_.delete_server(to_array(lq.server_), not_match_zone)); | COMMENT |
| LOW | unittest/rootserver/test_server_manager.cpp | 681 | // ASSERT_EQ(OB_SERVER_ZONE_NOT_MATCH, server_manager_.delete_server(to_array(lq.server_), not_exist_zone)); | COMMENT |
| LOW | unittest/rootserver/test_ddl_operator.cpp | 1 | /** | COMMENT |
| LOW | unittest/rootserver/test_ddl_operator.cpp | 401 | ASSERT_EQ(OB_SUCCESS, schema_guard2.get_table_id(pre_tenant_id_, | COMMENT |
| LOW | unittest/rootserver/test_ddl_operator.cpp | 441 | //ASSERT_EQ(OB_SUCCESS, schema_manager->check_database_exist( | COMMENT |
| LOW | unittest/rootserver/test_ddl_operator.cpp | 461 | //ObSchemaGetterGuard schema_guard; | COMMENT |
| LOW | unittest/rootserver/test_ddl_operator.cpp | 481 | ////schema_manager = multi_schema_service_.get_schema_manager_by_version(); | COMMENT |
| LOW | unittest/rootserver/test_major_freeze_launcher.cpp | 1 | /** | COMMENT |
| LOW | unittest/rootserver/test_dump_inner_table_schema.cpp | 1 | /** | COMMENT |
| LOW | unittest/rootserver/test_zone_manager.cpp | 1 | /** | COMMENT |
| LOW | unittest/rootserver/test_zone_manager.cpp | 201 | COMMENT | |
| LOW | …st/rootserver/test_rs_event_history_table_operator.cpp | 1 | /** | COMMENT |
| LOW | unittest/rootserver/test_alter_table_helper.cpp | 181 | // Even with valid column ops, partition check should make it false | COMMENT |
| LOW | unittest/rootserver/test_alter_table_helper.cpp | 741 | // Fix #5: foreign_key_checks = false (explicit SET foreign_key_checks=0) | COMMENT |
| LOW | unittest/rootserver/test_zone_merge_manager.cpp | 1 | /** | COMMENT |
| LOW | unittest/rootserver/test_zone_merge_manager.cpp | 101 | // ASSERT_EQ(OB_SUCCESS, zone_merge_mgr_.reload()); | COMMENT |
| LOW | unittest/rootserver/test_ob_backup_task_scheduler.cpp | 1 | /** | COMMENT |
| LOW | unittest/observer/test_inner_sql_result.cpp | 1 | /** | COMMENT |
| LOW | unittest/observer/net/test_rpc_frame_util.h | 1 | /** | COMMENT |
| LOW | unittest/observer/net/test_net_thread_count.cpp | 1 | /** | COMMENT |
| LOW | unittest/storage/test_multiple_multi_scan_merge.cpp | 1 | /** | COMMENT |
| LOW | unittest/storage/test_tablet_table_store.cpp | 1 | /** | COMMENT |
| LOW | unittest/storage/test_dml_common.h | 1 | /** | COMMENT |
| LOW | unittest/storage/test_dml_common.h | 21 | #include "share/ob_rpc_struct.h" | COMMENT |
| LOW | unittest/storage/test_i_store.cpp | 101 | } | COMMENT |
| LOW | unittest/storage/schema_utils.h | 1 | /** | COMMENT |
| LOW | unittest/storage/ob_truncate_info_helper.cpp | 1 | // Copyright (c) 2025 OceanBase | COMMENT |
| LOW | …storage/test_sn_ls_restore_check_tablet_checkpoint.cpp | 1 | /** | COMMENT |
| LOW | unittest/storage/test_io_manager_v1.cpp | 1 | /** | COMMENT |
| LOW | unittest/storage/test_io_manager_v1.cpp | 21 | #include "lib/thread/thread_pool.h" | COMMENT |
| LOW | unittest/storage/test_io_manager_v1.cpp | 861 | // { | COMMENT |
| LOW | unittest/storage/test_io_manager_v1.cpp | 881 | // io_config.unit_config_.weight_ = 100; | COMMENT |
| LOW | unittest/storage/test_io_manager_v1.cpp | 901 | // ASSERT_NE(nullptr, io_request); | COMMENT |
| LOW | unittest/storage/test_tablet_helper.h | 1 | /** | COMMENT |
| LOW | unittest/storage/test_fts_property.cpp | 1 | /** | COMMENT |
| LOW | unittest/storage/test_io_manager.cpp | 1 | /** | COMMENT |
| LOW | unittest/storage/test_io_manager.cpp | 801 | // io manager not init, skip this test | COMMENT |
| LOW | unittest/storage/test_io_manager.cpp | 841 | // static void SetUpTestCase() | COMMENT |
| LOW | unittest/storage/test_io_manager.cpp | 861 | // const uint64_t tenant_id = OB_SERVER_TENANT_ID; | COMMENT |
| LOW | unittest/storage/test_io_manager.cpp | 881 | // ObRefHolder<ObTenantIOManager> tenant_holder; | COMMENT |
| LOW | unittest/storage/test_io_manager.cpp | 901 | // void *result_buf = tenant_holder.get_ptr()->io_allocator_.alloc(sizeof(ObIOResult)); | COMMENT |
| LOW | unittest/storage/mock_ob_tenant_storage.h | 1 | /** | COMMENT |
| LOW | unittest/storage/test_fts_plugin.cpp | 1 | /** | COMMENT |
| LOW | unittest/storage/test_fts_plugin.cpp | 301 | // public: | COMMENT |
| LOW | unittest/storage/test_fts_plugin.cpp | 321 | // cs_(nullptr), | COMMENT |
| LOW | unittest/storage/test_fts_plugin.cpp | 341 | //{ | COMMENT |
| LOW | unittest/storage/test_fts_plugin.cpp | 361 | // ASSERT_TRUE(nullptr != plugin->desc_); | COMMENT |
| LOW | unittest/storage/test_fts_plugin.cpp | 381 | // int64_t size = -1; | COMMENT |
| LOW | unittest/storage/test_fts_plugin.cpp | 401 | // | COMMENT |
| 5197 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1003 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 1); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1011 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1019 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 3); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1026 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 4); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1067 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 3); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1074 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1081 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1087 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1094 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1100 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1140 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 1); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1149 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1155 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1162 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1168 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1212 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 1); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1222 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 1); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1228 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 1); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1236 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1242 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1249 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1255 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1299 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 1); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1309 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 1); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1315 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 1); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1323 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1329 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1336 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1342 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1639 | EXPECT_FALSE(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.contains(addr2)); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1646 | EXPECT_FALSE(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.contains(addr2)); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1652 | EXPECT_FALSE(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.contains(addr2)); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1660 | EXPECT_TRUE(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.contains(addr2)); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1665 | EXPECT_TRUE(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.contains(addr2)); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_config_mgr.cpp | 1672 | EXPECT_TRUE(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.contains(addr2)); | CODE |
| CRITICAL | unittest/logservice/test_log_config_mgr.cpp | 1043 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 1); | CODE |
| CRITICAL | unittest/logservice/test_log_config_mgr.cpp | 1050 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 1); | CODE |
| CRITICAL | unittest/logservice/test_log_config_mgr.cpp | 1117 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 3); | CODE |
| CRITICAL | unittest/logservice/test_log_config_mgr.cpp | 1124 | EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 3); | CODE |
| CRITICAL | unittest/logservice/test_log_config_mgr.cpp | 1372 | EXPECT_EQ(OB_SUCCESS, cm.log_ms_meta_.curr_.config_.learnerlist_.add_learner(ObMember(addr4, -1))); | CODE |
| CRITICAL | unittest/logservice/test_log_config_mgr.cpp | 2062 | EXPECT_EQ(OB_SUCCESS, cm.log_ms_meta_.curr_.config_.learnerlist_.add_server(ObAddr(ip_type, addr_str, port - i))); | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_meta.cpp | 169 | log_meta1.log_config_meta_.curr_.config_.log_sync_memberlist_.add_member(ObMember(ObAddr(ip_type, addr_str, port - i | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_meta.cpp | 170 | log_meta1.log_config_meta_.prev_.config_.log_sync_memberlist_.add_member(ObMember(ObAddr(ip_type, addr_str, port - i | CODE |
| CRITICAL⚡ | unittest/logservice/test_log_meta.cpp | 177 | log_meta1.log_config_meta_.curr_.config_.learnerlist_.add_server(ObAddr(ip_type, addr_str, port - i)); | CODE |
| CRITICAL | mittest/logservice/test_ob_simple_log_arb.cpp | 680 | EXPECT_FALSE(palf_list[leader_idx]->get_palf_handle_impl()->config_mgr_.log_ms_meta_.curr_.config_.log_sync_memberlist | CODE |
| CRITICAL | mittest/logservice/test_ob_simple_log_arb.cpp | 681 | EXPECT_TRUE(palf_list[another_f_idx]->get_palf_handle_impl()->config_mgr_.log_ms_meta_.curr_.config_.log_sync_memberli | CODE |
| CRITICAL | mittest/logservice/test_ob_simple_log_arb.cpp | 811 | EXPECT_EQ(2, leader.palf_handle_impl_->config_mgr_.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number() | CODE |
| CRITICAL | mittest/logservice/test_ob_simple_log_disk_hang.cpp | 365 | EXPECT_UNTIL_EQ(true, leader.palf_handle_impl_->config_mgr_.log_ms_meta_.curr_.config_.degraded_learnerlist_.get_mem | CODE |
| CRITICAL | mittest/logservice/test_ob_simple_log_disk_hang.cpp | 370 | EXPECT_UNTIL_EQ(0, leader.palf_handle_impl_->config_mgr_.log_ms_meta_.curr_.config_.degraded_learnerlist_.get_member | CODE |
| CRITICAL | mittest/logservice/test_ob_simple_log_disk_hang.cpp | 382 | EXPECT_UNTIL_EQ(true, leader.palf_handle_impl_->config_mgr_.log_ms_meta_.curr_.config_.degraded_learnerlist_.get_mem | CODE |
| CRITICAL | mittest/logservice/test_ob_simple_log_disk_hang.cpp | 447 | EXPECT_UNTIL_EQ(true, leader.palf_handle_impl_->config_mgr_.log_ms_meta_.curr_.config_.degraded_learnerlist_.get_mem | CODE |
| CRITICAL | mittest/logservice/test_ob_simple_log_disk_hang.cpp | 456 | EXPECT_UNTIL_EQ(true, leader.palf_handle_impl_->config_mgr_.log_ms_meta_.curr_.config_.degraded_learnerlist_.get_mem | CODE |
| CRITICAL | mittest/logservice/test_ob_simple_log_disk_hang.cpp | 469 | EXPECT_UNTIL_EQ(true, leader.palf_handle_impl_->config_mgr_.log_ms_meta_.curr_.config_.degraded_learnerlist_.get_mem | CODE |
| CRITICAL | mittest/logservice/test_ob_simple_log_disk_hang.cpp | 478 | EXPECT_UNTIL_EQ(true, leader.palf_handle_impl_->config_mgr_.log_ms_meta_.curr_.config_.degraded_learnerlist_.get_mem | CODE |
| CRITICAL | mittest/logservice/test_ob_simple_log_arb_mock_ele.cpp | 107 | EXPECT_FALSE(leader.palf_handle_impl_->config_mgr_.log_ms_meta_.curr_.config_.log_sync_memberlist_.contains(b_addr)) | CODE |
| CRITICAL | mittest/logservice/test_ob_simple_log_arb_mock_ele.cpp | 108 | EXPECT_TRUE(b_handle->palf_handle_impl_->config_mgr_.log_ms_meta_.curr_.config_.log_sync_memberlist_.contains(b_addr | CODE |
| CRITICAL | mittest/logservice/test_ob_simple_log_arb_mock_ele.cpp | 131 | EXPECT_FALSE(leader.palf_handle_impl_->config_mgr_.log_ms_meta_.curr_.config_.log_sync_memberlist_.contains(b_addr)) | CODE |
| CRITICAL | mittest/logservice/test_ob_simple_log_arb_mock_ele.cpp | 170 | EXPECT_TRUE(leader.palf_handle_impl_->config_mgr_.log_ms_meta_.curr_.config_.log_sync_memberlist_.contains(b_addr)); | CODE |
| CRITICAL | mittest/logservice/test_ob_simple_log_arb_mock_ele.cpp | 221 | EXPECT_FALSE(leader.palf_handle_impl_->config_mgr_.log_ms_meta_.curr_.config_.log_sync_memberlist_.contains(b_addr)) | CODE |
| CRITICAL | mittest/logservice/test_ob_simple_log_arb_mock_ele.cpp | 222 | EXPECT_TRUE(b_handle->palf_handle_impl_->config_mgr_.log_ms_meta_.curr_.config_.log_sync_memberlist_.contains(b_addr | CODE |
| 88 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | tools/upgrade/upgrade_pre.py | 0 | select distinct value from oceanbase.gv$ob_parameters where name='min_observer_version' | STRING |
| HIGH | tools/upgrade/actions.py | 0 | select distinct value from oceanbase.gv$ob_parameters where name='min_observer_version' | STRING |
| HIGH | tools/upgrade/upgrade_post.py | 0 | select distinct value from oceanbase.gv$ob_parameters where name='min_observer_version' | STRING |
| HIGH | tools/upgrade/upgrade_pre.py | 0 | select value from oceanbase.__all_sys_parameter where name = 'enable_ddl' | STRING |
| HIGH | tools/upgrade/actions.py | 0 | select value from oceanbase.__all_sys_parameter where name = 'enable_ddl' | STRING |
| HIGH | tools/upgrade/upgrade_post.py | 0 | select value from oceanbase.__all_sys_parameter where name = 'enable_ddl' | STRING |
| HIGH | tools/upgrade/upgrade_pre.py | 0 | select distinct(substring_index(build_version, '_', 1)) from __all_server | STRING |
| HIGH | tools/upgrade/upgrade_checker.py | 0 | select distinct(substring_index(build_version, '_', 1)) from __all_server | STRING |
| HIGH | tools/upgrade/actions.py | 0 | select distinct(substring_index(build_version, '_', 1)) from __all_server | STRING |
| HIGH | tools/upgrade/upgrade_post.py | 0 | select distinct(substring_index(build_version, '_', 1)) from __all_server | STRING |
| HIGH | tools/upgrade/upgrade_pre.py | 0 | select * from oceanbase.{0} where name = '{1}' and value = '{2}' | STRING |
| HIGH | tools/upgrade/upgrade_post.py | 0 | select * from oceanbase.{0} where name = '{1}' and value = '{2}' | STRING |
| HIGH | tools/upgrade/actions.py | 0 | select * from oceanbase.{0} where name = '{1}' and value = '{2}' | STRING |
| HIGH | tools/upgrade/upgrade_pre.py | 0 | select count(*) as cnt from oceanbase.{0} where name = '{1}' and value != '{2}'{3} | STRING |
| HIGH | tools/upgrade/upgrade_post.py | 0 | select count(*) as cnt from oceanbase.{0} where name = '{1}' and value != '{2}'{3} | STRING |
| HIGH | tools/upgrade/actions.py | 0 | select count(*) as cnt from oceanbase.{0} where name = '{1}' and value != '{2}'{3} | STRING |
| HIGH | tools/upgrade/upgrade_pre.py | 0 | select distinct value from __all_virtual_sys_parameter_stat where name='min_observer_version' | STRING |
| HIGH | tools/upgrade/actions.py | 0 | select distinct value from __all_virtual_sys_parameter_stat where name='min_observer_version' | STRING |
| HIGH | tools/upgrade/upgrade_post.py | 0 | select distinct value from __all_virtual_sys_parameter_stat where name='min_observer_version' | STRING |
| HIGH | tools/upgrade/upgrade_pre.py | 0 | select distinct tenant_id from oceanbase.__all_tenant order by tenant_id desc | STRING |
| HIGH | tools/upgrade/actions.py | 0 | select distinct tenant_id from oceanbase.__all_tenant order by tenant_id desc | STRING |
| HIGH | tools/upgrade/upgrade_health_checker.py | 0 | select distinct tenant_id from oceanbase.__all_tenant order by tenant_id desc | STRING |
| HIGH | tools/upgrade/upgrade_post.py | 0 | select distinct tenant_id from oceanbase.__all_tenant order by tenant_id desc | STRING |
| HIGH | tools/upgrade/upgrade_pre.py | 0 | select svr_ip, svr_port, value from oceanbase.__all_virtual_sys_parameter_stat where name = 'syslog_level' | STRING |
| HIGH | tools/upgrade/upgrade_post.py | 0 | select svr_ip, svr_port, value from oceanbase.__all_virtual_sys_parameter_stat where name = 'syslog_level' | STRING |
| HIGH | tools/upgrade/tenant_upgrade_action.py | 0 | select svr_ip, svr_port, value from oceanbase.__all_virtual_sys_parameter_stat where name = 'syslog_level' | STRING |
| HIGH | tools/upgrade/upgrade_pre.py | 0 | select count(*) cnt from oceanbase.__all_virtual_sys_parameter_stat where name = 'syslog_level' and value = 'info' | STRING |
| HIGH | tools/upgrade/upgrade_post.py | 0 | select count(*) cnt from oceanbase.__all_virtual_sys_parameter_stat where name = 'syslog_level' and value = 'info' | STRING |
| HIGH | tools/upgrade/tenant_upgrade_action.py | 0 | select count(*) cnt from oceanbase.__all_virtual_sys_parameter_stat where name = 'syslog_level' and value = 'info' | STRING |
| HIGH | tools/upgrade/upgrade_pre.py | 0 | select job_status from oceanbase.__all_rootservice_job where job_type = '{0}' order by job_id desc limit 1 | STRING |
| HIGH | tools/upgrade/upgrade_post.py | 0 | select job_status from oceanbase.__all_rootservice_job where job_type = '{0}' order by job_id desc limit 1 | STRING |
| HIGH | tools/upgrade/tenant_upgrade_action.py | 0 | select job_status from oceanbase.__all_rootservice_job where job_type = '{0}' order by job_id desc limit 1 | STRING |
| HIGH | tools/upgrade/upgrade_pre.py | 0 | select job_status, rs_svr_ip, rs_svr_port, gmt_create from oceanbase.__all_rootservice_job where job_type = '{0}' and jo | STRING |
| HIGH | tools/upgrade/upgrade_post.py | 0 | select job_status, rs_svr_ip, rs_svr_port, gmt_create from oceanbase.__all_rootservice_job where job_type = '{0}' and jo | STRING |
| HIGH | tools/upgrade/tenant_upgrade_action.py | 0 | select job_status, rs_svr_ip, rs_svr_port, gmt_create from oceanbase.__all_rootservice_job where job_type = '{0}' and jo | STRING |
| HIGH | tools/upgrade/upgrade_pre.py | 0 | select count(*) from oceanbase.__all_virtual_core_meta_table where role = 1 and svr_ip = '{0}' and svr_port = {1} | STRING |
| HIGH | tools/upgrade/upgrade_post.py | 0 | select count(*) from oceanbase.__all_virtual_core_meta_table where role = 1 and svr_ip = '{0}' and svr_port = {1} | STRING |
| HIGH | tools/upgrade/tenant_upgrade_action.py | 0 | select count(*) from oceanbase.__all_virtual_core_meta_table where role = 1 and svr_ip = '{0}' and svr_port = {1} | STRING |
| HIGH | tools/upgrade/upgrade_pre.py | 0 | select count(*) from oceanbase.__all_rootservice_event_history where gmt_create > '{0}' and event = 'full_rootservice' | STRING |
| HIGH | tools/upgrade/upgrade_post.py | 0 | select count(*) from oceanbase.__all_rootservice_event_history where gmt_create > '{0}' and event = 'full_rootservice' | STRING |
| HIGH | tools/upgrade/tenant_upgrade_action.py | 0 | select count(*) from oceanbase.__all_rootservice_event_history where gmt_create > '{0}' and event = 'full_rootservice' | STRING |
| HIGH | tools/upgrade/upgrade_pre.py | 0 | select count(*) as cnt from oceanbase.__all_virtual_sys_parameter_stat where name = '{0}' and value != '{1}' | STRING |
| HIGH | tools/upgrade/upgrade_post.py | 0 | select count(*) as cnt from oceanbase.__all_virtual_sys_parameter_stat where name = '{0}' and value != '{1}' | STRING |
| HIGH | tools/upgrade/upgrade_checker.py | 0 | select count(*) as cnt from oceanbase.__all_virtual_sys_parameter_stat where name = '{0}' and value != '{1}' | STRING |
| HIGH | tools/upgrade/upgrade_pre.py | 0 | select distinct value from gv$ob_parameters where name='min_observer_version' | STRING |
| HIGH | tools/upgrade/upgrade_checker.py | 0 | select distinct value from gv$ob_parameters where name='min_observer_version' | STRING |
| HIGH | tools/upgrade/upgrade_post.py | 0 | select distinct value from gv$ob_parameters where name='min_observer_version' | STRING |
| HIGH | tools/upgrade/upgrade_pre.py | 0 | select distinct value from oceanbase.__all_virtual_tenant_parameter_info where name='compatible' | STRING |
| HIGH | tools/upgrade/upgrade_checker.py | 0 | select distinct value from oceanbase.__all_virtual_tenant_parameter_info where name='compatible' | STRING |
| HIGH | tools/upgrade/upgrade_post.py | 0 | select distinct value from oceanbase.__all_virtual_tenant_parameter_info where name='compatible' | STRING |
| HIGH | tools/upgrade/upgrade_pre.py | 0 | select count(1) as unsync_cnt from gv$ob_log_stat where in_sync = 'no' | STRING |
| HIGH | tools/upgrade/upgrade_checker.py | 0 | select count(1) as unsync_cnt from gv$ob_log_stat where in_sync = 'no' | STRING |
| HIGH | tools/upgrade/upgrade_post.py | 0 | select count(1) as unsync_cnt from gv$ob_log_stat where in_sync = 'no' | STRING |
| HIGH | tools/upgrade/upgrade_pre.py | 0 | select count(1) as cnt from dba_ob_tenant_jobs where job_status='inprogress' and result_code is null | STRING |
| HIGH | tools/upgrade/upgrade_checker.py | 0 | select count(1) as cnt from dba_ob_tenant_jobs where job_status='inprogress' and result_code is null | STRING |
| HIGH | tools/upgrade/upgrade_post.py | 0 | select count(1) as cnt from dba_ob_tenant_jobs where job_status='inprogress' and result_code is null | STRING |
| HIGH | tools/upgrade/upgrade_pre.py | 0 | select count(1) as rebalance_task_cnt from cdb_ob_ls_replica_tasks | STRING |
| HIGH | tools/upgrade/upgrade_checker.py | 0 | select count(1) as rebalance_task_cnt from cdb_ob_ls_replica_tasks | STRING |
| HIGH | tools/upgrade/upgrade_post.py | 0 | select count(1) as rebalance_task_cnt from cdb_ob_ls_replica_tasks | STRING |
| HIGH | tools/upgrade/upgrade_pre.py | 0 | select count(1) from cdb_ob_major_compaction where (global_broadcast_scn > last_scn or status != 'idle') | STRING |
| 164 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM⚡ | …est/storage/multi_data_source/test_mds_table_flush.cpp | 93 | // ┌──────────┐ │ ┌──────────┐ ┌── | COMMENT |
| MEDIUM⚡ | …est/storage/multi_data_source/test_mds_table_flush.cpp | 94 | // MdsUnit<DummyKey, ExampleUserData1> │(MAX, 500]│◄─┼──────────────────────┤[300, 250]│◄──────────────────────────┤(1 | COMMENT |
| MEDIUM⚡ | …est/storage/multi_data_source/test_mds_table_flush.cpp | 95 | // └──────────┘ │ └──────────┘ └── | COMMENT |
| MEDIUM⚡ | …est/storage/multi_data_source/test_mds_table_flush.cpp | 100 | // │ ┌──────────┐ ┌──────────┐ | COMMENT |
| MEDIUM⚡ | …est/storage/multi_data_source/test_mds_table_flush.cpp | 101 | // MdsUnit<DummyKey, ExampleUserData2> │ │[400, 350]│◄──────────────────────────┤[225, 200]│ | COMMENT |
| MEDIUM⚡ | …est/storage/multi_data_source/test_mds_table_flush.cpp | 102 | // │ └──────────┘ └──────────┘ | COMMENT |
| MEDIUM | deps/oblib/src/lib/compress/zstd_1_3_8/CMakeLists.txt | 1 | # ============================================================ | COMMENT |
| MEDIUM | deps/oblib/src/lib/compress/zstd_1_3_8/CMakeLists.txt | 3 | # ============================================================ | COMMENT |
| MEDIUM | deps/oblib/src/lib/compress/lz4/CMakeLists.txt | 1 | # ============================================================ | COMMENT |
| MEDIUM | deps/oblib/src/lib/compress/lz4/CMakeLists.txt | 3 | # ============================================================ | COMMENT |
| MEDIUM | deps/oblib/src/lib/compress/zstd_1_5_7/CMakeLists.txt | 1 | # ============================================================ | COMMENT |
| MEDIUM | deps/oblib/src/lib/compress/zstd_1_5_7/CMakeLists.txt | 3 | # ============================================================ | COMMENT |
| MEDIUM | deps/oblib/src/lib/compress/snappy/CMakeLists.txt | 1 | # ============================================================ | COMMENT |
| MEDIUM | deps/oblib/src/lib/compress/snappy/CMakeLists.txt | 3 | # ============================================================ | COMMENT |
| MEDIUM | deps/oblib/src/lib/compress/zstd/CMakeLists.txt | 1 | # ============================================================ | COMMENT |
| MEDIUM | deps/oblib/src/lib/compress/zstd/CMakeLists.txt | 3 | # ============================================================ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_unique_guard.h | 6 | // ┌─────────────┐Upgrade ┌─────────────┐ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_unique_guard.h | 7 | // │ObUniqueGuard├───────►│ObSharedGuard│ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_unique_guard.h | 8 | // └─────────────┘ └──▲──────┬───┘ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_unique_guard.h | 12 | // ┌─┴──────▼──┐ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_unique_guard.h | 14 | // └───────────┘ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_unique_guard.h | 16 | // ┌─────────────┐ Transfer Ownership ┌─────────────┐ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_unique_guard.h | 17 | // │ObUniqueGuard│◄──────────────────►│ObUniqueGuard│ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_unique_guard.h | 18 | // └─────────────┘ └─────────────┘ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_unique_guard.h | 20 | // ┌─────────────┐ Share Ownership ┌─────────────┐ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_unique_guard.h | 21 | // │ObSharedGuard│◄───────────────►│ObSharedGuard│ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_unique_guard.h | 22 | // └─────────────┘ └─────────────┘ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_unique_guard.h | 24 | // ┌───────────┐ Observe the same object ┌───────────┐ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_unique_guard.h | 25 | // │ObWeakGuard│◄───────────────────────►│ObWeakGuard│ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_unique_guard.h | 26 | // └───────────┘ └───────────┘ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_shared_guard.h | 6 | // ┌─────────────┐Upgrade ┌─────────────┐ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_shared_guard.h | 7 | // │ObUniqueGuard├───────►│ObSharedGuard│ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_shared_guard.h | 8 | // └─────────────┘ └──▲──────┬───┘ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_shared_guard.h | 12 | // ┌─┴──────▼──┐ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_shared_guard.h | 14 | // └───────────┘ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_shared_guard.h | 16 | // ┌─────────────┐ Transfer Ownership ┌─────────────┐ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_shared_guard.h | 17 | // │ObUniqueGuard│◄──────────────────►│ObUniqueGuard│ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_shared_guard.h | 18 | // └─────────────┘ └─────────────┘ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_shared_guard.h | 20 | // ┌─────────────┐ Share Ownership ┌─────────────┐ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_shared_guard.h | 21 | // │ObSharedGuard│◄───────────────►│ObSharedGuard│ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_shared_guard.h | 22 | // └─────────────┘ └─────────────┘ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_shared_guard.h | 24 | // ┌───────────┐ Observe the same object ┌───────────┐ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_shared_guard.h | 25 | // │ObWeakGuard│◄───────────────────────►│ObWeakGuard│ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_shared_guard.h | 26 | // └───────────┘ └───────────┘ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_weak_guard.h | 6 | // ┌─────────────┐Upgrade ┌─────────────┐ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_weak_guard.h | 7 | // │ObUniqueGuard├───────►│ObSharedGuard│ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_weak_guard.h | 8 | // └─────────────┘ └──▲──────┬───┘ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_weak_guard.h | 12 | // ┌─┴──────▼──┐ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_weak_guard.h | 14 | // └───────────┘ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_weak_guard.h | 16 | // ┌─────────────┐ Transfer Ownership ┌─────────────┐ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_weak_guard.h | 17 | // │ObUniqueGuard│◄──────────────────►│ObUniqueGuard│ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_weak_guard.h | 18 | // └─────────────┘ └─────────────┘ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_weak_guard.h | 20 | // ┌─────────────┐ Share Ownership ┌─────────────┐ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_weak_guard.h | 21 | // │ObSharedGuard│◄───────────────►│ObSharedGuard│ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_weak_guard.h | 22 | // └─────────────┘ └─────────────┘ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_weak_guard.h | 24 | // ┌───────────┐ Observe the same object ┌───────────┐ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_weak_guard.h | 25 | // │ObWeakGuard│◄───────────────────────►│ObWeakGuard│ | COMMENT |
| MEDIUM⚡ | deps/oblib/src/lib/guard/ob_weak_guard.h | 26 | // └───────────┘ └───────────┘ | COMMENT |
| MEDIUM⚡ | src/storage/ob_partition_range_spliter.cpp | 293 | // ────────────────────────────── | COMMENT |
| MEDIUM⚡ | src/storage/ob_partition_range_spliter.cpp | 298 | // Info 2: split_rowkey────────────┘ │ | COMMENT |
| 54 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | unittest/storage/test_storage_schema.cpp | 420 | // Step 1: Build a base table schema with virtual columns | COMMENT |
| LOW⚡ | unittest/storage/test_storage_schema.cpp | 446 | // Step 2: Init storage schema from base table schema | COMMENT |
| LOW⚡ | unittest/storage/test_storage_schema.cpp | 454 | // Step 3: Simulate update_column_cnt_and_schema_version from memtable | COMMENT |
| LOW⚡ | unittest/storage/test_storage_schema.cpp | 459 | // Step 4: Build the new table schema with one more stored column (DDL add column) | COMMENT |
| LOW⚡ | unittest/storage/test_storage_schema.cpp | 480 | // Step 5: Call update_column_info — this is the function under test | COMMENT |
| LOW⚡ | unittest/storage/test_storage_schema.cpp | 484 | // Step 6: Verify the fix | COMMENT |
| LOW | …est/logservice/test_ob_log_submit_log_rate_limiter.cpp | 1323 | // Step 1: B and C join RTO group | COMMENT |
| LOW | …est/logservice/test_ob_log_submit_log_rate_limiter.cpp | 1354 | // Step 2: B out (timeout/stale) | COMMENT |
| LOW | …est/logservice/test_ob_log_submit_log_rate_limiter.cpp | 1384 | // Step 3: B in, C out | COMMENT |
| LOW | …est/logservice/test_ob_log_submit_log_rate_limiter.cpp | 1414 | // Step 4: B out | COMMENT |
| LOW | …est/logservice/test_ob_log_submit_log_rate_limiter.cpp | 1440 | // Step 5: B, C in | COMMENT |
| LOW | …est/logservice/test_ob_log_submit_log_rate_limiter.cpp | 1489 | // Step 6: A, C join RTO group | COMMENT |
| LOW | …est/logservice/test_ob_log_submit_log_rate_limiter.cpp | 1522 | // Step 7: C out | COMMENT |
| LOW | …est/logservice/test_ob_log_submit_log_rate_limiter.cpp | 1552 | // Step 8: C in, A out | COMMENT |
| LOW | …est/logservice/test_ob_log_submit_log_rate_limiter.cpp | 1582 | // Step 9: C out | COMMENT |
| LOW | …est/logservice/test_ob_log_submit_log_rate_limiter.cpp | 1607 | // Step 10: A, C in | COMMENT |
| LOW | …ittest/logservice/test_ob_log_replay_process_cache.cpp | 402 | // Step 1: B and C join RTO group | COMMENT |
| LOW | …ittest/logservice/test_ob_log_replay_process_cache.cpp | 417 | // Step 2: B out (timeout/stale) | COMMENT |
| LOW | …ittest/logservice/test_ob_log_replay_process_cache.cpp | 433 | // Step 3: B in, C out | COMMENT |
| LOW | …ittest/logservice/test_ob_log_replay_process_cache.cpp | 449 | // Step 4: B out | COMMENT |
| LOW | …ittest/logservice/test_ob_log_replay_process_cache.cpp | 460 | // Step 5: B, C in | COMMENT |
| LOW | …ittest/logservice/test_ob_log_replay_process_cache.cpp | 490 | // Step 6: A, C join RTO group | COMMENT |
| LOW | …ittest/logservice/test_ob_log_replay_process_cache.cpp | 506 | // Step 7: C out | COMMENT |
| LOW | …ittest/logservice/test_ob_log_replay_process_cache.cpp | 522 | // Step 8: C in, A out | COMMENT |
| LOW | …ittest/logservice/test_ob_log_replay_process_cache.cpp | 538 | // Step 9: C out | COMMENT |
| LOW | …ittest/logservice/test_ob_log_replay_process_cache.cpp | 549 | // Step 10: A, C in | COMMENT |
| LOW | …t/sql/encryption/test_ob_sha256_crypt_mysql_compat.cpp | 927 | // Step 1: 解析 authentication_string,得到 salt、rounds、hash | COMMENT |
| LOW | …t/sql/encryption/test_ob_sha256_crypt_mysql_compat.cpp | 941 | // Step 2: OB 生成 hash | COMMENT |
| LOW | …t/sql/encryption/test_ob_sha256_crypt_mysql_compat.cpp | 953 | // Step 3: 提取 digest 做对比 | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_sort.h | 190 | // Step 1: Collect sort key expressions (sk_exprs_) from ORDER BY | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_sort.h | 302 | // Step 2: Collect child output expressions (column expressions from table) | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_sort.h | 316 | // Step 3: Append child output columns, mirroring append_child_output_no_dup(). | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_sort.h | 348 | // Step 4: Initialize spec arrays | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_sort.h | 371 | // Step 5: Set output_ to sk_exprs_ + addon_exprs_ (what sort operator actually outputs) | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_sort.h | 389 | // Step 6: Add sk_exprs to calc_exprs_ so they get cleared between batches | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_sort.h | 405 | // Step 7: Decide SingleColCompare optimization, mirroring CG | COMMENT |
| LOW⚡ | unittest/sql/engine/op_tests/ob_op_test_merge_join.h | 209 | // Step 1: Allocate spec | COMMENT |
| LOW⚡ | unittest/sql/engine/op_tests/ob_op_test_merge_join.h | 217 | // Step 2: Set basic fields | COMMENT |
| LOW⚡ | unittest/sql/engine/op_tests/ob_op_test_merge_join.h | 225 | // Step 3: Set children pointer | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_merge_join.h | 239 | // Step 4: Extract equal conditions from ON clause | COMMENT |
| LOW⚡ | unittest/sql/engine/op_tests/ob_op_test_merge_join.h | 290 | // Step 5: Initialize equal_cond_infos_ | COMMENT |
| LOW⚡ | unittest/sql/engine/op_tests/ob_op_test_merge_join.h | 298 | // Step 6: Initialize left/right_child_fetcher_all_exprs_ | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_merge_join.h | 314 | // Step 7: Append left/right child output to fetcher_all_exprs | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_merge_join.h | 326 | // Step 8: Process each equal condition | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_merge_join.h | 473 | // Step 9: Set merge_directions_ matching the sort order of input data | COMMENT |
| LOW⚡ | unittest/sql/engine/op_tests/ob_op_test_datahub.h | 231 | // Step 1: Create MockDtlChannel | COMMENT |
| LOW⚡ | unittest/sql/engine/op_tests/ob_op_test_datahub.h | 241 | // Step 2: Configure ObPxSqcMeta with minimal settings | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_datahub.h | 257 | // Step 3: Create ObPxSubCoord using placement new | COMMENT |
| LOW⚡ | unittest/sql/engine/op_tests/ob_op_test_datahub.h | 270 | // Step 4: Initialize sqc_proxy_'s msg_ready_cond_ to avoid blocking in wait_whole_msg | COMMENT |
| LOW⚡ | unittest/sql/engine/op_tests/ob_op_test_datahub.h | 279 | // Step 5: Create ObPxSqcHandler | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_datahub.h | 292 | // Step 6: Register sqc_handler with exec_ctx | COMMENT |
| LOW⚡ | unittest/sql/engine/op_tests/ob_op_test_base.h | 779 | // Step 1: Get OpInput (calls create_input which may be overridden) | COMMENT |
| LOW⚡ | unittest/sql/engine/op_tests/ob_op_test_base.h | 782 | // Step 2: Allocate operator | COMMENT |
| LOW⚡ | unittest/sql/engine/op_tests/ob_op_test_base.h | 790 | // Step 3: Set children pointer | COMMENT |
| LOW⚡ | unittest/sql/engine/op_tests/ob_op_test_base.h | 1349 | // Step 1: Register mock table schema | COMMENT |
| LOW⚡ | unittest/sql/engine/op_tests/ob_op_test_base.h | 1356 | // Step 2: Build SQL string | COMMENT |
| LOW⚡ | unittest/sql/engine/op_tests/ob_op_test_base.h | 1359 | // Step 3: Resolve SQL | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_base.h | 1324 | // Step 0: Set SQL mode (must be set before init) | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_base.h | 1419 | // Step 4: Generate expressions via CG (frame layout follows expr_cg_rich_format_) | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_base.h | 1600 | // Step 6: Collect LIMIT/OFFSET exprs | COMMENT |
| 205 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | unittest/storage/test_storage_schema.cpp | 420 | // Step 1: Build a base table schema with virtual columns | COMMENT |
| LOW⚡ | unittest/storage/test_storage_schema.cpp | 446 | // Step 2: Init storage schema from base table schema | COMMENT |
| LOW⚡ | unittest/storage/test_storage_schema.cpp | 454 | // Step 3: Simulate update_column_cnt_and_schema_version from memtable | COMMENT |
| LOW⚡ | unittest/storage/test_storage_schema.cpp | 459 | // Step 4: Build the new table schema with one more stored column (DDL add column) | COMMENT |
| LOW⚡ | unittest/storage/test_storage_schema.cpp | 480 | // Step 5: Call update_column_info — this is the function under test | COMMENT |
| LOW⚡ | unittest/storage/test_storage_schema.cpp | 484 | // Step 6: Verify the fix | COMMENT |
| LOW | …est/logservice/test_ob_log_submit_log_rate_limiter.cpp | 1323 | // Step 1: B and C join RTO group | COMMENT |
| LOW | …est/logservice/test_ob_log_submit_log_rate_limiter.cpp | 1354 | // Step 2: B out (timeout/stale) | COMMENT |
| LOW | …est/logservice/test_ob_log_submit_log_rate_limiter.cpp | 1384 | // Step 3: B in, C out | COMMENT |
| LOW | …est/logservice/test_ob_log_submit_log_rate_limiter.cpp | 1414 | // Step 4: B out | COMMENT |
| LOW | …est/logservice/test_ob_log_submit_log_rate_limiter.cpp | 1440 | // Step 5: B, C in | COMMENT |
| LOW | …est/logservice/test_ob_log_submit_log_rate_limiter.cpp | 1489 | // Step 6: A, C join RTO group | COMMENT |
| LOW | …est/logservice/test_ob_log_submit_log_rate_limiter.cpp | 1522 | // Step 7: C out | COMMENT |
| LOW | …est/logservice/test_ob_log_submit_log_rate_limiter.cpp | 1552 | // Step 8: C in, A out | COMMENT |
| LOW | …est/logservice/test_ob_log_submit_log_rate_limiter.cpp | 1582 | // Step 9: C out | COMMENT |
| LOW | …est/logservice/test_ob_log_submit_log_rate_limiter.cpp | 1607 | // Step 10: A, C in | COMMENT |
| LOW | …ittest/logservice/test_ob_log_replay_process_cache.cpp | 402 | // Step 1: B and C join RTO group | COMMENT |
| LOW | …ittest/logservice/test_ob_log_replay_process_cache.cpp | 417 | // Step 2: B out (timeout/stale) | COMMENT |
| LOW | …ittest/logservice/test_ob_log_replay_process_cache.cpp | 433 | // Step 3: B in, C out | COMMENT |
| LOW | …ittest/logservice/test_ob_log_replay_process_cache.cpp | 449 | // Step 4: B out | COMMENT |
| LOW | …ittest/logservice/test_ob_log_replay_process_cache.cpp | 460 | // Step 5: B, C in | COMMENT |
| LOW | …ittest/logservice/test_ob_log_replay_process_cache.cpp | 490 | // Step 6: A, C join RTO group | COMMENT |
| LOW | …ittest/logservice/test_ob_log_replay_process_cache.cpp | 506 | // Step 7: C out | COMMENT |
| LOW | …ittest/logservice/test_ob_log_replay_process_cache.cpp | 522 | // Step 8: C in, A out | COMMENT |
| LOW | …ittest/logservice/test_ob_log_replay_process_cache.cpp | 538 | // Step 9: C out | COMMENT |
| LOW | …ittest/logservice/test_ob_log_replay_process_cache.cpp | 549 | // Step 10: A, C in | COMMENT |
| LOW | …t/sql/encryption/test_ob_sha256_crypt_mysql_compat.cpp | 927 | // Step 1: 解析 authentication_string,得到 salt、rounds、hash | COMMENT |
| LOW | …t/sql/encryption/test_ob_sha256_crypt_mysql_compat.cpp | 941 | // Step 2: OB 生成 hash | COMMENT |
| LOW | …t/sql/encryption/test_ob_sha256_crypt_mysql_compat.cpp | 953 | // Step 3: 提取 digest 做对比 | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_sort.h | 190 | // Step 1: Collect sort key expressions (sk_exprs_) from ORDER BY | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_sort.h | 302 | // Step 2: Collect child output expressions (column expressions from table) | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_sort.h | 316 | // Step 3: Append child output columns, mirroring append_child_output_no_dup(). | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_sort.h | 348 | // Step 4: Initialize spec arrays | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_sort.h | 371 | // Step 5: Set output_ to sk_exprs_ + addon_exprs_ (what sort operator actually outputs) | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_sort.h | 389 | // Step 6: Add sk_exprs to calc_exprs_ so they get cleared between batches | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_sort.h | 405 | // Step 7: Decide SingleColCompare optimization, mirroring CG | COMMENT |
| LOW⚡ | unittest/sql/engine/op_tests/ob_op_test_merge_join.h | 209 | // Step 1: Allocate spec | COMMENT |
| LOW⚡ | unittest/sql/engine/op_tests/ob_op_test_merge_join.h | 217 | // Step 2: Set basic fields | COMMENT |
| LOW⚡ | unittest/sql/engine/op_tests/ob_op_test_merge_join.h | 225 | // Step 3: Set children pointer | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_merge_join.h | 239 | // Step 4: Extract equal conditions from ON clause | COMMENT |
| LOW⚡ | unittest/sql/engine/op_tests/ob_op_test_merge_join.h | 290 | // Step 5: Initialize equal_cond_infos_ | COMMENT |
| LOW⚡ | unittest/sql/engine/op_tests/ob_op_test_merge_join.h | 298 | // Step 6: Initialize left/right_child_fetcher_all_exprs_ | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_merge_join.h | 314 | // Step 7: Append left/right child output to fetcher_all_exprs | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_merge_join.h | 326 | // Step 8: Process each equal condition | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_merge_join.h | 473 | // Step 9: Set merge_directions_ matching the sort order of input data | COMMENT |
| LOW⚡ | unittest/sql/engine/op_tests/ob_op_test_datahub.h | 231 | // Step 1: Create MockDtlChannel | COMMENT |
| LOW⚡ | unittest/sql/engine/op_tests/ob_op_test_datahub.h | 241 | // Step 2: Configure ObPxSqcMeta with minimal settings | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_datahub.h | 257 | // Step 3: Create ObPxSubCoord using placement new | COMMENT |
| LOW⚡ | unittest/sql/engine/op_tests/ob_op_test_datahub.h | 270 | // Step 4: Initialize sqc_proxy_'s msg_ready_cond_ to avoid blocking in wait_whole_msg | COMMENT |
| LOW⚡ | unittest/sql/engine/op_tests/ob_op_test_datahub.h | 279 | // Step 5: Create ObPxSqcHandler | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_datahub.h | 292 | // Step 6: Register sqc_handler with exec_ctx | COMMENT |
| LOW⚡ | unittest/sql/engine/op_tests/ob_op_test_base.h | 779 | // Step 1: Get OpInput (calls create_input which may be overridden) | COMMENT |
| LOW⚡ | unittest/sql/engine/op_tests/ob_op_test_base.h | 782 | // Step 2: Allocate operator | COMMENT |
| LOW⚡ | unittest/sql/engine/op_tests/ob_op_test_base.h | 790 | // Step 3: Set children pointer | COMMENT |
| LOW⚡ | unittest/sql/engine/op_tests/ob_op_test_base.h | 1349 | // Step 1: Register mock table schema | COMMENT |
| LOW⚡ | unittest/sql/engine/op_tests/ob_op_test_base.h | 1356 | // Step 2: Build SQL string | COMMENT |
| LOW⚡ | unittest/sql/engine/op_tests/ob_op_test_base.h | 1359 | // Step 3: Resolve SQL | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_base.h | 1324 | // Step 0: Set SQL mode (must be set before init) | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_base.h | 1419 | // Step 4: Generate expressions via CG (frame layout follows expr_cg_rich_format_) | COMMENT |
| LOW | unittest/sql/engine/op_tests/ob_op_test_base.h | 1600 | // Step 6: Collect LIMIT/OFFSET exprs | COMMENT |
| 200 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | replace_license.py | 72 | def replace_doubleslash_comments(content): | CODE |
| LOW | unittest/sql/optimizer/cost_model_utils/plot_multi.py | 13 | def extract_int_info_from_line(line): | CODE |
| LOW | …ttest/sql/optimizer/cost_model_utils/plot_demension.py | 14 | def extract_int_info_from_line(line): | CODE |
| LOW | unittest/sql/optimizer/storage_perf/plot_multi.py | 13 | def extract_int_info_from_line(line): | CODE |
| LOW | unittest/sql/optimizer/storage_perf/plot_demension.py | 14 | def extract_int_info_from_line(line): | CODE |
| LOW | unittest/sql/external_table/gen_parquet_test_data.py | 40 | def gen_bloom_filter_smoking_test(spark, tmp_dir, table_name, mysql_test_name=None): | CODE |
| LOW | unittest/sql/external_table/gen_parquet_test_data.py | 59 | def gen_bloom_filter_all_numerics(spark, tmp_dir, table_name): | CODE |
| LOW | unittest/sql/external_table/gen_parquet_test_data.py | 94 | def gen_bloom_filter_all_other_types(spark, tmp_dir, table_name): | CODE |
| LOW | unittest/sql/external_table/gen_parquet_test_data.py | 131 | def gen_multi_stripes_with_simple_types(spark, tmp_dir, table_name): | CODE |
| LOW | unittest/sql/external_table/gen_orc_test_data.py | 39 | def gen_bloom_filter_smoking_test(spark, tmp_dir, table_name): | CODE |
| LOW | unittest/sql/external_table/gen_orc_test_data.py | 55 | def gen_bloom_filter_all_numerics(spark, tmp_dir, table_name): | CODE |
| LOW | unittest/sql/external_table/gen_orc_test_data.py | 88 | def gen_bloom_filter_all_other_types(spark, tmp_dir, table_name): | CODE |
| LOW | unittest/sql/external_table/gen_orc_test_data.py | 121 | def gen_multi_stripes_with_simple_types(spark, tmp_dir, table_name): | CODE |
| LOW⚡ | tools/upgrade/upgrade_pre.py | 2352 | #def check_not_supported_tenant_name(query_cur): | COMMENT |
| LOW⚡ | tools/upgrade/upgrade_pre.py | 2361 | #def check_log_transport_compress_func(query_cur): | COMMENT |
| LOW⚡ | tools/upgrade/upgrade_pre.py | 2367 | #def check_table_compress_func(query_cur): | COMMENT |
| LOW⚡ | tools/upgrade/upgrade_pre.py | 2373 | #def check_table_api_transport_compress_func(query_cur): | COMMENT |
| LOW⚡ | tools/upgrade/upgrade_pre.py | 2380 | #def check_tenant_clone_job_exist(query_cur): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 35 | #def get_current_cluster_version(): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 66 | #def get_rollback_sql_file_lines_str(): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 78 | #def dump_rollback_sql_to_file(rollback_sql_filename): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 139 | #def set_default_timeout_by_tenant(cur, timeout, timeout_per_tenant, min_timeout): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 232 | #def check_server_version_by_cluster(cur): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 983 | #def set_session_timeout_for_upgrade(cur, time): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 1293 | #def regenerate_upgrade_script(): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 1576 | #def check_can_run_upgrade_job(cur, job_name): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 2208 | #def check_is_primary_zone_distributed(primary_zone_str): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 2225 | #def check_tenant_primary_zone(query_cur): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 2244 | #def modify_server_permanent_offline_time(cur): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 2400 | #def check_tenant_snapshot_task_exist(query_cur): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 2420 | #def check_variable_binlog_row_image(query_cur): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 2440 | #def check_oracle_standby_replication_exist(query_cur): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 2479 | #def check_disk_space_for_mds_sstable_compat(query_cur): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 2498 | #def do_check_disk_space_for_compat(query_cur): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 2591 | #def get_max_extension_support(): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 2626 | #def check_direct_load_job_exist(cur, query_cur): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 2634 | #def check_enable_logonly_replica(cur, query_cur): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 2645 | #def check_cs_encoding_arch_dependency_compatiblity(query_cur, cpu_arch): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 2715 | #def check_cos_archive_and_backup(query_cur): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 2786 | #def check_vector_index_exist_on_column_table(query_cur): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 3245 | #def set_default_timeout_by_tenant(query_cur, timeout, timeout_per_tenant, min_timeout): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 3261 | #def check_server_version_by_zone(query_cur, zone): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 3360 | #def check_cluster_version_for_vector_index(query_cur): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 3395 | #def query_vector_index_info_all(query_cur, valid_tablets): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 3404 | #def query_valid_vector_index_tablets(query_cur): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 3437 | #def filter_valid_vector_index_tablets(results, valid_tablets): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 3488 | #def get_expected_replica_count(query_cur): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 3523 | #def group_by_tenant_and_tablet(results): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 3556 | #def calc_vector_index_wait_seconds(replicas): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 3565 | #def check_tenant_hnsw_index_loaded(tenant_id, tablets, incr_history, tenant_ls_replica_count): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 3773 | #def get_vector_index_loaded_count(tenant_stats): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 3779 | #def get_vector_index_status_signature(tenant_stats): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 3794 | #def check_vector_index_loaded(query_cur, zone, timeout): | COMMENT |
| LOW | tools/upgrade/upgrade_pre.py | 3875 | #def check_vector_index_loaded_one_round(grouped, tenant_expected_replica_count, incr_history, current_round, max_round) | COMMENT |
| LOW | tools/upgrade/reset_upgrade_scripts.py | 30 | def regenerate_upgrade_script(): | CODE |
| LOW⚡ | tools/upgrade/upgrade_checker.py | 658 | def check_not_supported_tenant_name(query_cur): | CODE |
| LOW⚡ | tools/upgrade/upgrade_checker.py | 667 | def check_log_transport_compress_func(query_cur): | CODE |
| LOW⚡ | tools/upgrade/upgrade_checker.py | 673 | def check_table_compress_func(query_cur): | CODE |
| LOW⚡ | tools/upgrade/upgrade_checker.py | 679 | def check_table_api_transport_compress_func(query_cur): | CODE |
| LOW⚡ | tools/upgrade/upgrade_checker.py | 686 | def check_tenant_clone_job_exist(query_cur): | CODE |
| 143 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | tools/upgrade/upgrade_checker.py | 39 | def exec_sql(self, sql, print_when_succ = True): | CODE |
| MEDIUM | tools/upgrade/upgrade_checker.py | 52 | def exec_query(self, sql, print_when_succ = True): | CODE |
| MEDIUM | tools/upgrade/upgrade_checker.py | 1155 | def do_check(my_host, my_port, my_user, my_passwd, timeout, upgrade_params, cpu_ | CODE |
| LOW | tools/upgrade/upgrade_checker.py | 49 | except Exception as e: | CODE |
| LOW | tools/upgrade/upgrade_checker.py | 63 | except Exception as e: | CODE |
| LOW | tools/upgrade/upgrade_checker.py | 1201 | except Exception as e: | STRING |
| LOW | tools/upgrade/upgrade_checker.py | 1210 | except Exception as e: | STRING |
| LOW | tools/upgrade/upgrade_checker.py | 1239 | except Exception as e: | STRING |
| MEDIUM | tools/upgrade/actions.py | 386 | def exec_sql(self, sql, print_when_succ = True): | CODE |
| MEDIUM | tools/upgrade/actions.py | 399 | def exec_query(self, sql, print_when_succ = True): | CODE |
| MEDIUM | tools/upgrade/actions.py | 418 | def exec_ddl(self, sql, print_when_succ = True): | CODE |
| MEDIUM | tools/upgrade/actions.py | 431 | def exec_query(self, sql, print_when_succ = True): | CODE |
| MEDIUM | tools/upgrade/actions.py | 441 | def exec_update(self, sql, print_when_succ = True): | CODE |
| MEDIUM | tools/upgrade/actions.py | 551 | def fetch_tenant_ids(query_cur): | CODE |
| LOW | tools/upgrade/actions.py | 396 | except Exception as e: | CODE |
| LOW | tools/upgrade/actions.py | 410 | except Exception as e: | CODE |
| LOW | tools/upgrade/actions.py | 423 | except Exception as e: | CODE |
| LOW | tools/upgrade/actions.py | 436 | except Exception as e: | CODE |
| LOW | tools/upgrade/actions.py | 446 | except Exception as e: | CODE |
| LOW | tools/upgrade/actions.py | 558 | except Exception as e: | CODE |
| MEDIUM | tools/upgrade/upgrade_health_checker.py | 34 | def exec_sql(self, sql, print_when_succ = True): | CODE |
| MEDIUM | tools/upgrade/upgrade_health_checker.py | 47 | def exec_query(self, sql, print_when_succ = True): | CODE |
| MEDIUM | tools/upgrade/upgrade_health_checker.py | 297 | def fetch_tenant_ids(query_cur): | CODE |
| MEDIUM | tools/upgrade/upgrade_health_checker.py | 423 | def check_cluster_version_for_vector_index(query_cur): | CODE |
| MEDIUM | tools/upgrade/upgrade_health_checker.py | 992 | def do_check(my_host, my_port, my_user, my_passwd, upgrade_params, timeout, | CODE |
| LOW⚡ | tools/upgrade/upgrade_health_checker.py | 544 | except Exception as e: | CODE |
| LOW⚡ | tools/upgrade/upgrade_health_checker.py | 560 | except Exception as e: | CODE |
| LOW | tools/upgrade/upgrade_health_checker.py | 44 | except Exception as e: | CODE |
| LOW | tools/upgrade/upgrade_health_checker.py | 58 | except Exception as e: | CODE |
| LOW | tools/upgrade/upgrade_health_checker.py | 304 | except Exception as e: | CODE |
| LOW | tools/upgrade/upgrade_health_checker.py | 442 | except Exception as e: | CODE |
| LOW | tools/upgrade/upgrade_health_checker.py | 1015 | except Exception as e: | CODE |
| LOW | tools/upgrade/upgrade_health_checker.py | 1024 | except Exception as e: | CODE |
| LOW | tools/upgrade/upgrade_health_checker.py | 1053 | except Exception as e: | CODE |
| LOW | tools/upgrade/do_upgrade_pre.py | 101 | except Exception as e: | CODE |
| LOW | tools/upgrade/do_upgrade_pre.py | 114 | except Exception as e: | CODE |
| LOW | tools/upgrade/do_upgrade_pre.py | 154 | except Exception as e: | CODE |
| MEDIUM | tools/upgrade/do_upgrade_pre.py | 57 | def do_upgrade(my_host, my_port, my_user, my_passwd, timeout, my_module_set, upg | CODE |
| LOW | tools/upgrade/upgrade_post_checker.py | 144 | except Exception as e: | CODE |
| MEDIUM | tools/upgrade/upgrade_post_checker.py | 133 | def do_check(conn, cur, query_cur, timeout): | CODE |
| LOW | tools/upgrade/do_upgrade_post.py | 112 | except Exception as e: | CODE |
| LOW | tools/upgrade/do_upgrade_post.py | 125 | except Exception as e: | CODE |
| LOW | tools/upgrade/do_upgrade_post.py | 165 | except Exception as e: | CODE |
| MEDIUM | tools/upgrade/do_upgrade_post.py | 59 | def do_upgrade(my_host, my_port, my_user, my_passwd, timeout, my_module_set, upg | CODE |
| LOW | tools/upgrade/tenant_upgrade_action.py | 40 | except Exception as e: | CODE |
| LOW | tools/upgrade/tenant_upgrade_action.py | 144 | except Exception as e: | CODE |
| LOW | tools/upgrade/tenant_upgrade_action.py | 175 | except Exception as e: | CODE |
| LOW | tools/upgrade/tenant_upgrade_action.py | 236 | except Exception as e: | CODE |
| LOW | tools/upgrade/tenant_upgrade_action.py | 261 | except Exception as e: | CODE |
| MEDIUM | tools/upgrade/tenant_upgrade_action.py | 29 | def upgrade_syslog_level(conn, cur): | CODE |
| MEDIUM | tools/upgrade/tenant_upgrade_action.py | 127 | def get_max_used_job_id(cur): | CODE |
| MEDIUM | tools/upgrade/tenant_upgrade_action.py | 148 | def check_can_run_upgrade_job(cur, job_name): | CODE |
| MEDIUM | tools/upgrade/tenant_upgrade_action.py | 179 | def check_upgrade_job_result(cur, job_name, timeout, max_used_job_id): | CODE |
| MEDIUM | tools/upgrade/tenant_upgrade_action.py | 240 | def run_upgrade_job(conn, cur, job_name, timeout): | CODE |
| LOW | .github/obfarm/obfarm.py | 124 | except Exception: | CODE |
| LOW | src/logservice/libobcdc/tests/rerun_obcdc_case.py | 65 | except Exception as e: | CODE |
| LOW | src/logservice/libobcdc/tests/rerun_obcdc_case.py | 83 | except Exception as e: | CODE |
| LOW | src/logservice/libobcdc/tests/rerun_obcdc_case.py | 113 | except Exception as e: | CODE |
| LOW | src/logservice/libobcdc/tests/rerun_obcdc_case.py | 135 | except Exception as e: | CODE |
| LOW | src/logservice/libobcdc/tests/rerun_obcdc_case.py | 152 | except Exception as e: | CODE |
| 5 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | mittest/mtlenv/test_htable_lock.cpp | 221 | ObString fake_key = ObString::make_string("k1"); | CODE |
| LOW⚡ | mittest/mtlenv/test_htable_lock.cpp | 222 | ObHTableLockKey lock_key(fake_table_id, fake_key); | CODE |
| LOW⚡ | mittest/mtlenv/test_htable_lock.cpp | 232 | ASSERT_EQ(OB_SUCCESS, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::SHARED, *lock_handle1)); | CODE |
| LOW⚡ | mittest/mtlenv/test_htable_lock.cpp | 233 | ASSERT_EQ(OB_SUCCESS, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::SHARED, *lock_handle2)); | CODE |
| LOW⚡ | mittest/mtlenv/test_htable_lock.cpp | 288 | ObString fake_key = ObString::make_string("k1"); | CODE |
| LOW⚡ | mittest/mtlenv/test_htable_lock.cpp | 289 | ObHTableLockKey lock_key(fake_table_id, fake_key); | CODE |
| LOW⚡ | mittest/mtlenv/test_htable_lock.cpp | 299 | ASSERT_EQ(OB_SUCCESS, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::EXCLUSIVE, *lock_handle1)); | CODE |
| LOW⚡ | mittest/mtlenv/test_htable_lock.cpp | 300 | ASSERT_EQ(OB_TRY_LOCK_ROW_CONFLICT, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::EXCLUSIVE, *l | CODE |
| LOW⚡ | mittest/mtlenv/test_htable_lock.cpp | 305 | ASSERT_EQ(OB_SUCCESS, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::EXCLUSIVE, *lock_handle2)); | CODE |
| LOW⚡ | mittest/mtlenv/test_htable_lock.cpp | 318 | ObString fake_key = ObString::make_string("k1"); | CODE |
| LOW⚡ | mittest/mtlenv/test_htable_lock.cpp | 319 | ObHTableLockKey lock_key(fake_table_id, fake_key); | CODE |
| LOW⚡ | mittest/mtlenv/test_htable_lock.cpp | 326 | ASSERT_EQ(OB_SUCCESS, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::SHARED, *lock_handle)); | CODE |
| LOW⚡ | mittest/mtlenv/test_htable_lock.cpp | 329 | ASSERT_EQ(OB_SUCCESS, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::SHARED, *lock_handle)); | CODE |
| LOW⚡ | mittest/mtlenv/test_htable_lock.cpp | 335 | ASSERT_EQ(OB_TRY_LOCK_ROW_CONFLICT, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::EXCLUSIVE, *l | CODE |
| LOW⚡ | mittest/mtlenv/test_htable_lock.cpp | 336 | ASSERT_EQ(OB_SUCCESS, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::SHARED, *lock_handle2)); | CODE |
| LOW⚡ | mittest/mtlenv/test_htable_lock.cpp | 340 | ASSERT_EQ(OB_TRY_LOCK_ROW_CONFLICT, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::EXCLUSIVE, *l | CODE |
| LOW⚡ | mittest/mtlenv/test_htable_lock.cpp | 344 | ASSERT_EQ(OB_SUCCESS, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::EXCLUSIVE, *lock_handle)); | CODE |
| LOW⚡ | mittest/mtlenv/test_htable_lock.cpp | 351 | ASSERT_EQ(OB_TRY_LOCK_ROW_CONFLICT, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::EXCLUSIVE, *l | CODE |
| LOW⚡ | mittest/mtlenv/test_htable_lock.cpp | 352 | ASSERT_EQ(OB_TRY_LOCK_ROW_CONFLICT, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::SHARED, *lock | CODE |
| LOW⚡ | mittest/mtlenv/test_htable_lock.cpp | 355 | ASSERT_EQ(OB_SUCCESS, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::SHARED, *lock_handle)); | CODE |
| LOW⚡ | mittest/mtlenv/test_htable_lock.cpp | 362 | ASSERT_EQ(OB_TRY_LOCK_ROW_CONFLICT, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::EXCLUSIVE, *l | CODE |
| LOW⚡ | mittest/mtlenv/test_htable_lock.cpp | 363 | ASSERT_EQ(OB_TRY_LOCK_ROW_CONFLICT, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::SHARED, *lock | CODE |
| LOW⚡ | mittest/mtlenv/test_htable_lock.cpp | 366 | ASSERT_EQ(OB_SUCCESS, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::SHARED, *lock_handle)); | CODE |
| LOW⚡ | mittest/mtlenv/test_htable_lock.cpp | 372 | ASSERT_EQ(OB_TRY_LOCK_ROW_CONFLICT, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::EXCLUSIVE, *l | CODE |
| LOW⚡ | mittest/mtlenv/test_htable_lock.cpp | 373 | ASSERT_EQ(OB_TRY_LOCK_ROW_CONFLICT, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::SHARED, *lock | CODE |
| LOW | mittest/mtlenv/test_htable_lock.cpp | 137 | ObString fake_key = ObString::make_string("k1"); | CODE |
| LOW | mittest/mtlenv/test_htable_lock.cpp | 142 | ASSERT_EQ(OB_SUCCESS, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::SHARED, *lock_handle)); | CODE |
| LOW | mittest/mtlenv/test_htable_lock.cpp | 247 | ObString fake_key = ObString::make_string("k1"); | CODE |
| LOW | mittest/mtlenv/test_htable_lock.cpp | 248 | ObHTableLockKey lock_key(fake_table_id, fake_key); | CODE |
| LOW | mittest/mtlenv/test_htable_lock.cpp | 259 | ASSERT_EQ(OB_SUCCESS, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::SHARED, *lock_handle1)); | CODE |
| LOW | mittest/mtlenv/test_htable_lock.cpp | 260 | ASSERT_EQ(OB_TRY_LOCK_ROW_CONFLICT, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::EXCLUSIVE, *l | CODE |
| LOW | mittest/mtlenv/test_htable_lock.cpp | 273 | ASSERT_EQ(OB_SUCCESS, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::EXCLUSIVE, *lock_handle1)); | CODE |
| LOW | mittest/mtlenv/test_htable_lock.cpp | 274 | ASSERT_EQ(OB_TRY_LOCK_ROW_CONFLICT, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::SHARED, *lock | CODE |
| LOW | mittest/mtlenv/storage/test_mds_table_scan.cpp | 344 | common::ObString dummy_key; | CODE |
| LOW | mittest/mtlenv/storage/test_mds_table_scan.cpp | 355 | dummy_key, | CODE |
| LOW | mittest/mtlenv/storage/test_mds_table_scan.cpp | 385 | ret = tablet->read_raw_data(allocator_, mds_unit_id, dummy_key, snapshot, timeout_us, kv); | CODE |
| LOW | mittest/mtlenv/storage/test_mds_table_scan.cpp | 454 | common::ObString dummy_key; | CODE |
| LOW | mittest/mtlenv/storage/test_mds_table_scan.cpp | 465 | dummy_key, | CODE |
| LOW | mittest/mtlenv/storage/test_mds_table_scan.cpp | 708 | common::ObString dummy_key; | CODE |
| LOW | mittest/mtlenv/storage/test_mds_table_scan.cpp | 728 | dummy_key, | CODE |
| LOW | mittest/mtlenv/storage/test_mds_table_scan.cpp | 804 | dummy_key, | CODE |
| LOW | mittest/mtlenv/storage/test_mds_table_scan.cpp | 841 | dummy_key, | CODE |
| LOW | mittest/mtlenv/storage/test_mds_table_scan.cpp | 990 | common::ObString dummy_key; | CODE |
| LOW | mittest/mtlenv/storage/test_mds_table_scan.cpp | 1017 | dummy_key, | CODE |
| LOW | mittest/mtlenv/storage/test_mds_table_scan.cpp | 1331 | common::ObString dummy_key; | CODE |
| LOW | deps/oblib/src/lib/oblog/ob_log_print_kv.h | 800 | #define LOG_KVS(...) "placeholder" LOG_KVS_(ARGS_NUM(__VA_ARGS__), __VA_ARGS__) | COMMENT |
| LOW | deps/oblib/src/lib/oblog/ob_log_print_kv.h | 838 | #define LOG_VALUES(...) "placeholder" LOG_VALUES_(ARGS_NUM(__VA_ARGS__), __VA_ARGS__) | COMMENT |
| LOW | src/pl/ob_pl_code_generator.cpp | 9890 | ObLLVMValue dummy_value; | CODE |
| LOW | src/pl/ob_pl_code_generator.cpp | 9891 | if (OB_FAIL(vars_.push_back(dummy_value))) { | CODE |
| LOW | src/plugin/legacy/external_table/ob_external_filter.h | 45 | static constexpr const char *QUESTION_MARK_PLACEHOLDER_FIELD_NAME = "placeholder"; | CODE |
| LOW | src/storage/tablet/ob_tablet_block_aggregated_info.cpp | 238 | MacroBlockId dummy_id; | CODE |
| LOW | src/storage/tablet/ob_tablet_full_memory_mds_data.cpp | 236 | mds::DummyKey dummy_key; | CODE |
| LOW | src/storage/tablet/ob_tablet_full_memory_mds_data.cpp | 237 | if (OB_FAIL(key.init(table_id, unit_id, dummy_key, allocator))) { | CODE |
| LOW | src/storage/tablet/ob_tablet_full_memory_mds_data.cpp | 375 | mds::DummyKey dummy_key; | CODE |
| LOW | src/storage/tablet/ob_tablet_full_memory_mds_data.cpp | 376 | if (OB_FAIL(key.init(table_id, unit_id, dummy_key, allocator))) { | CODE |
| LOW | src/storage/memtable/mvcc/ob_keybtree.cpp | 689 | BtreeKey dummy_key; | CODE |
| LOW | src/storage/memtable/mvcc/ob_keybtree.cpp | 690 | ret = split_child(old_node, pos, pos < 0 ? dummy_key : old_node->get_key(pos, &this->index_), | CODE |
| LOW | src/share/system_variable/ob_system_variable_init.json | 11711 | "placeholder": false | CODE |
| LOW | src/share/system_variable/ob_system_variable_init.json | 12031 | "placeholder": true | CODE |
| LOW | src/share/system_variable/gen_ob_sys_variables.py | 77 | ignored_attrs = ["publish_version", "info_cn", "background_cn", "ref_url", "placeholder"] | CODE |
| 15 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | src/storage/blocksstable/ob_storage_object_type_def.py | 1559 | object_id.set_ss_fourth_id(!false && opt.ss_share_opt_.is_ls_inner_tablet_, | CODE |
| HIGH | src/share/system_variable/gen_ob_sys_variables.py | 376 | cpp_file.write(" for (int64_t i = 0; OB_SUCC(ret) && false == name_exist && i < var_amount; ++i){\n") | CODE |
| HIGH | src/share/system_variable/gen_ob_sys_variables.py | 378 | cpp_file.write(" ObSysVars[i].default_value_.assign_ptr(new_value.ptr(), new_value.length());\n") | CODE |
| HIGH | src/share/system_variable/gen_ob_sys_variables.py | 400 | cpp_file.write(" for (int64_t i = 0; OB_SUCC(ret) && false == name_exist && i < var_amount; ++i){\n") | CODE |
| HIGH | src/share/system_variable/gen_ob_sys_variables.py | 402 | cpp_file.write(" ObSysVars[i].base_value_.assign_ptr(new_value.ptr(), new_value.length());\n") | CODE |
| HIGH | src/share/system_variable/gen_ob_sys_variables.py | 861 | return 0 <= store_idx && store_idx < ObSysVarFactory::ALL_SYS_VARS_COUNT; | CODE |
| HIGH | src/share/system_variable/gen_ob_sys_variables.py | 1051 | } else if (-1 == store_idx && OB_FAIL(calc_sys_var_store_idx(sys_var_id, store_idx))) { | CODE |
| HIGH | src/share/system_variable/gen_ob_sys_variables.py | 1053 | } else if (store_idx < 0 || store_idx >= ALL_SYS_VARS_COUNT) { | CODE |
| HIGH | src/share/inner_table/generate_inner_table_schema.py | 2468 | h_f.write(" for (uint64_t i = 0; common::OB_INVALID_ID == idx && i < ARRAYSIZEOF(all_ora_mapping_virtual_tables); ++i | STRING |
| HIGH | src/share/inner_table/generate_inner_table_schema.py | 2498 | h_f.write(" if (pure_id > common::OB_MAX_MYSQL_VIRTUAL_TABLE_ID && pure_id < common::OB_MAX_VIRTUAL_TABLE_ID) {\n") | STRING |
| HIGH | src/share/inner_table/generate_inner_table_schema.py | 2518 | h_f.write(" if (pure_id > common::OB_MAX_MYSQL_VIRTUAL_TABLE_ID && pure_id < common::OB_MAX_VIRTUAL_TABLE_ID) {\n") | STRING |
| HIGH | src/share/inner_table/generate_inner_table_schema.py | 2527 | h_f.write(" for (int64_t i = 0; !bret && i < ARRAYSIZEOF(only_rs_vtables); ++i) {\n"); | STRING |
| HIGH | src/share/inner_table/generate_inner_table_schema.py | 2538 | h_f.write(" for (int64_t i = 0; !bret && i < ARRAYSIZEOF(cluster_distributed_vtables); ++i) {\n"); | STRING |
| HIGH | src/share/inner_table/generate_inner_table_schema.py | 2549 | h_f.write(" for (int64_t i = 0; !bret && i < ARRAYSIZEOF(tenant_distributed_vtables); ++i) {\n"); | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | unittest/sql/external_table/gen_parquet_test_data.py | 19 | CODE | |
| LOW | unittest/sql/external_table/gen_orc_test_data.py | 18 | CODE | |
| LOW | tools/import_srs_data.py | 2 | CODE | |
| LOW | tools/import_srs_data.py | 3 | CODE | |
| LOW | tools/import_srs_data.py | 4 | CODE | |
| LOW | tools/import_srs_data.py | 5 | CODE | |
| LOW | tools/import_srs_data.py | 8 | CODE | |
| LOW | tools/import_time_zone_info.py | 2 | CODE | |
| LOW | tools/import_time_zone_info.py | 4 | CODE | |
| LOW | tools/import_time_zone_info.py | 5 | CODE | |
| LOW | tools/import_time_zone_info.py | 7 | CODE | |
| LOW | tools/upgrade/upgrade_pre.py | 4146 | CODE | |
| LOW | tools/upgrade/upgrade_pre.py | 4146 | CODE | |
| LOW | tools/upgrade/special_upgrade_action_pre.py | 4 | CODE | |
| LOW | tools/upgrade/special_upgrade_action_pre.py | 6 | CODE | |
| LOW | tools/upgrade/special_upgrade_action_pre.py | 7 | CODE | |
| LOW | tools/upgrade/special_upgrade_action_pre.py | 9 | CODE | |
| LOW | tools/upgrade/special_upgrade_action_pre.py | 10 | CODE | |
| LOW | tools/upgrade/special_upgrade_action_pre.py | 11 | CODE | |
| LOW | tools/upgrade/special_upgrade_action_pre.py | 12 | CODE | |
| LOW | tools/upgrade/special_upgrade_action_pre.py | 14 | CODE | |
| LOW | tools/upgrade/special_upgrade_action_pre.py | 15 | CODE | |
| LOW | tools/upgrade/special_upgrade_action_pre.py | 17 | CODE | |
| LOW | tools/upgrade/upgrade_checker.py | 4 | CODE | |
| LOW | tools/upgrade/upgrade_checker.py | 8 | CODE | |
| LOW | tools/upgrade/actions.py | 5 | CODE | |
| LOW | tools/upgrade/actions.py | 6 | CODE | |
| LOW | tools/upgrade/actions.py | 7 | CODE | |
| LOW | tools/upgrade/actions.py | 8 | CODE | |
| LOW | tools/upgrade/actions.py | 10 | CODE | |
| LOW | tools/upgrade/upgrade_health_checker.py | 4 | CODE | |
| LOW | tools/upgrade/upgrade_health_checker.py | 9 | CODE | |
| LOW | tools/upgrade/my_utils.py | 4 | CODE | |
| LOW | tools/upgrade/my_utils.py | 5 | CODE | |
| LOW | tools/upgrade/do_upgrade_pre.py | 7 | CODE | |
| LOW | tools/upgrade/upgrade_post_checker.py | 5 | CODE | |
| LOW | tools/upgrade/upgrade_post_checker.py | 6 | CODE | |
| LOW | tools/upgrade/upgrade_post_checker.py | 8 | CODE | |
| LOW | tools/upgrade/upgrade_post_checker.py | 9 | CODE | |
| LOW | tools/upgrade/do_upgrade_post.py | 7 | CODE | |
| LOW | tools/upgrade/do_upgrade_post.py | 10 | CODE | |
| LOW | tools/upgrade/upgrade_post.py | 4146 | CODE | |
| LOW | tools/upgrade/upgrade_post.py | 4146 | CODE | |
| LOW | tools/upgrade/tenant_upgrade_action.py | 7 | CODE | |
| LOW | tools/upgrade/tenant_upgrade_action.py | 8 | CODE | |
| LOW | tools/upgrade/tenant_upgrade_action.py | 9 | CODE | |
| LOW | tools/upgrade/tenant_upgrade_action.py | 11 | CODE | |
| LOW | tools/upgrade/tenant_upgrade_action.py | 12 | CODE | |
| LOW | .github/obfarm/obfarm.py | 2 | CODE | |
| LOW | .github/obfarm/obfarm.py | 3 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …env/storage/blocksstable/ob_index_block_data_prepare.h | 1597 | // The robust way is to use the end rowkey of the last macro meta in `partial_sstable_` as the boundary, | COMMENT |
| MEDIUM | deps/oblib/src/common/row/ob_row_store.cpp | 707 | if (block == blocks_.get_last()) { // to be robust | CODE |
| MEDIUM | deps/oblib/src/lib/restore/ob_object_storage_base.h | 40 | // as COS cannot utilize OB's code directly, to avoid compilation errors | COMMENT |
| MEDIUM | …objit/deps/googletest/include/gtest/gtest-death-test.h | 146 | // This implementation is *not* meant to be as highly tuned or robust | COMMENT |
| MEDIUM | …objit/deps/googletest/include/gtest/gtest-death-test.h | 218 | // In practice, this can be used to test functions that utilize the | COMMENT |
| MEDIUM | src/storage/tx_table/ob_tx_table_define.h | 263 | // these checks. To address this scenario, we utilize configuration settings | COMMENT |
| MEDIUM | src/storage/tx_table/ob_tx_table_define.h | 315 | // these checks. To address this scenario, we utilize configuration settings | COMMENT |
| MEDIUM | src/logservice/libobcdc/src/ob_log_schema_getter.cpp | 560 | // Essentially, in addition to the schema information for tables, the schema for databases and tenants currently only | COMMENT |
| MEDIUM | src/share/ob_rpc_struct.h | 9884 | // Essentially, we can use ObIArray<ObNewRange> here | COMMENT |
| MEDIUM | src/share/wr/ob_wr_task.h | 198 | // Therefore, lazy_snapshot_interval_min_ is added to utilize a lazy loading mode to avoid the issue. | COMMENT |
| MEDIUM | src/sql/rewrite/ob_transform_utils.cpp | 16653 | // we store table indices instead of table item to leverage the consumption | COMMENT |
| MEDIUM | src/sql/optimizer/ob_logical_operator.h | 2020 | bool is_local_order_by_das_; // local order originates from DAS scan, GI cannot leverage it | CODE |
| MEDIUM | src/sql/engine/expr/ob_expr_local_dynamic_filter.cpp | 178 | // just use pk increment value as hash val to leverage current logic of dynamic in filter | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | replace_license.py | 25 | CODE | |
| LOW | replace_license.py | 97 | CODE | |
| LOW | tools/import_time_zone_info.py | 26 | CODE | |
| LOW | tools/upgrade/upgrade_pre.py | 4167 | CODE | |
| LOW | tools/upgrade/reset_upgrade_scripts.py | 6 | CODE | |
| LOW | tools/upgrade/upgrade_checker.py | 350 | CODE | |
| LOW | tools/upgrade/upgrade_checker.py | 433 | CODE | |
| LOW | tools/upgrade/upgrade_checker.py | 531 | CODE | |
| LOW | tools/upgrade/upgrade_checker.py | 572 | CODE | |
| LOW | tools/upgrade/upgrade_checker.py | 594 | CODE | |
| LOW | tools/upgrade/upgrade_checker.py | 615 | CODE | |
| LOW | tools/upgrade/upgrade_checker.py | 686 | CODE | |
| LOW | tools/upgrade/upgrade_checker.py | 706 | CODE | |
| LOW | tools/upgrade/upgrade_checker.py | 726 | CODE | |
| LOW | tools/upgrade/upgrade_checker.py | 746 | CODE | |
| LOW | tools/upgrade/upgrade_checker.py | 951 | CODE | |
| LOW | tools/upgrade/upgrade_checker.py | 1021 | CODE | |
| LOW | tools/upgrade/upgrade_checker.py | 1092 | CODE | |
| LOW | tools/upgrade/actions.py | 172 | CODE | |
| LOW | tools/upgrade/actions.py | 248 | CODE | |
| LOW | tools/upgrade/upgrade_health_checker.py | 628 | CODE | |
| LOW | tools/upgrade/upgrade_health_checker.py | 813 | CODE | |
| LOW | tools/upgrade/upgrade_health_checker.py | 857 | CODE | |
| LOW | tools/upgrade/do_upgrade_pre.py | 118 | CODE | |
| LOW | tools/upgrade/upgrade_post_checker.py | 22 | CODE | |
| LOW | tools/upgrade/do_upgrade_post.py | 129 | CODE | |
| LOW | tools/upgrade/upgrade_post.py | 4167 | CODE | |
| LOW | tools/upgrade/gen_upgrade_scripts.py | 8 | CODE | |
| LOW | tools/upgrade/tenant_upgrade_action.py | 70 | CODE | |
| LOW | tools/upgrade/tenant_upgrade_action.py | 148 | CODE | |
| LOW | tools/upgrade/tenant_upgrade_action.py | 179 | CODE | |
| LOW | .github/obfarm/obfarm.py | 132 | CODE | |
| LOW | src/storage/blocksstable/generate_shared_object_type.py | 68 | CODE | |
| LOW | src/storage/blocksstable/generate_shared_object_type.py | 113 | CODE | |
| LOW | src/storage/blocksstable/generate_shared_object_type.py | 445 | CODE | |
| LOW | src/logservice/libobcdc/tests/rerun_obcdc_case.py | 58 | CODE | |
| LOW | src/logservice/libobcdc/tests/rerun_obcdc_case.py | 68 | CODE | |
| LOW | src/logservice/libobcdc/tests/rerun_obcdc_case.py | 118 | CODE | |
| LOW | src/share/inner_table/sys_package/syspack_codegen.py | 125 | CODE | |
| LOW | src/share/inner_table/sys_package/syspack_codegen.py | 93 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | src/observer/omt/ob_tenant_ai_service.cpp | 62 | // TODO: implement after cache support | COMMENT |
| LOW | src/storage/meta_mem/ob_storage_meta_cache.cpp | 656 | // TODO: implement batch read in shared block reader. | COMMENT |
| LOW | …/storage/blocksstable/encoding/ob_vector_decode_util.h | 122 | // TODO: implement ? | COMMENT |
| LOW | src/storage/retrieval/ob_spiv_dim_iter.cpp | 274 | // TODO: implement agg_iter_ | COMMENT |
| LOW | src/share/vector_index/ob_vector_embedding_handler.cpp | 1567 | // TODO: implement this | COMMENT |
| LOW | src/sql/das/search/ob_das_match_query.h | 78 | // TODO: implement cost computing | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | replace_license.py | 43 | except (IOError, OSError): | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | src/storage/blocksstable/ob_storage_object_type_def.py | 5 | # you can add new storage object type here | COMMENT |
| LOW | src/storage/tx/ob_tx_api.cpp | 142 | * don't forget to call release_tx before release callback's memory | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tools/ob_admin/ss_ob_admin.py | 64 | CODE | |
| LOW | tools/ob_admin/ss_ob_admin.py | 77 | CODE |