You've already forked mariadb-columnstore-engine
mirror of
https://github.com/mariadb-corporation/mariadb-columnstore-engine.git
synced 2025-09-03 23:42:03 +03:00
MCOL-1423
This commit is contained in:
@@ -2846,10 +2846,13 @@ void processMSG(messageqcpp::IOSocket* cfIos)
|
|||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// if a DDLProc was restarted, reinit DMLProc
|
// if a DDLProc was restarted, restart DMLProc
|
||||||
if( processName == "DDLProc") {
|
if( processName == "DDLProc") {
|
||||||
processManager.reinitProcessType("DMLProc");
|
processManager.reinitProcessType("DMLProc");
|
||||||
|
//set query system states ready
|
||||||
processManager.setQuerySystemState(true);
|
processManager.setQuerySystemState(true);
|
||||||
|
|
||||||
|
processManager.setSystemState(oam::ACTIVE);
|
||||||
}
|
}
|
||||||
|
|
||||||
//only run on auto process restart
|
//only run on auto process restart
|
||||||
@@ -2900,6 +2903,8 @@ void processMSG(messageqcpp::IOSocket* cfIos)
|
|||||||
processManager.setQuerySystemState(true);
|
processManager.setQuerySystemState(true);
|
||||||
|
|
||||||
processManager.setSystemState(oam::ACTIVE);
|
processManager.setSystemState(oam::ACTIVE);
|
||||||
|
|
||||||
|
log.writeLog(__LINE__, "MSG RECEIVED: Process Restarted Completed");
|
||||||
}
|
}
|
||||||
break;
|
break;
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user