diff --git a/src/sql/engine/px/ob_px_sub_coord.cpp b/src/sql/engine/px/ob_px_sub_coord.cpp index 349c908c7552a3e5196487bb6b0a5dadc6c1e424..4fa742ba4e9ee743ed71774ee99c9501c27ca382 100644 --- a/src/sql/engine/px/ob_px_sub_coord.cpp +++ b/src/sql/engine/px/ob_px_sub_coord.cpp @@ -894,6 +894,9 @@ int ObPxSubCoord::end_ddl(const bool need_commit) } LOG_INFO("end ddl sstable", K(ret), K(need_commit)); } + if (OB_EAGAIN == ret) { + ret = OB_STATE_NOT_MATCH; // avoid px hang + } return ret; }