diff --git a/.github/workflows/gss.yml b/.github/workflows/gss.yml
index 5bf0558997ff..ffd550578596 100644
--- a/.github/workflows/gss.yml
+++ b/.github/workflows/gss.yml
@@ -79,6 +79,8 @@ jobs:
         . ${HOME}/.graphscope_env
         export SCCACHE_DIR=~/.cache/sccache
         export RUSTC_WRAPPER=/usr/local/bin/sccache
+        rustup toolchain install 1.81.0
+        rustup default 1.81.0
         cd ${GITHUB_WORKSPACE}/interactive_engine
         mvn clean install -P groot -Drust.compile.mode=debug -DskipTests --quiet
         mvn clean install -Pgroot-data-load --quiet
diff --git a/.github/workflows/k8s-ci.yml b/.github/workflows/k8s-ci.yml
index 2eff66e0a1af..66d6909d6b7d 100644
--- a/.github/workflows/k8s-ci.yml
+++ b/.github/workflows/k8s-ci.yml
@@ -282,6 +282,12 @@ jobs:
           ~/.cache/sccache
         key: ${{ runner.os }}-cargo-${{ hashFiles('**/Cargo.lock') }}
 
+    - name: Install Rust
+      uses: actions-rs/toolchain@v1
+      with:
+        toolchain: 1.81.0
+        override: true
+
     - name: Build Artifact
       run: |
         . ${HOME}/.graphscope_env
@@ -640,6 +646,12 @@ jobs:
             ~/.cache/sccache
           key: ${{ runner.os }}-cargo-${{ hashFiles('**/Cargo.lock') }}
 
+      - name: Install Rust
+        uses: actions-rs/toolchain@v1
+        with:
+          toolchain: 1.81.0
+          override: true
+
       - name: Build GIE Experimental Artifacts
         run: |
           . ~/.graphscope_env
diff --git a/.github/workflows/pr-check.yml b/.github/workflows/pr-check.yml
index 7f59f2182263..a66be7b6d96c 100644
--- a/.github/workflows/pr-check.yml
+++ b/.github/workflows/pr-check.yml
@@ -213,11 +213,15 @@ jobs:
         python3 -m black --check --diff .
         python3 -m flake8 .
         popd
-        pushd flex/interactive/sdk/python
+        # we need to generate the code first
+        pushd flex/interactive/sdk
+        bash generate_sdk.sh -g python
+        pushd python
         python3 -m isort --check --diff .
         python3 -m black --check --diff .
         python3 -m flake8 .
         popd
+        popd
 
     - name: Generate Docs
       shell: bash
diff --git a/docs/zh/frequently_asked_questions.rst b/docs/zh/frequently_asked_questions.rst
index 66be7aefef79..f0428aa941b4 100644
--- a/docs/zh/frequently_asked_questions.rst
+++ b/docs/zh/frequently_asked_questions.rst
@@ -69,7 +69,7 @@
 
     - ``vineyard_shared_mem``: 存储数据集的内存。我们发现将其设置为数据集在磁盘上的大小的 5 倍通常是一个合理的值。 它相当于 graphscope 的 helm chart 中的 ``vineyard.shared_mem``。
 
