diff --git a/src/sql/code_generator/ob_static_engine_cg.cpp b/src/sql/code_generator/ob_static_engine_cg.cpp
index a262ac3886..0169c458bd 100644
--- a/src/sql/code_generator/ob_static_engine_cg.cpp
+++ b/src/sql/code_generator/ob_static_engine_cg.cpp
@@ -303,6 +303,7 @@ int ObStaticEngineCG::postorder_generate_op(ObLogicalOperator &op,
     ret = OB_ERR_UNEXPECTED;
     LOG_WARN("NULL operator spec returned", K(ret));
   } else {
+    spec->compress_type_ = compress_type;
     for (int64_t i = 0; i < children.count() && OB_SUCC(ret); i++) {
       if (OB_FAIL(spec->set_child(i, children.at(i)))) {
         LOG_WARN("set child failed", K(ret));
@@ -332,8 +333,7 @@ int ObStaticEngineCG::postorder_generate_op(ObLogicalOperator &op,
   } else if (OB_FAIL(ObOperatorFactory::generate_spec(*this, op, *spec, in_root_job))) {
     LOG_WARN("generate operator spec failed",
              K(ret), KP(phy_plan_), K(ob_phy_operator_type_str(type)));
-  } else if (OB_FAIL(generate_spec_basic(op, *spec, check_eval_once, need_check_output_datum,
-                                         compress_type))) {
+  } else if (OB_FAIL(generate_spec_basic(op, *spec, check_eval_once, need_check_output_datum))) {
     LOG_WARN("generate operator spec basic failed", K(ret));
   } else if (OB_FAIL(generate_spec_final(op, *spec))) {
     LOG_WARN("generate operator spec final failed", K(ret));
@@ -787,8 +787,7 @@ int ObStaticEngineCG::generate_rt_exprs(const ObIArray<ObRawExpr *> &src,
 int ObStaticEngineCG::generate_spec_basic(ObLogicalOperator &op,
                                           ObOpSpec &spec,
                                           const bool check_eval_once,
-                                          const bool need_check_output_datum,
-                                          const common::ObCompressorType compress_type)
+                                          const bool need_check_output_datum)
 {
   int ret = OB_SUCCESS;
   if (0 == spec.rows_) {
@@ -798,7 +797,6 @@ int ObStaticEngineCG::generate_spec_basic(ObLogicalOperator &op,
   spec.width_ = op.get_width();
   spec.plan_depth_ = op.get_plan_depth();
   spec.px_est_size_factor_ = op.get_px_est_size_factor();
-  spec.compress_type_ = compress_type;
 
   OZ(generate_rt_exprs(op.get_startup_exprs(), spec.startup_filters_));
 
diff --git a/src/sql/code_generator/ob_static_engine_cg.h b/src/sql/code_generator/ob_static_engine_cg.h
index 608028e911..9f51af312c 100644
--- a/src/sql/code_generator/ob_static_engine_cg.h
+++ b/src/sql/code_generator/ob_static_engine_cg.h
@@ -247,8 +247,7 @@ private:
   int generate_spec_basic(ObLogicalOperator &op,
                           ObOpSpec &spec,
                           const bool check_eval_once,
-                          const bool need_check_output_datum,
-                          const common::ObCompressorType compress_type);
+                          const bool need_check_output_datum);
 
   // Invoked after generate_spec() and generate_spec_basic(),
   // some operator need this phase to do some special generation.
diff --git a/src/sql/engine/ob_operator.cpp b/src/sql/engine/ob_operator.cpp
index c47518a4cc..d3352b2226 100644
--- a/src/sql/engine/ob_operator.cpp
+++ b/src/sql/engine/ob_operator.cpp
@@ -166,7 +166,8 @@ DEF_TO_STRING(ObOpSpec)
        K_(rows),
        K_(max_batch_size),
        K_(filters),
-       K_(use_rich_format));
+       K_(use_rich_format),
+       K_(compress_type));
   J_OBJ_END();
   return pos;
 }