diff --git a/analytical_engine/core/loader/arrow_fragment_loader.h b/analytical_engine/core/loader/arrow_fragment_loader.h
index 8f9d0c24ffac..4b9ee97f8e27 100644
--- a/analytical_engine/core/loader/arrow_fragment_loader.h
+++ b/analytical_engine/core/loader/arrow_fragment_loader.h
@@ -273,6 +273,7 @@ class ArrowFragmentLoader {
 
   boost::leaf::result<vineyard::ObjectID> LoadFragmentAsFragmentGroup() {
     BOOST_LEAF_AUTO(frag_id, LoadFragment());
+    VY_OK_OR_RAISE(client_.Persist(frag_id));
     return vineyard::ConstructFragmentGroup(client_, frag_id, comm_spec_);
   }
 
diff --git a/analytical_engine/core/object/fragment_wrapper.h b/analytical_engine/core/object/fragment_wrapper.h
index 8e1262f4baa9..d3ef00d987b4 100644
--- a/analytical_engine/core/object/fragment_wrapper.h
+++ b/analytical_engine/core/object/fragment_wrapper.h
@@ -98,6 +98,7 @@ class FragmentWrapper<vineyard::ArrowFragment<OID_T, VID_T>>
     VINEYARD_CHECK_OK(client->GetMetaData(fragment_->id(), obj_meta));
     vineyard::ObjectID new_frag_id;
     VINEYARD_CHECK_OK(client->CreateMetaData(obj_meta, new_frag_id));
+    VINEYARD_CHECK_OK(client->Persist(new_frag_id));
     BOOST_LEAF_AUTO(frag_group_id, vineyard::ConstructFragmentGroup(
                                        *client, new_frag_id, comm_spec));
     auto new_frag =
@@ -206,6 +207,7 @@ class FragmentWrapper<vineyard::ArrowFragment<OID_T, VID_T>>
 
     auto new_frag_id = fragment_->AddVertexColumns(*client, columns);
 
+    VINEYARD_CHECK_OK(client->Persist(new_frag_id));
     BOOST_LEAF_AUTO(frag_group_id, vineyard::ConstructFragmentGroup(
                                        *client, new_frag_id, comm_spec));
     auto new_frag = client->GetObject<fragment_t>(new_frag_id);
diff --git a/analytical_engine/frame/property_graph_frame.cc b/analytical_engine/frame/property_graph_frame.cc
index 129c941d810c..f17eb006e285 100644
--- a/analytical_engine/frame/property_graph_frame.cc
+++ b/analytical_engine/frame/property_graph_frame.cc
@@ -86,6 +86,7 @@ void LoadGraph(
           auto new_frag = std::static_pointer_cast<_GRAPH_TYPE>(
               client.GetObject(new_frag_id));
 
+          VINEYARD_CHECK_OK(client.Persist(new_frag_id));
           BOOST_LEAF_AUTO(
               new_frag_group_id,
               vineyard::ConstructFragmentGroup(client, new_frag_id, comm_spec));
@@ -172,6 +173,7 @@ void ToArrowFragment(
 
         gs::DynamicToArrowConverter<oid_t> converter(comm_spec, client);
         BOOST_LEAF_AUTO(arrow_frag, converter.Convert(dynamic_frag));
+        VINEYARD_CHECK_OK(client.Persist(arrow_frag->id()));
         BOOST_LEAF_AUTO(frag_group_id,
                         vineyard::ConstructFragmentGroup(
                             client, arrow_frag->id(), comm_spec));
diff --git a/interactive_engine/src/executor/runtime/native/property_graph_stream.cc b/interactive_engine/src/executor/runtime/native/property_graph_stream.cc
index 1eb73add7b7d..845d722502ab 100644
--- a/interactive_engine/src/executor/runtime/native/property_graph_stream.cc
+++ b/interactive_engine/src/executor/runtime/native/property_graph_stream.cc
@@ -502,6 +502,7 @@ std::shared_ptr<Object> GlobalPGStreamBuilder::_Seal(Client& client) {
   auto gstream = std::make_shared<GlobalPGStream>();
   gstream->total_stream_chunks_ = total_stream_chunks_;
   gstream->meta_.SetTypeName(type_name<GlobalPGStream>());
+  gstream->meta_.SetGlobal(true);
   gstream->meta_.AddKeyValue("total_stream_chunks", total_stream_chunks_);
 
   for (size_t idx = 0; idx < stream_chunks_.size(); ++idx) {
diff --git a/interactive_engine/src/executor/runtime/native/property_graph_stream.h b/interactive_engine/src/executor/runtime/native/property_graph_stream.h
index ad326d92246a..5d0b768ce4e2 100644
--- a/interactive_engine/src/executor/runtime/native/property_graph_stream.h
+++ b/interactive_engine/src/executor/runtime/native/property_graph_stream.h
@@ -365,7 +365,7 @@ class PropertyGraphInStream {
 
 class GlobalPGStreamBuilder;
 
-class GlobalPGStream : public Registered<GlobalPGStream> {
+class GlobalPGStream : public Registered<GlobalPGStream>, GlobalObject {
  public:
   static std::shared_ptr<Object> Create() __attribute__((used)) {
     return std::static_pointer_cast<Object>(
diff --git a/k8s/gsvineyard.Dockerfile b/k8s/gsvineyard.Dockerfile
index aca040b9d9f0..f16ab35bb000 100644
--- a/k8s/gsvineyard.Dockerfile
+++ b/k8s/gsvineyard.Dockerfile
@@ -14,7 +14,7 @@ RUN cd /tmp && \
     make -j`nproc` && \
     make install && \
     cd /tmp && \
-    git clone -b v0.1.7 https://github.com/alibaba/libvineyard.git && \
+    git clone -b v0.1.8 https://github.com/alibaba/libvineyard.git && \
     cd libvineyard && \
     git submodule update --init && \
     mkdir -p /tmp/libvineyard/build && \