-    - ``k8s_engine_mem`: ``engine`` 容器的内存大小。一般将其设置为 ``vineyard_shared_mem`` 的同样大小。它相当于 graphscope 的 helm chart 中的 ``engines.resources.memory.requests`` 和 ``engines.resources.memory.requests``。
+    - ``k8s_engine_mem``: ``engine`` 容器的内存大小。一般将其设置为 ``vineyard_shared_mem`` 的同样大小。它相当于 graphscope 的 helm chart 中的 ``engines.resources.memory.requests`` 和 ``engines.resources.memory.requests``。
 
 10. 导致在 Apple M1 python3.8 环境下安装 GraphScope 失败的原因可能有哪些？
 
diff --git a/flex/engines/graph_db/runtime/adhoc/expr_impl.cc b/flex/engines/graph_db/runtime/adhoc/expr_impl.cc
index b965f6045fcf..50618aebdf04 100644
--- a/flex/engines/graph_db/runtime/adhoc/expr_impl.cc
+++ b/flex/engines/graph_db/runtime/adhoc/expr_impl.cc
@@ -207,6 +207,9 @@ RTAny UnaryLogicalExpr::eval_edge(const LabelTriplet& label, vid_t src,
   if (logic_ == common::Logical::NOT) {
     return RTAny::from_bool(
         !expr_->eval_edge(label, src, dst, data, idx).as_bool());
+  } else if (logic_ == common::Logical::ISNULL) {
+    return RTAny::from_bool(
+        expr_->eval_edge(label, src, dst, data, idx, 0).is_null());
   }
   LOG(FATAL) << "not support" << static_cast<int>(logic_);
   return RTAny::from_bool(false);
diff --git a/flex/engines/graph_db/runtime/adhoc/expr_impl.h b/flex/engines/graph_db/runtime/adhoc/expr_impl.h
index 20a764de0696..91046e31e19c 100644
--- a/flex/engines/graph_db/runtime/adhoc/expr_impl.h
+++ b/flex/engines/graph_db/runtime/adhoc/expr_impl.h
@@ -85,17 +85,23 @@ class WithInExpr : public ExprBase {
   WithInExpr(const ReadTransaction& txn, const Context& ctx,
              std::unique_ptr<ExprBase>&& key, const common::Value& array)
       : key_(std::move(key)) {
-    if constexpr (std::is_same_v<T, int64_t>) {
-      CHECK(array.item_case() == common::Value::kI64Array);
-      size_t len = array.i64_array().item_size();
-      for (size_t idx = 0; idx < len; ++idx) {
-        container_.push_back(array.i64_array().item(idx));
-      }
-    } else if constexpr (std::is_same_v<T, int32_t>) {
-      CHECK(array.item_case() == common::Value::kI32Array);
-      size_t len = array.i32_array().item_size();
-      for (size_t idx = 0; idx < len; ++idx) {
-        container_.push_back(array.i32_array().item(idx));
+    if constexpr ((std::is_same_v<T, int64_t>) ||
+                  (std::is_same_v<T, int32_t>) ) {
+      // Implicitly convert to T
+      if (array.item_case() == common::Value::kI64Array) {
+        size_t len = array.i64_array().item_size();
+        for (size_t idx = 0; idx < len; ++idx) {
+          container_.push_back(array.i64_array().item(idx));
+        }
+      } else if (array.item_case() == common::Value::kI32Array) {
+        size_t len = array.i32_array().item_size();
+        for (size_t idx = 0; idx < len; ++idx) {
+          container_.push_back(array.i32_array().item(idx));
+        }
+      } else {
+        LOG(FATAL) << "Fail to construct WithInExpr of type "
+                   << typeid(T).name() << " with array of type "
+                   << array.item_case();
       }
     } else if constexpr (std::is_same_v<T, std::string>) {
       CHECK(array.item_case() == common::Value::kStrArray);
diff --git a/flex/engines/graph_db/runtime/adhoc/operators/group_by.cc b/flex/engines/graph_db/runtime/adhoc/operators/group_by.cc
index 14f070759c1e..20cff565f700 100644
--- a/flex/engines/graph_db/runtime/adhoc/operators/group_by.cc
+++ b/flex/engines/graph_db/runtime/adhoc/operators/group_by.cc
@@ -413,6 +413,29 @@ std::shared_ptr<IContextColumn> string_to_list(
   return builder.finish();
 }
 
+template <typename T>
+std::shared_ptr<IContextColumn> scalar_to_list(
+    const Var& var, const std::vector<std::vector<size_t>>& to_aggregate) {
+  ListValueColumnBuilder<T> builder;
+  size_t col_size = to_aggregate.size();
+  builder.reserve(col_size);
+  std::vector<std::shared_ptr<ListImplBase>> impls;
+  for (size_t k = 0; k < col_size; ++k) {
+    auto& vec = to_aggregate[k];
+
+    std::vector<T> elem;
+    for (auto idx : vec) {
+      elem.push_back(TypedConverter<T>::to_typed(var.get(idx)));
+    }
+    auto impl = ListImpl<T>::make_list_impl(std::move(elem));
+    auto list = List::make_list(impl);
+    impls.emplace_back(impl);
+    builder.push_back_opt(list);
+  }
+  builder.set_list_impls(impls);
+  return builder.finish();
+}
+
 bl::result<std::shared_ptr<IContextColumn>> apply_reduce(
     const AggFunc& func, const std::vector<std::vector<size_t>>& to_aggregate) {
   if (func.aggregate == AggrKind::kSum) {
@@ -497,6 +520,14 @@ bl::result<std::shared_ptr<IContextColumn>> apply_reduce(
       return tuple_to_list(var, to_aggregate);
     } else if (var.type() == RTAnyType::kStringValue) {
       return string_to_list(var, to_aggregate);
+    } else if (var.type() == RTAnyType::kI32Value) {
+      return scalar_to_list<int32_t>(var, to_aggregate);
+    } else if (var.type() == RTAnyType::kI64Value) {
+      return scalar_to_list<int64_t>(var, to_aggregate);
+    } else if (var.type() == RTAnyType::kU64Value) {
+      return scalar_to_list<uint64_t>(var, to_aggregate);
+    } else if (var.type() == RTAnyType::kF64Value) {
+      return scalar_to_list<double>(var, to_aggregate);
     } else {
       LOG(FATAL) << "not support" << static_cast<int>(var.type().type_enum_);
     }
diff --git a/flex/engines/graph_db/runtime/common/operators/scan.cc b/flex/engines/graph_db/runtime/common/operators/scan.cc
index 9b260008cd71..d61e3fd776ae 100644
--- a/flex/engines/graph_db/runtime/common/operators/scan.cc
+++ b/flex/engines/graph_db/runtime/common/operators/scan.cc
@@ -47,11 +47,10 @@ bl::result<Context> Scan::find_vertex_with_id(const ReadTransaction& txn,
     }
     if (GlobalId::get_label_id(gid) == label) {
       vid = GlobalId::get_vid(gid);
+      builder.push_back_opt(vid);
     } else {
       LOG(ERROR) << "Global id " << gid << " does not match label " << label;
-      return Context();
     }
-    builder.push_back_opt(vid);
     Context ctx;
     ctx.set(alias, builder.finish());
     return ctx;
diff --git a/flex/engines/graph_db/runtime/common/rt_any.cc b/flex/engines/graph_db/runtime/common/rt_any.cc
index c2f60da57346..fc63a4d00dd3 100644
--- a/flex/engines/graph_db/runtime/common/rt_any.cc
+++ b/flex/engines/graph_db/runtime/common/rt_any.cc
@@ -132,6 +132,8 @@ RTAny::RTAny(const Any& val) {
   } else if (val.type == PropertyType::Bool()) {
     type_ = RTAnyType::kBoolValue;
     value_.b_val = val.AsBool();
+  } else if (val.type == PropertyType::Empty()) {
+    type_ = RTAnyType::kNull;
   } else {
     LOG(FATAL) << "Any value: " << val.to_string()
                << ", type = " << val.type.type_enum;
@@ -368,6 +370,8 @@ std::string_view RTAny::as_string() const {
     return value_.str_val;
   } else if (type_ == RTAnyType::kUnknown) {
     return std::string_view();
+  } else if (type_ == RTAnyType::kNull) {
+    return std::string_view();
   } else {
     LOG(FATAL) << "unexpected type" << static_cast<int>(type_.type_enum_);
     return std::string_view();
diff --git a/flex/engines/graph_db/runtime/common/rt_any.h b/flex/engines/graph_db/runtime/common/rt_any.h
index cc5371e4005f..3b73f06e3998 100644
--- a/flex/engines/graph_db/runtime/common/rt_any.h
+++ b/flex/engines/graph_db/runtime/common/rt_any.h
@@ -420,6 +420,7 @@ class ListImpl : ListImplBase {
   static std::shared_ptr<ListImplBase> make_list_impl(std::vector<T>&& vals) {
     auto new_list = new ListImpl<T>();
     new_list->list_ = std::move(vals);
+    new_list->is_valid_.resize(new_list->list_.size(), true);
     return std::shared_ptr<ListImplBase>(static_cast<ListImplBase*>(new_list));
   }
 
diff --git a/flex/engines/http_server/handler/graph_db_http_handler.cc b/flex/engines/http_server/handler/graph_db_http_handler.cc
index 319920459058..4ff8c9e540ff 100644
--- a/flex/engines/http_server/handler/graph_db_http_handler.cc
+++ b/flex/engines/http_server/handler/graph_db_http_handler.cc
@@ -176,7 +176,7 @@ class stored_proc_handler : public StoppableHandler {
 
   bool start() override {
     if (get_executors()[StoppableHandler::shard_id()].size() > 0) {
-      LOG(ERROR) << "The actors have been already created!";
+      VLOG(10) << "The actors have been already created!";
       return false;
     }
     return StoppableHandler::start_scope(
diff --git a/flex/engines/http_server/handler/graph_db_http_handler.h b/flex/engines/http_server/handler/graph_db_http_handler.h
index 6bc5c906910e..22090e66dc41 100644
--- a/flex/engines/http_server/handler/graph_db_http_handler.h
+++ b/flex/engines/http_server/handler/graph_db_http_handler.h
@@ -69,7 +69,7 @@ class StoppableHandler : public seastar::httpd::handler_base {
           } catch (const std::exception& e) {
             // In case the scope is already cancelled, we should ignore the
             // exception.
-            LOG(INFO) << "Failed to cancel IC scope: " << e.what();
+            VLOG(1) << "Failed to cancel IC scope: " << e.what();
           }
           func();
           return seastar::make_ready_future<>();
diff --git a/flex/interactive/sdk/python/gs_interactive/client/result.py b/flex/interactive/sdk/python/gs_interactive/client/result.py
index f5aea2b6417f..79ec0d126bb5 100644
--- a/flex/interactive/sdk/python/gs_interactive/client/result.py
+++ b/flex/interactive/sdk/python/gs_interactive/client/result.py
@@ -20,9 +20,8 @@
 from typing import TypeVar
 
 from gs_interactive.api_response import ApiResponse
-from gs_interactive.exceptions import ApiException
-
 from gs_interactive.client.status import Status
+from gs_interactive.exceptions import ApiException
 
 # Define a generic type placeholder
 T = TypeVar("T")
diff --git a/flex/interactive/sdk/python/gs_interactive/client/session.py b/flex/interactive/sdk/python/gs_interactive/client/session.py
index 96da79ed7007..95ff753502a2 100644
--- a/flex/interactive/sdk/python/gs_interactive/client/session.py
+++ b/flex/interactive/sdk/python/gs_interactive/client/session.py
@@ -23,6 +23,11 @@
 from typing import Optional
 from typing import Union
 
+from pydantic import Field
+from pydantic import StrictBytes
+from pydantic import StrictStr
+from typing_extensions import Annotated
+
 from gs_interactive.api import AdminServiceGraphManagementApi
 from gs_interactive.api import AdminServiceJobManagementApi
 from gs_interactive.api import AdminServiceProcedureManagementApi
@@ -32,18 +37,13 @@
 from gs_interactive.api import QueryServiceApi
 from gs_interactive.api import UtilsApi
 from gs_interactive.api_client import ApiClient
-from gs_interactive.configuration import Configuration
-from pydantic import Field
-from pydantic import StrictBytes
-from pydantic import StrictStr
-from typing_extensions import Annotated
-
 from gs_interactive.client.generated.results_pb2 import CollectiveResults
 from gs_interactive.client.result import Result
 from gs_interactive.client.status import Status
 from gs_interactive.client.status import StatusCode
 from gs_interactive.client.utils import InputFormat
 from gs_interactive.client.utils import append_format_byte
+from gs_interactive.configuration import Configuration
 from gs_interactive.models import CreateGraphRequest
 from gs_interactive.models import CreateGraphResponse
 from gs_interactive.models import CreateProcedureRequest
diff --git a/flex/interactive/sdk/python/gs_interactive/client/status.py b/flex/interactive/sdk/python/gs_interactive/client/status.py
index 13af0e0ed660..26745c230f5f 100644
--- a/flex/interactive/sdk/python/gs_interactive/client/status.py
+++ b/flex/interactive/sdk/python/gs_interactive/client/status.py
@@ -16,15 +16,16 @@
 # limitations under the License.
 #
 
+from urllib3.exceptions import MaxRetryError
+from urllib3.exceptions import ProtocolError
+
 from gs_interactive.api_response import ApiResponse
+from gs_interactive.client.generated.interactive_pb2 import Code as StatusCode
 from gs_interactive.exceptions import ApiException
 from gs_interactive.exceptions import BadRequestException
 from gs_interactive.exceptions import ForbiddenException
 from gs_interactive.exceptions import NotFoundException
 from gs_interactive.exceptions import ServiceException
-from urllib3.exceptions import MaxRetryError
-
-from gs_interactive.client.generated.interactive_pb2 import Code as StatusCode
 from gs_interactive.models.api_response_with_code import APIResponseWithCode
 
 
@@ -108,6 +109,8 @@ def from_exception(exception: ApiException):
                 return Status(StatusCode.INTERNAL_ERROR, exception.body)
         elif isinstance(exception, MaxRetryError):
             return Status(StatusCode.INTERNAL_ERROR, exception)
+        elif isinstance(exception, ProtocolError):
+            return Status(StatusCode.INTERNAL_ERROR, exception)
         return Status(
             StatusCode.UNKNOWN, "Unknown Error from exception " + exception.body
         )
diff --git a/flex/interactive/sdk/python/gs_interactive/tests/conftest.py b/flex/interactive/sdk/python/gs_interactive/tests/conftest.py
index 94f0b34a25f2..3617115b4740 100644
--- a/flex/interactive/sdk/python/gs_interactive/tests/conftest.py
+++ b/flex/interactive/sdk/python/gs_interactive/tests/conftest.py
@@ -17,6 +17,7 @@
 #
 
 # get the directory of the current file
+import copy
 import os
 import time
 
@@ -27,6 +28,7 @@
 from gs_interactive.client.session import Session
 from gs_interactive.models import CreateGraphRequest
 from gs_interactive.models import CreateProcedureRequest
+from gs_interactive.models import GetGraphSchemaResponse
 from gs_interactive.models import SchemaMapping
 from gs_interactive.models import StartServiceRequest
 from gs_interactive.models import UpdateProcedureRequest
@@ -39,7 +41,7 @@
 
 
 modern_graph_full = {
-    "name": "modern_graph",
+    "name": "full_graph",
     "description": "This is a test graph",
     "schema": {
         "vertex_types": [
@@ -120,7 +122,7 @@
 }
 
 modern_graph_vertex_only = {
-    "name": "modern_graph",
+    "name": "vertex_only",
     "description": "This is a test graph, only contains vertex",
     "schema": {
         "vertex_types": [
@@ -148,7 +150,7 @@
 }
 
 modern_graph_partial = {
-    "name": "modern_graph",
+    "name": "partial_graph",
     "description": "This is a test graph",
     "schema": {
         "vertex_types": [
@@ -336,7 +338,7 @@ def create_partial_modern_graph(interactive_session):
 
 @pytest.fixture(scope="function")
 def create_graph_with_custom_pk_name(interactive_session):
-    modern_graph_custom_pk_name = modern_graph_full.copy()
+    modern_graph_custom_pk_name = copy.deepcopy(modern_graph_full)
     for vertex_type in modern_graph_custom_pk_name["schema"]["vertex_types"]:
         vertex_type["properties"][0]["property_name"] = "custom_id"
         vertex_type["primary_keys"] = ["custom_id"]
@@ -479,3 +481,24 @@ def start_service_on_graph(interactive_session, graph_id: str):
     assert resp.is_ok()
     # wait three second to let compiler get the new graph
     time.sleep(3)
+
+
+def ensure_compiler_schema_ready(
+    interactive_session, neo4j_session: Neo4jSession, graph_id: str
+):
+    rel_graph_meta = interactive_session.get_graph_schema(graph_id).get_value()
+    max_times = 10
+    while True:
+        if max_times == 0:
+            raise Exception("compiler schema is not ready")
+        res = neo4j_session.run("CALL gs.procedure.meta.schema();")
+        val = res.single().value()
+        compiler_graph_schema = GetGraphSchemaResponse.from_json(val)
+        # print("compiler_graph_schema: ", compiler_graph_schema)
+        # print("rel_graph_meta: ", rel_graph_meta)
+        if compiler_graph_schema == rel_graph_meta:
+            break
+        print("compiler schema is not ready, wait for 1 second")
+        time.sleep(1)
+        max_times -= 1
+    print("compiler schema is ready")
diff --git a/flex/interactive/sdk/python/gs_interactive/tests/test_robustness.py b/flex/interactive/sdk/python/gs_interactive/tests/test_robustness.py
index a144a1e07948..2fb50d138f4e 100644
--- a/flex/interactive/sdk/python/gs_interactive/tests/test_robustness.py
+++ b/flex/interactive/sdk/python/gs_interactive/tests/test_robustness.py
@@ -27,6 +27,7 @@
 from gs_interactive.tests.conftest import call_procedure  # noqa: E402
 from gs_interactive.tests.conftest import create_procedure
 from gs_interactive.tests.conftest import delete_procedure
+from gs_interactive.tests.conftest import ensure_compiler_schema_ready
 from gs_interactive.tests.conftest import import_data_to_full_modern_graph
 from gs_interactive.tests.conftest import import_data_to_partial_modern_graph
 from gs_interactive.tests.conftest import import_data_to_vertex_only_modern_graph
@@ -61,6 +62,9 @@ def test_query_on_vertex_only_graph(
     """
     print("[Query on vertex only graph]")
     start_service_on_graph(interactive_session, create_vertex_only_modern_graph)
+    ensure_compiler_schema_ready(
+        interactive_session, neo4j_session, create_vertex_only_modern_graph
+    )
     run_cypher_test_suite(
         neo4j_session, create_vertex_only_modern_graph, vertex_only_cypher_queries
     )
@@ -69,6 +73,10 @@ def test_query_on_vertex_only_graph(
     import_data_to_vertex_only_modern_graph(
         interactive_session, create_vertex_only_modern_graph
     )
+    start_service_on_graph(interactive_session, create_vertex_only_modern_graph)
+    ensure_compiler_schema_ready(
+        interactive_session, neo4j_session, create_vertex_only_modern_graph
+    )
     run_cypher_test_suite(
         neo4j_session, create_vertex_only_modern_graph, vertex_only_cypher_queries
     )
@@ -83,12 +91,19 @@ def test_query_on_partial_graph(
     print("[Query on partial graph]")
     # start service on new graph
     start_service_on_graph(interactive_session, create_partial_modern_graph)
+    ensure_compiler_schema_ready(
+        interactive_session, neo4j_session, create_partial_modern_graph
+    )
     # try to query on the graph
     run_cypher_test_suite(neo4j_session, create_partial_modern_graph, cypher_queries)
     start_service_on_graph(interactive_session, "1")
     import_data_to_partial_modern_graph(
         interactive_session, create_partial_modern_graph
     )
+    start_service_on_graph(interactive_session, create_partial_modern_graph)
+    ensure_compiler_schema_ready(
+        interactive_session, neo4j_session, create_partial_modern_graph
+    )
     run_cypher_test_suite(neo4j_session, create_partial_modern_graph, cypher_queries)
 
 
@@ -100,10 +115,17 @@ def test_query_on_full_modern_graph(
     """
     print("[Query on full modern graph]")
     start_service_on_graph(interactive_session, create_modern_graph)
+    ensure_compiler_schema_ready(
+        interactive_session, neo4j_session, create_modern_graph
+    )
     # try to query on the graph
     run_cypher_test_suite(neo4j_session, create_modern_graph, cypher_queries)
     start_service_on_graph(interactive_session, "1")
     import_data_to_full_modern_graph(interactive_session, create_modern_graph)
+    start_service_on_graph(interactive_session, create_modern_graph)
+    ensure_compiler_schema_ready(
+        interactive_session, neo4j_session, create_modern_graph
+    )
     run_cypher_test_suite(neo4j_session, create_modern_graph, cypher_queries)
 
 
@@ -129,6 +151,9 @@ def test_service_switching(
     )
     print("Procedure id: ", a_proc_id)
     start_service_on_graph(interactive_session, create_modern_graph)
+    ensure_compiler_schema_ready(
+        interactive_session, neo4j_session, create_modern_graph
+    )
     call_procedure(neo4j_session, create_modern_graph, a_proc_id)
 
     # create procedure on graph_b_id
@@ -139,6 +164,9 @@ def test_service_switching(
         "MATCH(n: person) return count(n);",
     )
     start_service_on_graph(interactive_session, create_vertex_only_modern_graph)
+    ensure_compiler_schema_ready(
+        interactive_session, neo4j_session, create_vertex_only_modern_graph
+    )
     call_procedure(neo4j_session, create_vertex_only_modern_graph, b_proc_id)
 
 
@@ -156,6 +184,9 @@ def test_procedure_creation(interactive_session, neo4j_session, create_modern_gr
     )
     print("Procedure id: ", a_proc_id)
     start_service_on_graph(interactive_session, create_modern_graph)
+    ensure_compiler_schema_ready(
+        interactive_session, neo4j_session, create_modern_graph
+    )
     call_procedure(neo4j_session, create_modern_graph, a_proc_id)
 
     # create procedure with name containing space,
@@ -202,6 +233,9 @@ def test_builtin_procedure(interactive_session, neo4j_session, create_modern_gra
         )
     # Call the builtin procedure
     start_service_on_graph(interactive_session, create_modern_graph)
+    ensure_compiler_schema_ready(
+        interactive_session, neo4j_session, create_modern_graph
+    )
     call_procedure(
         neo4j_session,
         create_modern_graph,
@@ -259,6 +293,10 @@ def test_list_jobs(interactive_session, create_vertex_only_modern_graph):
 def test_call_proc_in_cypher(interactive_session, neo4j_session, create_modern_graph):
     print("[Test call procedure in cypher]")
     import_data_to_full_modern_graph(interactive_session, create_modern_graph)
+    start_service_on_graph(interactive_session, create_modern_graph)
+    ensure_compiler_schema_ready(
+        interactive_session, neo4j_session, create_modern_graph
+    )
     result = neo4j_session.run(
         'MATCH(p: person) with p.id as oid CALL k_neighbors("person", oid, 1) return label_name, vertex_oid;'
     )
@@ -276,6 +314,9 @@ def test_custom_pk_name(
         interactive_session, create_graph_with_custom_pk_name
     )
     start_service_on_graph(interactive_session, create_graph_with_custom_pk_name)
+    ensure_compiler_schema_ready(
+        interactive_session, neo4j_session, create_graph_with_custom_pk_name
+    )
     result = neo4j_session.run(
         "MATCH (n: person) where n.custom_id = 4 return n.custom_id;"
     )
@@ -289,4 +330,3 @@ def test_custom_pk_name(
     )
     records = result.fetch(1)
     assert len(records) == 1 and records[0]["$f0"] == 2
-    start_service_on_graph(interactive_session, "1")
diff --git a/flex/interactive/sdk/python/setup.cfg b/flex/interactive/sdk/python/setup.cfg
index 1e1839250158..255781291114 100644
--- a/flex/interactive/sdk/python/setup.cfg
+++ b/flex/interactive/sdk/python/setup.cfg
@@ -3,7 +3,7 @@ profile = black
 ensure_newline_before_comments = True
 line_length = 88
 force_single_line = True
-skip = build/,dist/,gs_interactive/api/,gs_interactive/api_response.py,gs_interactive/configuration.py,gs_interactive/exceptions.py,gs_interactive/models/,gs_interactiverest.py,
+skip = build/,dist/,gs_interactive/api/,gs_interactive/api_response.py,gs_interactive/configuration.py,gs_interactive/exceptions.py,gs_interactive/models/,gs_interactiverest.py,gs_interactive/api_client.py,gs_interactive/__init__.py,gs_interactive/rest.py
 skip_glob = *_pb2.py,*_pb2_grpc.py,build/*
 
 [flake8]
diff --git a/flex/storages/metadata/local_file_metadata_store.cc b/flex/storages/metadata/local_file_metadata_store.cc
index 5f77d0cc2e7a..bcff4bf4ed38 100644
--- a/flex/storages/metadata/local_file_metadata_store.cc
+++ b/flex/storages/metadata/local_file_metadata_store.cc
@@ -181,8 +181,8 @@ Result<bool> LocalFileMetadataStore::UpdateMeta(const meta_kind_t& meta_kind,
 
 Result<LocalFileMetadataStore::meta_key_t>
 LocalFileMetadataStore::get_next_meta_key(
-    const LocalFileMetadataStore::meta_kind_t& meta_kind) const {
-  return std::to_string(get_max_id(meta_kind) + 1);
+    const LocalFileMetadataStore::meta_kind_t& meta_kind) {
+  return std::to_string(increase_and_get_id(meta_kind));
 }
 
 std::string LocalFileMetadataStore::get_root_meta_dir() const {
@@ -208,29 +208,38 @@ std::string LocalFileMetadataStore::get_meta_file(const meta_kind_t& meta_kind,
   return ret;
 }
 
-int32_t LocalFileMetadataStore::get_max_id(const meta_kind_t& meta_kind) const {
-  // iterate all files in the directory, get the max id.
-  int max_id_ = 0;
+// Guarded by meta_mutex_ outside.
+int32_t LocalFileMetadataStore::increase_and_get_id(
+    const meta_kind_t& meta_kind) {
   auto dir = get_meta_kind_dir(meta_kind);
-  for (auto& p : std::filesystem::directory_iterator(dir)) {
-    if (std::filesystem::is_directory(p)) {
-      continue;
-    }
-    auto file_name = p.path().filename().string();
-    if (file_name.find(META_FILE_PREFIX) != std::string::npos) {
-      auto id_str = file_name.substr(strlen(META_FILE_PREFIX));
-      int32_t id;
-      try {
-        id = std::stoi(id_str);
-      } catch (std::invalid_argument& e) {
-        LOG(ERROR) << "Invalid id: " << id_str;
-        continue;
-      }
-      if (id > max_id_) {
-        max_id_ = id;
-      }
+  int max_id_ = 0;
+  // In the directory, we expect a file with name CUR_ID_FILE_NAME.
+  // If the file does not exist, we will create one with content "0".
+  auto cur_id_file = dir + "/" + CUR_ID_FILE_NAME;
+  if (!std::filesystem::exists(cur_id_file)) {
+    std::ofstream out_file(cur_id_file);
+    if (!out_file.is_open()) {
+      LOG(ERROR) << "Failed to create file: " << cur_id_file;
+      return -1;
     }
+    out_file << "0";
+    out_file.close();
+  }
+  std::ifstream in_file(cur_id_file);
+  if (!in_file.is_open()) {
+    LOG(ERROR) << "Failed to open file: " << cur_id_file;
+    return -1;
   }
+  in_file >> max_id_;
+  in_file.close();
+  max_id_++;
+  std::ofstream out_file(cur_id_file);
+  if (!out_file.is_open()) {
+    LOG(ERROR) << "Failed to open file: " << cur_id_file;
+    return -1;
+  }
+  out_file << max_id_;
+  out_file.close();
   return max_id_;
 }
 
diff --git a/flex/storages/metadata/local_file_metadata_store.h b/flex/storages/metadata/local_file_metadata_store.h
index 186aa68e7efd..bada3778d535 100644
--- a/flex/storages/metadata/local_file_metadata_store.h
+++ b/flex/storages/metadata/local_file_metadata_store.h
@@ -48,6 +48,7 @@ class LocalFileMetadataStore : public IMetaStore {
 
   static constexpr const char* METADATA_DIR = "METADATA";
   static constexpr const char* META_FILE_PREFIX = "META_";
+  static constexpr const char* CUR_ID_FILE_NAME = "CUR_ID";
 
   LocalFileMetadataStore(const std::string& path);
 
@@ -110,12 +111,15 @@ class LocalFileMetadataStore : public IMetaStore {
                           update_func_t update_func) override;
 
  private:
-  Result<meta_key_t> get_next_meta_key(const meta_kind_t& meta_kind) const;
+  Result<meta_key_t> get_next_meta_key(const meta_kind_t& meta_kind);
   std::string get_root_meta_dir() const;
   std::string get_meta_kind_dir(const meta_kind_t& meta_kind) const;
   std::string get_meta_file(const meta_kind_t& meta_kind,
                             const meta_key_t& meta_key) const;
-  int32_t get_max_id(const meta_kind_t& meta_kind) const;
+  /**
+   * For the specified meta_kind, increase the id and return the new id.
+   */
+  int32_t increase_and_get_id(const meta_kind_t& meta_kind);
   bool is_key_exist(const meta_kind_t& meta_kind,
                     const meta_key_t& meta_key) const;
 
diff --git a/flex/tests/hqps/hqps_robust_test.sh b/flex/tests/hqps/hqps_robust_test.sh
index 8090d8be8164..af21a57459ac 100644
--- a/flex/tests/hqps/hqps_robust_test.sh
+++ b/flex/tests/hqps/hqps_robust_test.sh
@@ -82,7 +82,7 @@ start_engine_service(){
     fi
 
     cmd="${SERVER_BIN} -c ${config_path} --enable-admin-service true "
-    cmd="${cmd}  -w ${INTERACTIVE_WORKSPACE} --start-compiler true &"
+    cmd="${cmd}  -w ${INTERACTIVE_WORKSPACE} --start-compiler true > /tmp/engine.log 2>&1 & "
 
     echo "Start engine service with command: ${cmd}"
     eval ${cmd} 
diff --git a/flex/tests/hqps/interactive_config_test.yaml b/flex/tests/hqps/interactive_config_test.yaml
index 0e1f9f15ed21..6013b0079d90 100644
--- a/flex/tests/hqps/interactive_config_test.yaml
+++ b/flex/tests/hqps/interactive_config_test.yaml
@@ -5,7 +5,7 @@ compute_engine:
   type: hiactor
   workers:
     - localhost:10000
-  thread_num_per_worker: 1
+  thread_num_per_worker: 4
   store:
     type: cpp-mcsr
   metadata_store:
@@ -26,6 +26,7 @@ compiler:
       statistics:
         uri: http://localhost:7777/v1/graph/%s/statistics
         interval: 86400000 # ms
+      timeout: 1000 # ms
   endpoint:
     default_listen_address: localhost
     bolt_connector:
diff --git a/flex/utils/yaml_utils.cc b/flex/utils/yaml_utils.cc
index 775c4245ea2a..3c36a0e85535 100644
--- a/flex/utils/yaml_utils.cc
+++ b/flex/utils/yaml_utils.cc
@@ -52,12 +52,20 @@ void convert_yaml_node_to_json(const YAML::Node& node,
         json.SetInt(node.as<int>());
       } catch (const YAML::BadConversion& e) {
         try {
-          json.SetDouble(node.as<double>());
+          json.SetInt64(node.as<int64_t>());
         } catch (const YAML::BadConversion& e) {
           try {
-            json.SetBool(node.as<bool>());
+            json.SetUint64(node.as<uint64_t>());
           } catch (const YAML::BadConversion& e) {
-            json.SetString(node.as<std::string>().c_str(), allocator);
+            try {
+              json.SetDouble(node.as<double>());
+            } catch (const YAML::BadConversion& e) {
+              try {
+                json.SetBool(node.as<bool>());
+              } catch (const YAML::BadConversion& e) {
+                json.SetString(node.as<std::string>().c_str(), allocator);
+              }
+            }
           }
         }
       }
diff --git a/interactive_engine/compiler/conf/ir.compiler.properties b/interactive_engine/compiler/conf/ir.compiler.properties
index 992f828a2b2e..2ab6058f579c 100644
--- a/interactive_engine/compiler/conf/ir.compiler.properties
+++ b/interactive_engine/compiler/conf/ir.compiler.properties
@@ -68,5 +68,8 @@ calcite.default.charset: UTF-8
 # set the interval in milliseconds to fetch graph schema
 # graph.meta.schema.fetch.interval.ms: 1000
 
-# set the timeout in milliseconds to fetch graph statistics
+# set the interval in milliseconds to fetch graph statistics
 # graph.meta.statistics.fetch.interval.ms: 86400000l
+
+# set the timeout in milliseconds to fetch graph statistics
+# graph.meta.fetch.timeout.ms: 1000
diff --git a/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/config/GraphConfig.java b/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/config/GraphConfig.java
index 9ab065f61366..74a7086599bc 100644
--- a/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/config/GraphConfig.java
+++ b/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/config/GraphConfig.java
@@ -31,6 +31,9 @@ public class GraphConfig {
     public static final Config<Long> GRAPH_META_STATISTICS_FETCH_INTERVAL_MS =
             Config.longConfig("graph.meta.statistics.fetch.interval.ms", 24 * 3600 * 1000l);
 
+    public static final Config<Long> GRAPH_META_FETCH_TIMEOUT_MS =
+            Config.longConfig("graph.meta.fetch.timeout.ms", 1000);
+
     // an intermediate solution to support foreign key, will be integrated into schema
     public static final Config<String> GRAPH_FOREIGN_KEY_URI =
             Config.stringConfig("graph.foreign.key", "");
diff --git a/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/config/YamlConfigs.java b/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/config/YamlConfigs.java
index e55682a86cdb..ec35991327ad 100644
--- a/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/config/YamlConfigs.java
+++ b/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/config/YamlConfigs.java
@@ -72,6 +72,9 @@ public class YamlConfigs extends Configs {
                         "graph.meta.statistics.fetch.interval.ms",
                         (Configs configs) ->
                                 configs.get("compiler.meta.reader.statistics.interval"))
+                .put(
+                        "graph.meta.fetch.timeout.ms",
+                        (Configs configs) -> configs.get("compiler.meta.reader.timeout"))
                 .put(
                         "graph.store",
                         (Configs configs) -> {
diff --git a/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/ir/meta/GraphId.java b/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/ir/meta/GraphId.java
index 8ddf0d75a511..4c63425263cd 100644
--- a/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/ir/meta/GraphId.java
+++ b/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/ir/meta/GraphId.java
@@ -51,4 +51,9 @@ public boolean equals(Object o) {
     public int hashCode() {
         return Objects.hashCode(id);
     }
+
+    @Override
+    public String toString() {
+        return "GraphId{" + "id=" + id + '}';
+    }
 }
diff --git a/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/ir/meta/reader/HttpIrMetaReader.java b/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/ir/meta/reader/HttpIrMetaReader.java
index 2e12792d7bf1..ba6cfb089d87 100644
--- a/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/ir/meta/reader/HttpIrMetaReader.java
+++ b/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/ir/meta/reader/HttpIrMetaReader.java
@@ -57,7 +57,9 @@ public HttpIrMetaReader(Configs configs) {
     public IrMeta readMeta() throws IOException {
         try {
             HttpResponse<String> response =
-                    sendRequest(GraphConfig.GRAPH_META_SCHEMA_URI.get(configs));
+                    sendRequest(
+                            GraphConfig.GRAPH_META_SCHEMA_URI.get(configs),
+                            GraphConfig.GRAPH_META_FETCH_TIMEOUT_MS.get(configs));
             String res = response.body();
             Preconditions.checkArgument(
                     response.statusCode() == 200,
@@ -91,7 +93,8 @@ public IrGraphStatistics readStats(GraphId graphId) throws IOException {
                     sendRequest(
                             String.format(
                                     GraphConfig.GRAPH_META_STATISTICS_URI.get(configs),
-                                    graphId.getId()));
+                                    graphId.getId()),
+                            GraphConfig.GRAPH_META_FETCH_TIMEOUT_MS.get(configs));
             String res = response.body();
             Preconditions.checkArgument(
                     response.statusCode() == 200,
@@ -109,7 +112,9 @@ public IrGraphStatistics readStats(GraphId graphId) throws IOException {
     public boolean syncStatsEnabled(GraphId graphId) throws IOException {
         try {
             HttpResponse<String> response =
-                    sendRequest(GraphConfig.GRAPH_META_SCHEMA_URI.get(configs));
+                    sendRequest(
+                            GraphConfig.GRAPH_META_SCHEMA_URI.get(configs),
+                            GraphConfig.GRAPH_META_FETCH_TIMEOUT_MS.get(configs));
             String res = response.body();
             Preconditions.checkArgument(
                     response.statusCode() == 200,
@@ -122,13 +127,14 @@ public boolean syncStatsEnabled(GraphId graphId) throws IOException {
         }
     }
 
-    private HttpResponse<String> sendRequest(String requestUri)
+    private HttpResponse<String> sendRequest(String requestUri, long timeOut)
             throws IOException, InterruptedException {
         HttpRequest request =
                 HttpRequest.newBuilder()
                         .uri(URI.create(requestUri))
                         .headers(CONTENT_TYPE, APPLICATION_JSON)
                         .GET()
+                        .timeout(java.time.Duration.ofMillis(timeOut))
                         .build();
         return httpClient.send(request, HttpResponse.BodyHandlers.ofString());
     }
diff --git a/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/cypher/antlr4/visitor/ExpressionVisitor.java b/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/cypher/antlr4/visitor/ExpressionVisitor.java
index 209e9c317b09..70bc21515fd6 100644
--- a/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/cypher/antlr4/visitor/ExpressionVisitor.java
+++ b/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/cypher/antlr4/visitor/ExpressionVisitor.java
@@ -279,7 +279,7 @@ public ExprVisitorResult visitOC_ParenthesizedExpression(
 
     @Override
     public ExprVisitorResult visitOC_Variable(CypherGSParser.OC_VariableContext ctx) {
-        String aliasName = ctx.getText();
+        String aliasName = Utils.getAliasName(ctx);
         return new ExprVisitorResult(builder.variable(aliasName));
     }
 
diff --git a/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/cypher/antlr4/visitor/GraphBuilderVisitor.java b/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/cypher/antlr4/visitor/GraphBuilderVisitor.java
index cab36fdc1348..0fefef6a9717 100644
--- a/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/cypher/antlr4/visitor/GraphBuilderVisitor.java
+++ b/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/cypher/antlr4/visitor/GraphBuilderVisitor.java
@@ -100,7 +100,7 @@ public GraphBuilder visitOC_Cypher(CypherGSParser.OC_CypherContext ctx) {
     @Override
     public GraphBuilder visitOC_Unwind(CypherGSParser.OC_UnwindContext ctx) {
         RexNode expr = expressionVisitor.visitOC_Expression(ctx.oC_Expression()).getExpr();
-        String alias = ctx.oC_Variable() == null ? null : ctx.oC_Variable().getText();
+        String alias = Utils.getAliasName(ctx.oC_Variable());
         return builder.unfold(expr, alias);
     }
 
@@ -339,7 +339,8 @@ private boolean isGroupPattern(
         for (CypherGSParser.OC_ProjectionItemContext itemCtx :
                 ctx.oC_ProjectionItems().oC_ProjectionItem()) {
             ExprVisitorResult item = expressionVisitor.visitOC_Expression(itemCtx.oC_Expression());
-            String alias = (itemCtx.AS() == null) ? null : itemCtx.oC_Variable().getText();
+            String alias =
+                    (itemCtx.AS() == null) ? null : Utils.getAliasName(itemCtx.oC_Variable());
             if (item.getAggCalls().isEmpty()) {
                 keyExprs.add(item.getExpr());
                 keyAliases.add(alias);
diff --git a/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/cypher/antlr4/visitor/LiteralVisitor.java b/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/cypher/antlr4/visitor/LiteralVisitor.java
index 5ca354a23c68..346fa16e78ed 100644
--- a/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/cypher/antlr4/visitor/LiteralVisitor.java
+++ b/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/cypher/antlr4/visitor/LiteralVisitor.java
@@ -100,6 +100,15 @@ public Object visitTerminal(TerminalNode node) {
         }
     }
 
+    @Override
+    public Object visitOC_SymbolicName(CypherGSParser.OC_SymbolicNameContext ctx) {
+        if (ctx.EscapedSymbolicName() != null) {
+            // escape the back-ticks
+            return ctx.getText().replace("`", "");
+        }
+        return ctx.getText();
+    }
+
     /**
      * Remove single/double quotes around String literal
      *
diff --git a/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/cypher/antlr4/visitor/Utils.java b/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/cypher/antlr4/visitor/Utils.java
index ad5f668c8521..9f8ff8b0fbb9 100644
--- a/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/cypher/antlr4/visitor/Utils.java
+++ b/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/cypher/antlr4/visitor/Utils.java
@@ -24,20 +24,21 @@
 import org.apache.calcite.rex.RexCall;
 import org.apache.calcite.rex.RexNode;
 import org.apache.calcite.sql.SqlKind;
+import org.checkerframework.checker.nullness.qual.Nullable;
 
 import java.util.ArrayList;
 import java.util.List;
 
 public abstract class Utils extends com.alibaba.graphscope.common.antlr4.Utils {
     public static SourceConfig sourceConfig(CypherGSParser.OC_NodePatternContext ctx) {
-        String alias = (ctx.oC_Variable() != null) ? ctx.oC_Variable().getText() : null;
+        String alias = getAliasName(ctx.oC_Variable());
         LabelConfig config = labelConfig(ctx.oC_NodeLabels());
         // source
         return new SourceConfig(GraphOpt.Source.VERTEX, config, alias);
     }
 
     public static GetVConfig getVConfig(CypherGSParser.OC_NodePatternContext ctx) {
-        String alias = (ctx.oC_Variable() != null) ? ctx.oC_Variable().getText() : null;
+        String alias = getAliasName(ctx.oC_Variable());
         LabelConfig config = labelConfig(ctx.oC_NodeLabels());
         // getV
         return new GetVConfig(getVOpt(ctx), config, alias);
@@ -50,7 +51,7 @@ public static ExpandConfig expandConfig(CypherGSParser.OC_RelationshipPatternCon
 
     public static ExpandConfig expandConfig(
             CypherGSParser.OC_RelationshipDetailContext ctx, GraphOpt.Expand opt) {
-        String alias = (ctx.oC_Variable() != null) ? ctx.oC_Variable().getText() : null;
+        String alias = getAliasName(ctx.oC_Variable());
         LabelConfig config = labelConfig(ctx.oC_RelationshipTypes());
         return new ExpandConfig(opt, config, alias);
     }
@@ -63,7 +64,7 @@ public static LabelConfig labelConfig(CypherGSParser.OC_NodeLabelsContext ctx) {
             config = new LabelConfig(false);
             for (CypherGSParser.OC_LabelNameContext ctx1 : ctx.oC_LabelName()) {
                 if (ctx1 == null) continue;
-                config.addLabel(ctx1.getText());
+                config.addLabel(getLabelName(ctx1));
             }
         }
         return config;
@@ -77,7 +78,7 @@ public static LabelConfig labelConfig(CypherGSParser.OC_RelationshipTypesContext
             config = new LabelConfig(false);
             for (CypherGSParser.OC_RelTypeNameContext ctx1 : ctx.oC_RelTypeName()) {
                 if (ctx1 == null) continue;
-                config.addLabel(ctx1.getText());
+                config.addLabel(getLabelName(ctx1));
             }
         }
         return config;
@@ -133,4 +134,16 @@ public static final List<RexNode> propertyFilters(
         }
         return filters;
     }
+
+    public static @Nullable String getAliasName(CypherGSParser.OC_VariableContext ctx) {
+        return ctx == null ? null : (String) LiteralVisitor.INSTANCE.visit(ctx);
+    }
+
+    public static String getLabelName(CypherGSParser.OC_LabelNameContext ctx) {
+        return (String) LiteralVisitor.INSTANCE.visit(ctx);
+    }
+
+    public static String getLabelName(CypherGSParser.OC_RelTypeNameContext ctx) {
+        return (String) LiteralVisitor.INSTANCE.visit(ctx);
+    }
 }
diff --git a/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/cypher/integration/suite/movie/MovieQueries.java b/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/cypher/integration/suite/movie/MovieQueries.java
index d4db0275b34f..f51c7c386b1a 100644
--- a/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/cypher/integration/suite/movie/MovieQueries.java
+++ b/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/cypher/integration/suite/movie/MovieQueries.java
@@ -399,4 +399,10 @@ public static QueryContext get_movie_query28_test() {
         List<String> expected = Arrays.asList("Record<{typeA: \"Person\", typeC: \"Movie\"}>");
         return new QueryContext(query, expected);
     }
+
+    public static QueryContext get_movie_query29_test() {
+        String query = "MATCH(a)-[r]->(b) where r.rating is null return count(r) as count;";
+        List<String> expected = Arrays.asList("Record<{count: 249}>");
+        return new QueryContext(query, expected);
+    }
 }
diff --git a/interactive_engine/compiler/src/test/java/com/alibaba/graphscope/cypher/antlr4/MatchTest.java b/interactive_engine/compiler/src/test/java/com/alibaba/graphscope/cypher/antlr4/MatchTest.java
index 68e3318dfe42..6d8f49b7be03 100644
--- a/interactive_engine/compiler/src/test/java/com/alibaba/graphscope/cypher/antlr4/MatchTest.java
+++ b/interactive_engine/compiler/src/test/java/com/alibaba/graphscope/cypher/antlr4/MatchTest.java
@@ -713,4 +713,22 @@ public void optional_shortest_path_test() {
                     + " alias=[p1], opt=[VERTEX], uniqueKeyFilters=[=(_.id, ?0)])",
                 after.explain().trim());
     }
+
+    @Test
+    public void special_label_name_test() {
+        GraphBuilder builder =
+                com.alibaba.graphscope.common.ir.Utils.mockGraphBuilder(optimizer, irMeta);
+        RelNode node =
+                Utils.eval("Match (n:`@person`)-[e:`contains`]->(n2) Return n", builder).build();
+        RelNode after = optimizer.optimize(node, new GraphIOProcessor(builder, irMeta));
+        Assert.assertEquals(
+                "GraphLogicalProject(n=[n], isAppend=[false])\n"
+                        + "  GraphLogicalGetV(tableConfig=[{isAll=false, tables=[@person]}],"
+                        + " alias=[n2], opt=[END])\n"
+                        + "    GraphLogicalExpand(tableConfig=[{isAll=false, tables=[contains]}],"
+                        + " alias=[e], startAlias=[n], opt=[OUT])\n"
+                        + "      GraphLogicalSource(tableConfig=[{isAll=false, tables=[@person]}],"
+                        + " alias=[n], opt=[VERTEX])",
+                after.explain().trim());
+    }
 }
diff --git a/interactive_engine/compiler/src/test/java/com/alibaba/graphscope/cypher/integration/movie/MovieTest.java b/interactive_engine/compiler/src/test/java/com/alibaba/graphscope/cypher/integration/movie/MovieTest.java
index 7f5ea090886d..84a3d4721c89 100644
--- a/interactive_engine/compiler/src/test/java/com/alibaba/graphscope/cypher/integration/movie/MovieTest.java
+++ b/interactive_engine/compiler/src/test/java/com/alibaba/graphscope/cypher/integration/movie/MovieTest.java
@@ -218,6 +218,13 @@ public void run_movie_query28_test() {
         Assert.assertEquals(testQuery.getExpectedResult().toString(), result.list().toString());
     }
 
+    @Test
+    public void run_movie_query29_test() {
+        QueryContext testQuery = MovieQueries.get_movie_query29_test();
+        Result result = session.run(testQuery.getQuery());
+        Assert.assertEquals(testQuery.getExpectedResult().toString(), result.list().toString());
+    }
+
     @AfterClass
     public static void afterClass() {
         if (session != null) {
diff --git a/interactive_engine/compiler/src/test/resources/config/modern/graph.yaml b/interactive_engine/compiler/src/test/resources/config/modern/graph.yaml
index 053d11184603..a740b08c2098 100644
--- a/interactive_engine/compiler/src/test/resources/config/modern/graph.yaml
+++ b/interactive_engine/compiler/src/test/resources/config/modern/graph.yaml
@@ -100,6 +100,26 @@ schema:
               date32:
       primary_keys:
         - id
+    - type_name: "@person"
+      type_id: 2
+      x_csr_params:
+        max_vertex_num: 100
+      properties:
+        - property_id: 0
+          property_name: id
+          property_type:
+            primitive_type: DT_SIGNED_INT64
+        - property_id: 1
+          property_name: name
+          property_type:
+            string:
+              long_text:
+        - property_id: 2
+          property_name: age
+          property_type:
+            primitive_type: DT_SIGNED_INT32
+      primary_keys:
+        - id
   edge_types:
     - type_name: knows
       type_id: 0
@@ -123,3 +143,14 @@ schema:
           property_name: weight
           property_type:
             primitive_type: DT_DOUBLE
+    - type_name: contains
+      type_id: 2
+      vertex_type_pair_relations:
+        - source_vertex: "@person"
+          destination_vertex: "@person"
+          relation: MANY_TO_MANY
+      properties:
+        - property_id: 0
+          property_name: weight
+          property_type:
+            primitive_type: DT_DOUBLE
diff --git a/interactive_engine/compiler/src/test/resources/statistics/modern_statistics.json b/interactive_engine/compiler/src/test/resources/statistics/modern_statistics.json
index ac3a7a7959c7..dfaad011c331 100644
--- a/interactive_engine/compiler/src/test/resources/statistics/modern_statistics.json
+++ b/interactive_engine/compiler/src/test/resources/statistics/modern_statistics.json
@@ -11,6 +11,11 @@
             "type_id": 1,
             "type_name": "software",
             "count": 3
+        },
+        {
+            "type_id": 2,
+            "type_name": "@person",
+            "count": 3
         }
     ],
     "edge_type_statistics": [
@@ -35,6 +40,16 @@
                     "count": 4
                 }
             ]
+        },{
+            "type_id": 2,
+            "type_name": "contains",
+            "vertex_type_pair_statistics": [
+                {
+                    "source_vertex": "@person",
+                    "destination_vertex": "@person",
+                    "count": 2
+                }
+            ]
         }
     ]
   }
\ No newline at end of file
diff --git a/interactive_engine/pom.xml b/interactive_engine/pom.xml
index f69d68faca14..e5f55ca86aec 100644
--- a/interactive_engine/pom.xml
+++ b/interactive_engine/pom.xml
@@ -253,7 +253,7 @@
 
     <neo4j.version>4.4.0</neo4j.version>
     <neo4j.driver.version>4.4.0</neo4j.driver.version>
-    <interactive.sdk.version>0.4.2</interactive.sdk.version>
+    <interactive.sdk.version>0.4.3</interactive.sdk.version>
     <interactive.sdk.classifier>no-gaia-ir</interactive.sdk.classifier>
   </properties>
 
diff --git a/k8s/dockerfiles/coordinator.Dockerfile b/k8s/dockerfiles/coordinator.Dockerfile
index d12cbe99c043..3b36d8e6811a 100644
--- a/k8s/dockerfiles/coordinator.Dockerfile
+++ b/k8s/dockerfiles/coordinator.Dockerfile
@@ -36,10 +36,17 @@ FROM ubuntu:22.04 AS coordinator
 ENV DEBIAN_FRONTEND=noninteractive
 
 RUN apt-get update -y && \
-    apt-get install -y sudo python3-pip openmpi-bin curl tzdata netcat && \
+    apt-get install -y sudo python3-pip openmpi-bin curl locales tzdata netcat && \
+    locale-gen en_US.UTF-8 && \
     apt-get clean -y && \
     rm -rf /var/lib/apt/lists/*
 
+ENV LANG en_US.UTF-8
+ENV LANGUAGE en_US:en
+ENV LC_ALL en_US.UTF-8
+ENV TZ=Asia/Shanghai
+RUN ln -snf /usr/share/zoneinfo/$TZ /etc/localtime && echo $TZ > /etc/timezone
+
 ENV GRAPHSCOPE_HOME=/opt/graphscope
 
 RUN useradd -m graphscope -u 1001 \
diff --git a/k8s/dockerfiles/graphscope-store.Dockerfile b/k8s/dockerfiles/graphscope-store.Dockerfile
index c079b2aac43b..a2466cf11a51 100644
--- a/k8s/dockerfiles/graphscope-store.Dockerfile
+++ b/k8s/dockerfiles/graphscope-store.Dockerfile
@@ -14,7 +14,7 @@ COPY --chown=graphscope:graphscope . /home/graphscope/graphscope
 COPY --chown=graphscope:graphscope ./interactive_engine/assembly/src/conf/maven.settings.xml /home/graphscope/.m2/settings.xml
 
 USER graphscope
-RUN rustup toolchain install 1.76.0 && rustup default 1.76.0
+RUN rustup toolchain install 1.81.0 && rustup default 1.81.0
 
 RUN cd /home/graphscope/graphscope \
     && . ~/.graphscope_env \
diff --git a/k8s/dockerfiles/interactive-entrypoint.sh b/k8s/dockerfiles/interactive-entrypoint.sh
index 009323f6c31f..76715ec609d6 100644
--- a/k8s/dockerfiles/interactive-entrypoint.sh
+++ b/k8s/dockerfiles/interactive-entrypoint.sh
@@ -57,6 +57,9 @@ function prepare_workspace() {
     cp /opt/flex/share/interactive_config.yaml $engine_config_path
     #make sure the line which start with default_graph is changed to default_graph: ${DEFAULT_GRAPH_NAME}
     sed -i "s/default_graph:.*/default_graph: ${DEFAULT_GRAPH_NAME}/" $engine_config_path
