4.1 rm ddl_tracing serialize related code

src/rootserver/ddl_task/ob_constraint_task.cpp

@@ -1811,8 +1811,6 @@ int ObConstraintTask::serialize_params_to_message(char *buf, const int64_t buf_l
     LOG_WARN("fail to serialize task version", K(ret), K(task_version_));
   } else if (OB_FAIL(alter_table_arg_.serialize(buf, buf_len, pos))) {
     LOG_WARN("serialize table arg failed", K(ret));
-  } else if (OB_FAIL(ddl_tracing_.serialize(buf, buf_len, pos))) {
-    LOG_WARN("fail to serialize ddl_flt_ctx", K(ret));
   }
   return ret;
 }
@@ -1830,20 +1828,13 @@ int ObConstraintTask::deserlize_params_from_message(const char *buf, const int64
     LOG_WARN("serialize table failed", K(ret));
   } else if (OB_FAIL(deep_copy_table_arg(allocator_, tmp_arg, alter_table_arg_))) {
     LOG_WARN("deep copy table arg failed", K(ret));
-  } else {
-    if (pos < data_len) {
-      if (OB_FAIL(ddl_tracing_.deserialize(buf, data_len, pos))) {
-        LOG_WARN("fail to deserialize ddl_tracing_", K(ret));
-      }
-    }
   }
   return ret;
 }
 
 int64_t ObConstraintTask::get_serialize_param_size() const
 {
-  return alter_table_arg_.get_serialize_size() + serialization::encoded_length_i64(task_version_)
+  return alter_table_arg_.get_serialize_size() + serialization::encoded_length_i64(task_version_);
-    + ddl_tracing_.get_serialize_size();
 }
 
 void ObConstraintTask::flt_set_task_span_tag() const

src/rootserver/ddl_task/ob_ddl_retry_task.cpp

@@ -610,8 +610,6 @@ int ObDDLRetryTask::serialize_params_to_message(char *buf, const int64_t buf_siz
     LOG_WARN("fail to serialize task version", K(ret), K(task_version_));
   } else if (OB_FAIL(ddl_arg_->serialize(buf, buf_size, pos))) {
     LOG_WARN("serialize table arg failed", K(ret));
-  } else if (OB_FAIL(ddl_tracing_.serialize(buf, buf_size, pos))) {
-    LOG_WARN("fail to serialize ddl_flt_ctx", K(ret));
   }
   return ret;
 }
@@ -656,13 +654,6 @@ int ObDDLRetryTask::deserlize_params_from_message(const char *buf, const int64_t
       LOG_WARN("deep copy table arg failed", K(ret));
     }
   }
-  if (OB_SUCC(ret)) {
-    if (pos < buf_size) {
-      if (OB_FAIL(ddl_tracing_.deserialize(buf, buf_size, pos))) {
-        LOG_WARN("fail to deserialize ddl_tracing_", K(ret));
-      }
-    }
-  }
   return ret;
 }
 
@@ -672,7 +663,6 @@ int64_t ObDDLRetryTask::get_serialize_param_size() const
   if (OB_NOT_NULL(ddl_arg_)) {
     serialize_param_size += ddl_arg_->get_serialize_size();
   }
-  serialize_param_size += ddl_tracing_.get_serialize_size();
   return serialize_param_size;
 }
 

src/rootserver/ddl_task/ob_drop_index_task.cpp

@@ -414,8 +414,6 @@ int ObDropIndexTask::serialize_params_to_message(char *buf, const int64_t buf_si
     LOG_WARN("invalid arg", K(ret), KP(buf), K(buf_size));
   } else if (OB_FAIL(drop_index_arg_.serialize(buf, buf_size, pos))) {
     LOG_WARN("serialize failed", K(ret));
-  } else if (OB_FAIL(ddl_tracing_.serialize(buf, buf_size, pos))) {
-    LOG_WARN("fail to serialize ddl_flt_ctx", K(ret));
   }
   return ret;
 }
