mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-05-20 06:40:41 -05:00
Code Issues Packages Projects Releases Wiki Activity

[inner-1585] fix NPE

Browse Source
This commit is contained in:
wd2365151147
2022-01-06 13:45:22 +08:00
parent 0df825e281
commit ba293797b5
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/actiontech/dble/backend/mysql/nio/handler/ddl/BaseDDLHandler.java
+1 -1
View File
@@ -238,7 +238,7 @@ public abstract class BaseDDLHandler implements ResponseHandler, ExecutableHandl
err0.setPacketId(shardingService.nextPacketId());
err0.setErrNo(ErrorCode.ER_META_DATA);
String msg = "DDL executed successfully, maybe there's something wrong with update_ddl_metadata or notice_cluster_ddl. You are advised to analyze dble log first, then decide whether to execute 'reload @@metadata'.";
err.setMessage(StringUtil.encode(msg, shardingService.getCharset().getResults()));
err0.setMessage(StringUtil.encode(msg, shardingService.getCharset().getResults()));
packet = err0;
}
QueryResultDispatcher.doSqlStat(rrs, session, 0, netOutBytes, resultSize);
src/main/java/com/actiontech/dble/meta/table/DDLNotifyTableMetaHandler.java
+3 -3
View File
@@ -53,7 +53,7 @@ public class DDLNotifyTableMetaHandler extends AbstractTableMetaHandler {
@Override
public void handlerTableByNode(boolean isSucc, String tableName0, String shardingNode) {
DDLTraceHelper.log2(currShardingService, DDLTraceHelper.Stage.update_ddl_metadata, "In shardingNode[" + shardingNode + "], fetching " + (isSucc ? "success." : "fail"));
DDLTraceHelper.log2(currShardingService, DDLTraceHelper.Stage.update_ddl_metadata, "In shardingNode[" + shardingNode + "], fetching " + (isSucc ? "success" : "fail"));
}
@Override
@@ -61,9 +61,9 @@ public class DDLNotifyTableMetaHandler extends AbstractTableMetaHandler {
if (tableMeta != null) {
ProxyMeta.getInstance().getTmManager().addTable(schema, tableMeta, isCreateSql);
metaInited = true;
DDLTraceHelper.log2(currShardingService, DDLTraceHelper.Stage.update_ddl_metadata, DDLTraceHelper.Status.succ, "Successful to update table[" + schema + "." + tableMeta.getTableName() + "]metadata");
DDLTraceHelper.log2(currShardingService, DDLTraceHelper.Stage.update_ddl_metadata, DDLTraceHelper.Status.succ, "Successful to update table[" + schema + "." + tableMeta.getTableName() + "]’s metadata");
} else {
DDLTraceHelper.log2(currShardingService, DDLTraceHelper.Stage.update_ddl_metadata, DDLTraceHelper.Status.fail, "Failed to update table[" + schema + "." + tableName + "]metadata");
DDLTraceHelper.log2(currShardingService, DDLTraceHelper.Stage.update_ddl_metadata, DDLTraceHelper.Status.fail, "Failed to update table[" + schema + "." + tableName + "]’s metadata");
}
signalDone();
}