+    # By default, we occupy the all available cpus
+    cpus=$(grep -c ^processor /proc/cpuinfo)
+    sed -i "s/thread_num_per_worker:.*/thread_num_per_worker: ${cpus}/" $engine_config_path
     echo "Using default graph: ${DEFAULT_GRAPH_NAME} to start the service"
     
     # copy the builtin graph
diff --git a/k8s/dockerfiles/interactive.Dockerfile b/k8s/dockerfiles/interactive.Dockerfile
index 4a818174e5f3..10fb05880510 100644
--- a/k8s/dockerfiles/interactive.Dockerfile
+++ b/k8s/dockerfiles/interactive.Dockerfile
@@ -18,7 +18,7 @@ RUN cd /home/graphscope/GraphScope/ && \
     else \
         mkdir /home/graphscope/install; \
         . /home/graphscope/.graphscope_env; \
-        rustup toolchain install 1.76.0 && rustup default 1.76.0; \
+        rustup toolchain install 1.81.0 && rustup default 1.81.0; \
         make interactive-install BUILD_TYPE="$profile" INSTALL_PREFIX=/home/graphscope/install; \
     fi
 
diff --git a/k8s/internal/Makefile b/k8s/internal/Makefile
index 81736ddf4b52..fd3f5b8ea26f 100644
--- a/k8s/internal/Makefile
+++ b/k8s/internal/Makefile
@@ -110,7 +110,7 @@ graphscope-manylinux2014-py3-nodocker:
 	sudo sed -i 's|#baseurl=http://mirror.centos.org|baseurl=http://vault.centos.org|g' /etc/yum.repos.d/CentOS-* && \
 	sudo yum install java-11-openjdk-devel -y && \
 	sudo yum remove java-1.8.0-openjdk-devel java-1.8.0-openjdk java-1.8.0-openjdk-headless -y && \
-	rustup toolchain install 1.76.0 && rustup default 1.76.0 && \
+	rustup toolchain install 1.81.0 && rustup default 1.81.0 && \
 	cd $(WORKING_DIR)/../.. && \
 		if [[ "${PLATFORM}" == "aarch64" ]]; then \
 			export AUDITWHEEL_PLAT=manylinux2014_${PLATFORM}; \
diff --git a/python/graphscope/gsctl/scripts/install_deps.sh b/python/graphscope/gsctl/scripts/install_deps.sh
index e758062cd2c7..dd351f2e019f 100755
--- a/python/graphscope/gsctl/scripts/install_deps.sh
+++ b/python/graphscope/gsctl/scripts/install_deps.sh
@@ -882,8 +882,8 @@ install_interactive_dependencies() {
   if ! command -v rustup &>/dev/null; then
     curl --proto '=https' --tlsv1.2 -sSf https://sh.rustup.rs | sh -s -- -y
     source $HOME/.cargo/env
-    rustup install 1.76.0
-    rustup default 1.76.0
+    rustup install 1.81.0
+    rustup default 1.81.0
     rustc --version
   fi
   # opentelemetry