add some debug logs
This commit is contained in:
@ -308,6 +308,8 @@ int ObPxMultiPartSSTableInsertOp::get_next_row_with_cache()
|
|||||||
datum.set_uint(next_autoinc_val);
|
datum.set_uint(next_autoinc_val);
|
||||||
auto_inc_expr->set_evaluated_projected(eval_ctx_);
|
auto_inc_expr->set_evaluated_projected(eval_ctx_);
|
||||||
ddl_task_id_ = tablet_seq_caches_.at(curr_tablet_idx_).task_id_;
|
ddl_task_id_ = tablet_seq_caches_.at(curr_tablet_idx_).task_id_;
|
||||||
|
LOG_INFO("update ddl parallel id", K(ret), K(curr_tablet_idx_), K(ddl_task_id_),
|
||||||
|
"cache_interval", tablet_seq_caches_.at(curr_tablet_idx_));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
|
|||||||
@ -676,6 +676,8 @@ int ObSSTableInsertTabletContext::construct_sstable_slice_writer(
|
|||||||
LOG_WARN("fail to new ObSSTableInsertSliceWriter", KR(ret));
|
LOG_WARN("fail to new ObSSTableInsertSliceWriter", KR(ret));
|
||||||
} else if (OB_FAIL(sstable_slice_writer->init(slice_param, table_schema, ddl_kv_mgr_handle_))) {
|
} else if (OB_FAIL(sstable_slice_writer->init(slice_param, table_schema, ddl_kv_mgr_handle_))) {
|
||||||
LOG_WARN("fail to init sstable slice writer", KR(ret), K(slice_param));
|
LOG_WARN("fail to init sstable slice writer", KR(ret), K(slice_param));
|
||||||
|
} else {
|
||||||
|
LOG_INFO("init sstable slice writer finished", K(ret), K(slice_param));
|
||||||
}
|
}
|
||||||
if (OB_FAIL(ret)) {
|
if (OB_FAIL(ret)) {
|
||||||
if (nullptr != sstable_slice_writer) {
|
if (nullptr != sstable_slice_writer) {
|
||||||
|
|||||||
Reference in New Issue
Block a user