hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

fix mysqltest:root dfo can not alloc bloom filter in pull to local shuffle

Browse Source
This commit is contained in:
obdev
2022-11-14 09:38:15 +00:00
committed by wangzelin.wzl
parent f47331f508
commit ff0c30bc5d
2 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/sql/engine/expr/ob_expr_to_outfile_row.cpp
View File

@ -205,9 +205,9 @@ int ObExprToOutfileRow::to_outfile_str(const ObExpr &expr, ObEvalCtx &ctx, ObDat
} }
int ObExprToOutfileRow::extract_fisrt_wchar_from_varhcar(const ObObj &obj, int32_t &wchar) int ObExprToOutfileRow::extract_fisrt_wchar_from_varhcar(const ObObj &obj, int32_t &wchar)
{ {
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
int32_t length = 0; int32_t length = 0;
if (obj.is_varying_len_char_type()) { if (obj.is_varying_len_char_type()) {
ObString str = obj.get_varchar(); ObString str = obj.get_varchar();
if (str.length() > 0) { if (str.length() > 0) {

3
src/sql/optimizer/ob_join_order.cpp
View File

@ -7834,7 +7834,8 @@ int ObJoinOrder::create_and_add_hash_path(const Path *left_path,
LOG_WARN("failed to append join filters", K(ret)); LOG_WARN("failed to append join filters", K(ret));
} else if (OB_FAIL(append(join_path->filter_, filters))) { } else if (OB_FAIL(append(join_path->filter_, filters))) {
LOG_WARN("failed to append join quals", K(ret)); LOG_WARN("failed to append join quals", K(ret));
} else if (OB_FAIL(generate_join_filter_infos(left_path, } else if (DistAlgo::DIST_PULL_TO_LOCAL != join_dist_algo &&
OB_FAIL(generate_join_filter_infos(left_path,
right_path, right_path,
join_type, join_type,
join_dist_algo, join_dist_algo,