You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
24/03/05 03:19:43 INFO FlintREPL: Updated job: {"jobid": 00fhhv3f7tqslo0a, "sessionId": dDllcU1BSGxOZW15czM=} from .query_execution_request_mys3
24/03/05 03:19:43 INFO FlintREPL: read from .query_execution_request_mys3, sessionId: dDllcU1BSGxOZW15czM=
...
24/03/05 03:19:44 INFO FlintREPL: Shutting down REPL
What is the expected behavior?
index state is update to "dead" or "fail"
add more log if getResponse is empty or source is empty
shutdownHookManager.addShutdownHook(() => {
logInfo("Shutting down REPL")
val getResponse = osClient.getDoc(sessionIndex, sessionId)
if (!getResponse.isExists()) {
return
}
val source = getResponse.getSourceAsMap
if (source == null) {
return
}
val state = Option(source.get("state")).map(_.asInstanceOf[String])
if (!earlyExitFlag && state.isDefined && state.get != "dead" && state.get != "fail") {
updateFlintInstanceBeforeShutdown(
source,
getResponse,
flintSessionIndexUpdater,
sessionId,
sessionTimerContext)
}
})
The text was updated successfully, but these errors were encountered:
What is the bug?
What is the expected behavior?
The text was updated successfully, but these errors were encountered: