fix some typo error
This commit is contained in:
@ -203,7 +203,7 @@ int ObDropDatabaseExecutor::execute(ObExecContext &ctx, ObDropDatabaseStmt &stmt
|
|||||||
SQL_ENG_LOG(WARN, "get common rpc proxy failed", K(ret));
|
SQL_ENG_LOG(WARN, "get common rpc proxy failed", K(ret));
|
||||||
} else if (OB_ISNULL(common_rpc_proxy) || OB_ISNULL(ctx.get_my_session())) {
|
} else if (OB_ISNULL(common_rpc_proxy) || OB_ISNULL(ctx.get_my_session())) {
|
||||||
ret = OB_ERR_UNEXPECTED;
|
ret = OB_ERR_UNEXPECTED;
|
||||||
SQL_ENG_LOG(WARN, "failt to get my session", K(ctx), K(common_rpc_proxy));
|
SQL_ENG_LOG(WARN, "fail to get my session", K(ctx), K(common_rpc_proxy));
|
||||||
} else {
|
} else {
|
||||||
obrpc::UInt64 affected_row(0);
|
obrpc::UInt64 affected_row(0);
|
||||||
obrpc::ObDropDatabaseRes drop_database_res;
|
obrpc::ObDropDatabaseRes drop_database_res;
|
||||||
|
|||||||
@ -598,7 +598,7 @@ int ObCreateTableExecutor::execute(ObExecContext &ctx, ObCreateTableStmt &stmt)
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// only CTAS or create temperary table will make session_id != 0. If such table detected, set
|
// only CTAS or create temporary table will make session_id != 0. If such table detected, set
|
||||||
// need ctas cleanup task anyway to do some cleanup jobs
|
// need ctas cleanup task anyway to do some cleanup jobs
|
||||||
if (0 != table_schema.get_session_id()) {
|
if (0 != table_schema.get_session_id()) {
|
||||||
LOG_TRACE("CTAS or temporary table create detected", K(table_schema));
|
LOG_TRACE("CTAS or temporary table create detected", K(table_schema));
|
||||||
@ -2173,7 +2173,7 @@ int ObTruncateTableExecutor::execute(ObExecContext &ctx, ObTruncateTableStmt &st
|
|||||||
bool use_parallel_truncate = false;
|
bool use_parallel_truncate = false;
|
||||||
const uint64_t tenant_id = truncate_table_arg.tenant_id_;
|
const uint64_t tenant_id = truncate_table_arg.tenant_id_;
|
||||||
if (OB_FAIL(check_use_parallel_truncate(truncate_table_arg, use_parallel_truncate))) {
|
if (OB_FAIL(check_use_parallel_truncate(truncate_table_arg, use_parallel_truncate))) {
|
||||||
LOG_WARN("fail to check use parallel trunate", KR(ret), K(truncate_table_arg));
|
LOG_WARN("fail to check use parallel truncate", KR(ret), K(truncate_table_arg));
|
||||||
} else if (!use_parallel_truncate) {
|
} else if (!use_parallel_truncate) {
|
||||||
if (OB_FAIL(common_rpc_proxy->truncate_table(truncate_table_arg, res))) {
|
if (OB_FAIL(common_rpc_proxy->truncate_table(truncate_table_arg, res))) {
|
||||||
LOG_WARN("rpc proxy alter table failed", K(ret));
|
LOG_WARN("rpc proxy alter table failed", K(ret));
|
||||||
@ -2372,7 +2372,7 @@ int ObFlashBackTableToScnExecutor::execute(ObExecContext &ctx, ObFlashBackTableT
|
|||||||
LOG_WARN("get common rpc proxy failed", K(ret));
|
LOG_WARN("get common rpc proxy failed", K(ret));
|
||||||
} else if (OB_ISNULL(common_rpc_proxy)) {
|
} else if (OB_ISNULL(common_rpc_proxy)) {
|
||||||
ret = OB_ERR_UNEXPECTED;
|
ret = OB_ERR_UNEXPECTED;
|
||||||
LOG_WARN("cmmon rpc proxy should not be null", K(ret));
|
LOG_WARN("common rpc proxy should not be null", K(ret));
|
||||||
} else if (OB_FAIL(common_rpc_proxy->flashback_table_to_time_point(arg))) {
|
} else if (OB_FAIL(common_rpc_proxy->flashback_table_to_time_point(arg))) {
|
||||||
LOG_WARN("rpc proxy flashback table failed", K(ret));
|
LOG_WARN("rpc proxy flashback table failed", K(ret));
|
||||||
}
|
}
|
||||||
|
|||||||
@ -596,7 +596,7 @@ int ObSubPlanFilterOp::switch_iterator()
|
|||||||
} else if (OB_FAIL(child_->switch_iterator())) {
|
} else if (OB_FAIL(child_->switch_iterator())) {
|
||||||
//TODO: 目前只支持对非相关子查询做多组迭代器切换,只切换主表
|
//TODO: 目前只支持对非相关子查询做多组迭代器切换,只切换主表
|
||||||
if (OB_ITER_END != ret) {
|
if (OB_ITER_END != ret) {
|
||||||
LOG_WARN("swtich child operator iterator failed", K(ret));
|
LOG_WARN("switch child operator iterator failed", K(ret));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -918,7 +918,7 @@ int ObSubPlanFilterOp::handle_next_batch_with_px_rescan(const int64_t op_max_bat
|
|||||||
}
|
}
|
||||||
if (left_rows_total_cnt != left_rows_.get_row_cnt()) {
|
if (left_rows_total_cnt != left_rows_.get_row_cnt()) {
|
||||||
ret = OB_ERR_UNEXPECTED;
|
ret = OB_ERR_UNEXPECTED;
|
||||||
LOG_WARN("left_rows row cnt is unexpectd", K(ret));
|
LOG_WARN("left_rows row cnt is unexpected", K(ret));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -1045,7 +1045,7 @@ int ObSubPlanFilterOp::handle_next_batch_with_group_rescan(const int64_t op_max_
|
|||||||
LOG_WARN("prepare rescan params failed", K(ret));
|
LOG_WARN("prepare rescan params failed", K(ret));
|
||||||
} else if (left_rows_total_cnt != left_rows_.get_row_cnt()) {
|
} else if (left_rows_total_cnt != left_rows_.get_row_cnt()) {
|
||||||
ret = OB_ERR_UNEXPECTED;
|
ret = OB_ERR_UNEXPECTED;
|
||||||
LOG_WARN("left_rows row cnt is unexpectd", K(ret));
|
LOG_WARN("left_rows row cnt is unexpected", K(ret));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -1383,7 +1383,7 @@ int ObSubPlanFilterOp::handle_update_set()
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
if (OB_SUCC(ret) && OB_FAIL(row_val.store_row_->to_expr(MY_SPEC.update_set_, eval_ctx_))) {
|
if (OB_SUCC(ret) && OB_FAIL(row_val.store_row_->to_expr(MY_SPEC.update_set_, eval_ctx_))) {
|
||||||
LOG_WARN("failed to get expr from chunck datum store. ", K(ret));
|
LOG_WARN("failed to get expr from chunk datum store. ", K(ret));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@ -26,7 +26,7 @@ class ObSubPlanScanSpec : public ObOpSpec
|
|||||||
public:
|
public:
|
||||||
ObSubPlanScanSpec(common::ObIAllocator &alloc, const ObPhyOperatorType type);
|
ObSubPlanScanSpec(common::ObIAllocator &alloc, const ObPhyOperatorType type);
|
||||||
// project child output to subplan scan column.
|
// project child output to subplan scan column.
|
||||||
// projector_is filled with [child output, scan column] paires, even index is child output,
|
// projector_is filled with [child output, scan column] pairs, even index is child output,
|
||||||
// odd is scan column. e.g.:
|
// odd is scan column. e.g.:
|
||||||
// [child output, scan column, child output, scan column, ...]
|
// [child output, scan column, child output, scan column, ...]
|
||||||
ExprFixedArray projector_;
|
ExprFixedArray projector_;
|
||||||
|
|||||||
Reference in New Issue
Block a user