Skip to content
This repository has been archived by the owner on May 10, 2022. It is now read-only.

Commit

Permalink
fix: add info for ERR_SESSION_RESET when querying meta failed (#66)
Browse files Browse the repository at this point in the history
  • Loading branch information
Wu Tao authored Nov 15, 2019
1 parent d078730 commit 0619e2c
Showing 1 changed file with 2 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -71,15 +71,12 @@ public TableHandler(ClusterManager mgr, String name, KeyHasher h) throws Replica

query_cfg_request req = new query_cfg_request(name, new ArrayList<Integer>());
query_cfg_operator op = new query_cfg_operator(new gpid(-1, -1), req);

mgr.getMetaSession().query(op, 5);

error_types err = MetaSession.getMetaServiceError(op);
if (err != error_types.ERR_OK) {
handleMetaException(err, mgr, name);
return;
}

query_cfg_response resp = op.get_response();
logger.info(
"query meta configuration succeed, table_name({}), app_id({}), partition_count({})",
Expand Down Expand Up @@ -458,6 +455,8 @@ private void handleMetaException(error_types err_type, ClusterManager mgr, Strin
case ERR_BUSY_DROPPING:
message = " The table is dropping, please confirm the table name!";
break;
case ERR_SESSION_RESET:
message = " Unable to connect to the meta servers!";
}
throw new ReplicationException(err_type, header + message);
}
Expand Down

0 comments on commit 0619e2c

Please sign in to comment.