diff --git a/src/sql/engine/pdml/static/ob_px_sstable_insert_op.cpp b/src/sql/engine/pdml/static/ob_px_sstable_insert_op.cpp index 19b05c9000..358c64fc4c 100644 --- a/src/sql/engine/pdml/static/ob_px_sstable_insert_op.cpp +++ b/src/sql/engine/pdml/static/ob_px_sstable_insert_op.cpp @@ -308,6 +308,8 @@ int ObPxMultiPartSSTableInsertOp::get_next_row_with_cache() datum.set_uint(next_autoinc_val); auto_inc_expr->set_evaluated_projected(eval_ctx_); 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 { diff --git a/src/storage/ddl/ob_direct_insert_sstable_ctx.cpp b/src/storage/ddl/ob_direct_insert_sstable_ctx.cpp index 4f96c699f6..e40fa13191 100644 --- a/src/storage/ddl/ob_direct_insert_sstable_ctx.cpp +++ b/src/storage/ddl/ob_direct_insert_sstable_ctx.cpp @@ -676,6 +676,8 @@ int ObSSTableInsertTabletContext::construct_sstable_slice_writer( LOG_WARN("fail to new ObSSTableInsertSliceWriter", KR(ret)); } 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)); + } else { + LOG_INFO("init sstable slice writer finished", K(ret), K(slice_param)); } if (OB_FAIL(ret)) { if (nullptr != sstable_slice_writer) {