@@ -431,19 +429,13 @@ int ObDropIndexTask::deserlize_params_from_message(const char *buf, const int64_
     LOG_WARN("deserialize failed", K(ret));
   } else if (OB_FAIL(deep_copy_index_arg(allocator_, tmp_drop_index_arg, drop_index_arg_))) {
     LOG_WARN("deep copy drop index arg failed", K(ret));
-  } else {
-    if (pos < buf_size) {
-      if (OB_FAIL(ddl_tracing_.deserialize(buf, buf_size, pos))) {
-        LOG_WARN("fail to deserialize ddl_tracing_", K(ret));
-      }
-    }
   }
   return ret;
 }
 
 int64_t ObDropIndexTask::get_serialize_param_size() const
 {
-  return drop_index_arg_.get_serialize_size() + ddl_tracing_.get_serialize_size();
+  return drop_index_arg_.get_serialize_size();
 }
 
 void ObDropIndexTask::flt_set_task_span_tag() const

src/rootserver/ddl_task/ob_index_build_task.cpp

@@ -1465,11 +1465,6 @@ int ObIndexBuildTask::serialize_params_to_message(char *buf, const int64_t buf_l
   } else {
     LST_DO_CODE(OB_UNIS_ENCODE, check_unique_snapshot_);
     LST_DO_CODE(OB_UNIS_ENCODE, parallelism_, data_format_version_);
-    if (OB_SUCC(ret)) {
-      if (OB_FAIL(ddl_tracing_.serialize(buf, buf_len, pos))) {
-        LOG_WARN("fail to serialize ddl_flt_ctx", K(ret));
-      }
-    }
   }
   return ret;
 }
@@ -1490,11 +1485,6 @@ int ObIndexBuildTask::deserlize_params_from_message(const char *buf, const int64
   } else {
     LST_DO_CODE(OB_UNIS_DECODE, check_unique_snapshot_);
     LST_DO_CODE(OB_UNIS_DECODE, parallelism_, data_format_version_);
-    if (OB_SUCC(ret) && pos < data_len) {
-      if (OB_FAIL(ddl_tracing_.deserialize(buf, data_len, pos))) {
-        LOG_WARN("fail to deserialize ddl_tracing_", K(ret));
-      }
-    }
   }
   return ret;
 }
@@ -1505,6 +1495,5 @@ int64_t ObIndexBuildTask::get_serialize_param_size() const
       + serialization::encoded_length_i64(check_unique_snapshot_)
       + serialization::encoded_length_i64(task_version_)
       + serialization::encoded_length_i64(parallelism_)
-      + serialization::encoded_length_i64(data_format_version_)
+      + serialization::encoded_length_i64(data_format_version_);
-      + ddl_tracing_.get_serialize_size();
 }

src/rootserver/ddl_task/ob_modify_autoinc_task.cpp

@@ -594,8 +594,6 @@ int ObModifyAutoincTask::serialize_params_to_message(char *buf, const int64_t bu
     LOG_WARN("fail to serialize task version", K(ret), K(task_version_));
   } else if (OB_FAIL(alter_table_arg_.serialize(buf, buf_len, pos))) {
     LOG_WARN("serialize table arg failed", K(ret));
-  } else if (OB_FAIL(ddl_tracing_.serialize(buf, buf_len, pos))) {
-    LOG_WARN("fail to serialize ddl_flt_ctx", K(ret));
   }
   return ret;
 }
@@ -613,20 +611,13 @@ int ObModifyAutoincTask::deserlize_params_from_message(const char *buf, const in
     LOG_WARN("serialize table failed", K(ret));
   } else if (OB_FAIL(deep_copy_table_arg(allocator_, tmp_arg, alter_table_arg_))) {
     LOG_WARN("deep copy table arg failed", K(ret));
-  } else {
-    if (pos < data_len) {
-      if (OB_FAIL(ddl_tracing_.deserialize(buf, data_len, pos))) {
-        LOG_WARN("fail to deserialize ddl_tracing_", K(ret));
-      }
-    }
   }
   return ret;
 }
 
 int64_t ObModifyAutoincTask::get_serialize_param_size() const
 {
-  return alter_table_arg_.get_serialize_size() + serialization::encoded_length_i64(task_version_)
+  return alter_table_arg_.get_serialize_size() + serialization::encoded_length_i64(task_version_);
-    + ddl_tracing_.get_serialize_size();
 }
 
 void ObModifyAutoincTask::flt_set_task_span_tag() const