do not generate channel id when server id is not initialized

2023-03-13 13:13:45 +00:00
parent 0c1246660d
commit bce17f207e
1 changed files with 3 additions and 0 deletions
--- a/src/sql/engine/px/ob_px_coord_op.cpp
+++ b/src/sql/engine/px/ob_px_coord_op.cpp
@ -342,6 +342,9 @@ int ObPxCoordOp::inner_open()
  int ret = OB_SUCCESS;
  ObDfo *root_dfo = NULL;
  if (OB_FAIL(ObPxReceiveOp::inner_open())) {
+  } else if (GCTX.server_id_ <= 0) {
+    ret = OB_SERVER_IS_INIT;
+    LOG_WARN("Server is initializing", K(ret), K(GCTX.server_id_));
  } else if (OB_FAIL(post_init_op_ctx())) {
    LOG_WARN("init operator context failed", K(ret));
  } else if (FALSE_IT(px_sequence_id_ = GCTX.sql_engine_->get_px_sequence_id())) {