Skip to content

Commit 749eff4

Browse files
committed
add log info for ObTableConnectionUnWritableException
1 parent 9fc0583 commit 749eff4

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

src/main/java/com/alipay/oceanbase/rpc/bolt/transport/ObTableConnection.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -259,7 +259,7 @@ public void reConnectAndLogin(String msg) throws ObTableException {
259259
} catch (ObTableServerConnectException ex) {
260260
throw ex;
261261
} catch (Exception ex) {
262-
throw new ObTableConnectionStatusException("check status failed", ex);
262+
throw new ObTableConnectionStatusException("check status failed, cause: " + ex.getMessage(), ex);
263263
}
264264
}
265265

src/main/java/com/alipay/oceanbase/rpc/table/ObTable.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -391,7 +391,7 @@ public ObPayload execute(final ObPayload request) throws RemotingException,
391391
} catch (ObTableServerConnectException ex) {
392392
throw ex;
393393
} catch (Exception ex) {
394-
throw new ObTableConnectionStatusException("check status failed", ex);
394+
throw new ObTableConnectionStatusException("check status failed, cause: " + ex.getMessage(), ex);
395395
}
396396
return executeWithReconnect(connection, request);
397397
}
@@ -455,7 +455,7 @@ public ObPayload executeWithConnection(final ObPayload request,
455455
} catch (ObTableServerConnectException ex) {
456456
throw ex;
457457
} catch (Exception ex) {
458-
throw new ObTableConnectionStatusException("check status failed", ex);
458+
throw new ObTableConnectionStatusException("check status failed, cause: " + ex.getMessage(), ex);
459459
}
460460
return executeWithReconnect(connection, request);
461461
}

0 commit comments

Comments
 (0)