Do not update session if the session in meta is newer.

vesoft-inc · Jun 22, 2021 · dde015e · dde015e
1 parent e4873cc
commit dde015e
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/meta/processors/sessionMan/SessionManagerProcessor.cpp b/src/meta/processors/sessionMan/SessionManagerProcessor.cpp
@@ -84,6 +84,10 @@ void UpdateSessionsProcessor::process(const cpp2::UpdateSessionsReq& req) {
             killedQueries[sessionId] = std::move(killedQueriesInCurrentSession);
         }
 
+        if (sessionInMeta.get_update_time() > session.get_update_time()) {
+            continue;
+        }
+
         data.emplace_back(MetaServiceUtils::sessionKey(sessionId),
                           MetaServiceUtils::sessionVal(session));
     }