diff --git a/c++/greptime/v1/meta/heartbeat.pb.cc b/c++/greptime/v1/meta/heartbeat.pb.cc
index 2d482c83..fb45319a 100644
--- a/c++/greptime/v1/meta/heartbeat.pb.cc
+++ b/c++/greptime/v1/meta/heartbeat.pb.cc
@@ -101,9 +101,21 @@ struct FlowStat_FlowStatSizeEntry_DoNotUseDefaultTypeInternal {
   };
 };
 PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 FlowStat_FlowStatSizeEntry_DoNotUseDefaultTypeInternal _FlowStat_FlowStatSizeEntry_DoNotUse_default_instance_;
+PROTOBUF_CONSTEXPR FlowStat_FlowLastExecTimeMapEntry_DoNotUse::FlowStat_FlowLastExecTimeMapEntry_DoNotUse(
+    ::_pbi::ConstantInitialized) {}
+struct FlowStat_FlowLastExecTimeMapEntry_DoNotUseDefaultTypeInternal {
+  PROTOBUF_CONSTEXPR FlowStat_FlowLastExecTimeMapEntry_DoNotUseDefaultTypeInternal()
+      : _instance(::_pbi::ConstantInitialized{}) {}
+  ~FlowStat_FlowLastExecTimeMapEntry_DoNotUseDefaultTypeInternal() {}
+  union {
+    FlowStat_FlowLastExecTimeMapEntry_DoNotUse _instance;
+  };
+};
+PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 FlowStat_FlowLastExecTimeMapEntry_DoNotUseDefaultTypeInternal _FlowStat_FlowLastExecTimeMapEntry_DoNotUse_default_instance_;
 PROTOBUF_CONSTEXPR FlowStat::FlowStat(
     ::_pbi::ConstantInitialized): _impl_{
     /*decltype(_impl_.flow_stat_size_)*/{::_pbi::ConstantInitialized()}
+  , /*decltype(_impl_.flow_last_exec_time_map_)*/{::_pbi::ConstantInitialized()}
   , /*decltype(_impl_._cached_size_)*/{}} {}
 struct FlowStatDefaultTypeInternal {
   PROTOBUF_CONSTEXPR FlowStatDefaultTypeInternal()
@@ -209,7 +221,7 @@ PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORIT
 }  // namespace meta
 }  // namespace v1
 }  // namespace greptime
-static ::_pb::Metadata file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[12];
+static ::_pb::Metadata file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[13];
 static const ::_pb::EnumDescriptor* file_level_enum_descriptors_greptime_2fv1_2fmeta_2fheartbeat_2eproto[1];
 static constexpr ::_pb::ServiceDescriptor const** file_level_service_descriptors_greptime_2fv1_2fmeta_2fheartbeat_2eproto = nullptr;
 
@@ -272,6 +284,16 @@ const uint32_t TableStruct_greptime_2fv1_2fmeta_2fheartbeat_2eproto::offsets[] P
   PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::FlowStat_FlowStatSizeEntry_DoNotUse, value_),
   0,
   1,
+  PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::FlowStat_FlowLastExecTimeMapEntry_DoNotUse, _has_bits_),
+  PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::FlowStat_FlowLastExecTimeMapEntry_DoNotUse, _internal_metadata_),
+  ~0u,  // no _extensions_
+  ~0u,  // no _oneof_case_
+  ~0u,  // no _weak_field_map_
+  ~0u,  // no _inlined_string_donated_
+  PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::FlowStat_FlowLastExecTimeMapEntry_DoNotUse, key_),
+  PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::FlowStat_FlowLastExecTimeMapEntry_DoNotUse, value_),
+  0,
+  1,
   ~0u,  // no _has_bits_
   PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::FlowStat, _internal_metadata_),
   ~0u,  // no _extensions_
@@ -279,6 +301,7 @@ const uint32_t TableStruct_greptime_2fv1_2fmeta_2fheartbeat_2eproto::offsets[] P
   ~0u,  // no _weak_field_map_
   ~0u,  // no _inlined_string_donated_
   PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::FlowStat, _impl_.flow_stat_size_),
+  PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::FlowStat, _impl_.flow_last_exec_time_map_),
   ~0u,  // no _has_bits_
   PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::HeartbeatResponse, _internal_metadata_),
   ~0u,  // no _extensions_
@@ -341,13 +364,14 @@ static const ::_pbi::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protode
   { 25, 33, -1, sizeof(::greptime::v1::meta::RegionStat_ExtensionsEntry_DoNotUse)},
   { 35, -1, -1, sizeof(::greptime::v1::meta::RegionStat)},
   { 48, 56, -1, sizeof(::greptime::v1::meta::FlowStat_FlowStatSizeEntry_DoNotUse)},
-  { 58, -1, -1, sizeof(::greptime::v1::meta::FlowStat)},
-  { 65, -1, -1, sizeof(::greptime::v1::meta::HeartbeatResponse)},
-  { 74, -1, -1, sizeof(::greptime::v1::meta::GrantedRegion)},
-  { 82, -1, -1, sizeof(::greptime::v1::meta::RegionLease)},
-  { 92, -1, -1, sizeof(::greptime::v1::meta::AskLeaderRequest)},
-  { 99, -1, -1, sizeof(::greptime::v1::meta::AskLeaderResponse)},
-  { 107, -1, -1, sizeof(::greptime::v1::meta::MailboxMessage)},
+  { 58, 66, -1, sizeof(::greptime::v1::meta::FlowStat_FlowLastExecTimeMapEntry_DoNotUse)},
+  { 68, -1, -1, sizeof(::greptime::v1::meta::FlowStat)},
+  { 76, -1, -1, sizeof(::greptime::v1::meta::HeartbeatResponse)},
+  { 85, -1, -1, sizeof(::greptime::v1::meta::GrantedRegion)},
+  { 93, -1, -1, sizeof(::greptime::v1::meta::RegionLease)},
+  { 103, -1, -1, sizeof(::greptime::v1::meta::AskLeaderRequest)},
+  { 110, -1, -1, sizeof(::greptime::v1::meta::AskLeaderResponse)},
+  { 118, -1, -1, sizeof(::greptime::v1::meta::MailboxMessage)},
 };
 
 static const ::_pb::Message* const file_default_instances[] = {
@@ -356,6 +380,7 @@ static const ::_pb::Message* const file_default_instances[] = {
   &::greptime::v1::meta::_RegionStat_ExtensionsEntry_DoNotUse_default_instance_._instance,
   &::greptime::v1::meta::_RegionStat_default_instance_._instance,
   &::greptime::v1::meta::_FlowStat_FlowStatSizeEntry_DoNotUse_default_instance_._instance,
+  &::greptime::v1::meta::_FlowStat_FlowLastExecTimeMapEntry_DoNotUse_default_instance_._instance,
   &::greptime::v1::meta::_FlowStat_default_instance_._instance,
   &::greptime::v1::meta::_HeartbeatResponse_default_instance_._instance,
   &::greptime::v1::meta::_GrantedRegion_default_instance_._instance,
@@ -387,45 +412,49 @@ const char descriptor_table_protodef_greptime_2fv1_2fmeta_2fheartbeat_2eproto[]
   "ta.RegionRole\022@\n\nextensions\030c \003(\0132,.grep"
   "time.v1.meta.RegionStat.ExtensionsEntry\032"
   "1\n\017ExtensionsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value"
-  "\030\002 \001(\014:\0028\001\"\205\001\n\010FlowStat\022D\n\016flow_stat_siz"
+  "\030\002 \001(\014:\0028\001\"\227\002\n\010FlowStat\022D\n\016flow_stat_siz"
   "e\030\001 \003(\0132,.greptime.v1.meta.FlowStat.Flow"
-  "StatSizeEntry\0323\n\021FlowStatSizeEntry\022\013\n\003ke"
-  "y\030\001 \001(\r\022\r\n\005value\030\002 \001(\004:\0028\001\"\265\001\n\021Heartbeat"
-  "Response\0220\n\006header\030\001 \001(\0132 .greptime.v1.m"
-  "eta.ResponseHeader\0229\n\017mailbox_message\030\002 "
-  "\001(\0132 .greptime.v1.meta.MailboxMessage\0223\n"
-  "\014region_lease\030\003 \001(\0132\035.greptime.v1.meta.R"
-  "egionLease\"N\n\rGrantedRegion\022\021\n\tregion_id"
-  "\030\001 \001(\004\022*\n\004role\030\002 \001(\0162\034.greptime.v1.meta."
-  "RegionRole\"\222\001\n\013RegionLease\0220\n\007regions\030\001 "
-  "\003(\0132\037.greptime.v1.meta.GrantedRegion\022\034\n\024"
-  "duration_since_epoch\030\002 \001(\004\022\025\n\rlease_seco"
-  "nds\030\003 \001(\004\022\034\n\024closeable_region_ids\030\004 \003(\004\""
-  "C\n\020AskLeaderRequest\022/\n\006header\030\001 \001(\0132\037.gr"
-  "eptime.v1.meta.RequestHeader\"m\n\021AskLeade"
-  "rResponse\0220\n\006header\030\001 \001(\0132 .greptime.v1."
-  "meta.ResponseHeader\022&\n\006leader\030\002 \001(\0132\026.gr"
-  "eptime.v1.meta.Peer\"|\n\016MailboxMessage\022\n\n"
-  "\002id\030\001 \001(\004\022\017\n\007subject\030\002 \001(\t\022\014\n\004from\030\003 \001(\t"
-  "\022\n\n\002to\030\004 \001(\t\022\030\n\020timestamp_millis\030\005 \001(\003\022\016"
-  "\n\004json\030\006 \001(\tH\000B\t\n\007payload*=\n\nRegionRole\022"
-  "\n\n\006Leader\020\000\022\014\n\010Follower\020\001\022\025\n\021Downgrading"
-  "Leader\020\0022\277\001\n\tHeartbeat\022Z\n\tHeartbeat\022\".gr"
-  "eptime.v1.meta.HeartbeatRequest\032#.grepti"
-  "me.v1.meta.HeartbeatResponse\"\000(\0010\001\022V\n\tAs"
-  "kLeader\022\".greptime.v1.meta.AskLeaderRequ"
-  "est\032#.greptime.v1.meta.AskLeaderResponse"
-  "\"\000B<Z:github.com/GreptimeTeam/greptime-p"
-  "roto/go/greptime/v1/metab\006proto3"
+  "StatSizeEntry\022T\n\027flow_last_exec_time_map"
+  "\030\002 \003(\01323.greptime.v1.meta.FlowStat.FlowL"
+  "astExecTimeMapEntry\0323\n\021FlowStatSizeEntry"
+  "\022\013\n\003key\030\001 \001(\r\022\r\n\005value\030\002 \001(\004:\0028\001\032:\n\030Flow"
+  "LastExecTimeMapEntry\022\013\n\003key\030\001 \001(\r\022\r\n\005val"
+  "ue\030\002 \001(\003:\0028\001\"\265\001\n\021HeartbeatResponse\0220\n\006he"
+  "ader\030\001 \001(\0132 .greptime.v1.meta.ResponseHe"
+  "ader\0229\n\017mailbox_message\030\002 \001(\0132 .greptime"
+  ".v1.meta.MailboxMessage\0223\n\014region_lease\030"
+  "\003 \001(\0132\035.greptime.v1.meta.RegionLease\"N\n\r"
+  "GrantedRegion\022\021\n\tregion_id\030\001 \001(\004\022*\n\004role"
+  "\030\002 \001(\0162\034.greptime.v1.meta.RegionRole\"\222\001\n"
+  "\013RegionLease\0220\n\007regions\030\001 \003(\0132\037.greptime"
+  ".v1.meta.GrantedRegion\022\034\n\024duration_since"
+  "_epoch\030\002 \001(\004\022\025\n\rlease_seconds\030\003 \001(\004\022\034\n\024c"
+  "loseable_region_ids\030\004 \003(\004\"C\n\020AskLeaderRe"
+  "quest\022/\n\006header\030\001 \001(\0132\037.greptime.v1.meta"
+  ".RequestHeader\"m\n\021AskLeaderResponse\0220\n\006h"
+  "eader\030\001 \001(\0132 .greptime.v1.meta.ResponseH"
+  "eader\022&\n\006leader\030\002 \001(\0132\026.greptime.v1.meta"
+  ".Peer\"|\n\016MailboxMessage\022\n\n\002id\030\001 \001(\004\022\017\n\007s"
+  "ubject\030\002 \001(\t\022\014\n\004from\030\003 \001(\t\022\n\n\002to\030\004 \001(\t\022\030"
+  "\n\020timestamp_millis\030\005 \001(\003\022\016\n\004json\030\006 \001(\tH\000"
+  "B\t\n\007payload*=\n\nRegionRole\022\n\n\006Leader\020\000\022\014\n"
+  "\010Follower\020\001\022\025\n\021DowngradingLeader\020\0022\277\001\n\tH"
+  "eartbeat\022Z\n\tHeartbeat\022\".greptime.v1.meta"
+  ".HeartbeatRequest\032#.greptime.v1.meta.Hea"
+  "rtbeatResponse\"\000(\0010\001\022V\n\tAskLeader\022\".grep"
+  "time.v1.meta.AskLeaderRequest\032#.greptime"
+  ".v1.meta.AskLeaderResponse\"\000B<Z:github.c"
+  "om/GreptimeTeam/greptime-proto/go/grepti"
+  "me/v1/metab\006proto3"
   ;
 static const ::_pbi::DescriptorTable* const descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_deps[1] = {
   &::descriptor_table_greptime_2fv1_2fmeta_2fcommon_2eproto,
 };
 static ::_pbi::once_flag descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_once;
 const ::_pbi::DescriptorTable descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto = {
-    false, false, 2032, descriptor_table_protodef_greptime_2fv1_2fmeta_2fheartbeat_2eproto,
+    false, false, 2178, descriptor_table_protodef_greptime_2fv1_2fmeta_2fheartbeat_2eproto,
     "greptime/v1/meta/heartbeat.proto",
-    &descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_once, descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_deps, 1, 12,
+    &descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_once, descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_deps, 1, 13,
     schemas, file_default_instances, TableStruct_greptime_2fv1_2fmeta_2fheartbeat_2eproto::offsets,
     file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto, file_level_enum_descriptors_greptime_2fv1_2fmeta_2fheartbeat_2eproto,
     file_level_service_descriptors_greptime_2fv1_2fmeta_2fheartbeat_2eproto,
@@ -1709,6 +1738,20 @@ ::PROTOBUF_NAMESPACE_ID::Metadata FlowStat_FlowStatSizeEntry_DoNotUse::GetMetada
 
 // ===================================================================
 
+FlowStat_FlowLastExecTimeMapEntry_DoNotUse::FlowStat_FlowLastExecTimeMapEntry_DoNotUse() {}
+FlowStat_FlowLastExecTimeMapEntry_DoNotUse::FlowStat_FlowLastExecTimeMapEntry_DoNotUse(::PROTOBUF_NAMESPACE_ID::Arena* arena)
+    : SuperType(arena) {}
+void FlowStat_FlowLastExecTimeMapEntry_DoNotUse::MergeFrom(const FlowStat_FlowLastExecTimeMapEntry_DoNotUse& other) {
+  MergeFromInternal(other);
+}
+::PROTOBUF_NAMESPACE_ID::Metadata FlowStat_FlowLastExecTimeMapEntry_DoNotUse::GetMetadata() const {
+  return ::_pbi::AssignDescriptors(
+      &descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_getter, &descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_once,
+      file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[5]);
+}
+
+// ===================================================================
+
 class FlowStat::_Internal {
  public:
 };
@@ -1727,10 +1770,12 @@ FlowStat::FlowStat(const FlowStat& from)
   FlowStat* const _this = this; (void)_this;
   new (&_impl_) Impl_{
       /*decltype(_impl_.flow_stat_size_)*/{}
+    , /*decltype(_impl_.flow_last_exec_time_map_)*/{}
     , /*decltype(_impl_._cached_size_)*/{}};
 
   _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
   _this->_impl_.flow_stat_size_.MergeFrom(from._impl_.flow_stat_size_);
+  _this->_impl_.flow_last_exec_time_map_.MergeFrom(from._impl_.flow_last_exec_time_map_);
   // @@protoc_insertion_point(copy_constructor:greptime.v1.meta.FlowStat)
 }
 
@@ -1740,6 +1785,7 @@ inline void FlowStat::SharedCtor(
   (void)is_message_owned;
   new (&_impl_) Impl_{
       /*decltype(_impl_.flow_stat_size_)*/{::_pbi::ArenaInitialized(), arena}
+    , /*decltype(_impl_.flow_last_exec_time_map_)*/{::_pbi::ArenaInitialized(), arena}
     , /*decltype(_impl_._cached_size_)*/{}
   };
 }
@@ -1758,11 +1804,14 @@ inline void FlowStat::SharedDtor() {
   GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
   _impl_.flow_stat_size_.Destruct();
   _impl_.flow_stat_size_.~MapField();
+  _impl_.flow_last_exec_time_map_.Destruct();
+  _impl_.flow_last_exec_time_map_.~MapField();
 }
 
 void FlowStat::ArenaDtor(void* object) {
   FlowStat* _this = reinterpret_cast< FlowStat* >(object);
   _this->_impl_.flow_stat_size_.Destruct();
+  _this->_impl_.flow_last_exec_time_map_.Destruct();
 }
 void FlowStat::SetCachedSize(int size) const {
   _impl_._cached_size_.Set(size);
@@ -1775,6 +1824,7 @@ void FlowStat::Clear() {
   (void) cached_has_bits;
 
   _impl_.flow_stat_size_.Clear();
+  _impl_.flow_last_exec_time_map_.Clear();
   _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
 }
 
@@ -1797,6 +1847,19 @@ const char* FlowStat::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx)
         } else
           goto handle_unusual;
         continue;
+      // map<uint32, int64> flow_last_exec_time_map = 2;
+      case 2:
+        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 18)) {
+          ptr -= 1;
+          do {
+            ptr += 1;
+            ptr = ctx->ParseMessage(&_impl_.flow_last_exec_time_map_, ptr);
+            CHK_(ptr);
+            if (!ctx->DataAvailable(ptr)) break;
+          } while (::PROTOBUF_NAMESPACE_ID::internal::ExpectTag<18>(ptr));
+        } else
+          goto handle_unusual;
+        continue;
       default:
         goto handle_unusual;
     }  // switch
@@ -1843,6 +1906,23 @@ uint8_t* FlowStat::_InternalSerialize(
     }
   }
 
+  // map<uint32, int64> flow_last_exec_time_map = 2;
+  if (!this->_internal_flow_last_exec_time_map().empty()) {
+    using MapType = ::_pb::Map<uint32_t, int64_t>;
+    using WireHelper = FlowStat_FlowLastExecTimeMapEntry_DoNotUse::Funcs;
+    const auto& map_field = this->_internal_flow_last_exec_time_map();
+
+    if (stream->IsSerializationDeterministic() && map_field.size() > 1) {
+      for (const auto& entry : ::_pbi::MapSorterFlat<MapType>(map_field)) {
+        target = WireHelper::InternalSerialize(2, entry.first, entry.second, target, stream);
+      }
+    } else {
+      for (const auto& entry : map_field) {
+        target = WireHelper::InternalSerialize(2, entry.first, entry.second, target, stream);
+      }
+    }
+  }
+
   if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
     target = ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
         _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream);
@@ -1868,6 +1948,15 @@ size_t FlowStat::ByteSizeLong() const {
     total_size += FlowStat_FlowStatSizeEntry_DoNotUse::Funcs::ByteSizeLong(it->first, it->second);
   }
 
+  // map<uint32, int64> flow_last_exec_time_map = 2;
+  total_size += 1 *
+      ::PROTOBUF_NAMESPACE_ID::internal::FromIntSize(this->_internal_flow_last_exec_time_map_size());
+  for (::PROTOBUF_NAMESPACE_ID::Map< uint32_t, int64_t >::const_iterator
+      it = this->_internal_flow_last_exec_time_map().begin();
+      it != this->_internal_flow_last_exec_time_map().end(); ++it) {
+    total_size += FlowStat_FlowLastExecTimeMapEntry_DoNotUse::Funcs::ByteSizeLong(it->first, it->second);
+  }
+
   return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_);
 }
 
@@ -1887,6 +1976,7 @@ void FlowStat::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTO
   (void) cached_has_bits;
 
   _this->_impl_.flow_stat_size_.MergeFrom(from._impl_.flow_stat_size_);
+  _this->_impl_.flow_last_exec_time_map_.MergeFrom(from._impl_.flow_last_exec_time_map_);
   _this->_internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
 }
 
@@ -1905,12 +1995,13 @@ void FlowStat::InternalSwap(FlowStat* other) {
   using std::swap;
   _internal_metadata_.InternalSwap(&other->_internal_metadata_);
   _impl_.flow_stat_size_.InternalSwap(&other->_impl_.flow_stat_size_);
+  _impl_.flow_last_exec_time_map_.InternalSwap(&other->_impl_.flow_last_exec_time_map_);
 }
 
 ::PROTOBUF_NAMESPACE_ID::Metadata FlowStat::GetMetadata() const {
   return ::_pbi::AssignDescriptors(
       &descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_getter, &descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_once,
-      file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[5]);
+      file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[6]);
 }
 
 // ===================================================================
@@ -2196,7 +2287,7 @@ void HeartbeatResponse::InternalSwap(HeartbeatResponse* other) {
 ::PROTOBUF_NAMESPACE_ID::Metadata HeartbeatResponse::GetMetadata() const {
   return ::_pbi::AssignDescriptors(
       &descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_getter, &descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_once,
-      file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[6]);
+      file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[7]);
 }
 
 // ===================================================================
@@ -2410,7 +2501,7 @@ void GrantedRegion::InternalSwap(GrantedRegion* other) {
 ::PROTOBUF_NAMESPACE_ID::Metadata GrantedRegion::GetMetadata() const {
   return ::_pbi::AssignDescriptors(
       &descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_getter, &descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_once,
-      file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[7]);
+      file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[8]);
 }
 
 // ===================================================================
@@ -2697,7 +2788,7 @@ void RegionLease::InternalSwap(RegionLease* other) {
 ::PROTOBUF_NAMESPACE_ID::Metadata RegionLease::GetMetadata() const {
   return ::_pbi::AssignDescriptors(
       &descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_getter, &descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_once,
-      file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[8]);
+      file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[9]);
 }
 
 // ===================================================================
@@ -2896,7 +2987,7 @@ void AskLeaderRequest::InternalSwap(AskLeaderRequest* other) {
 ::PROTOBUF_NAMESPACE_ID::Metadata AskLeaderRequest::GetMetadata() const {
   return ::_pbi::AssignDescriptors(
       &descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_getter, &descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_once,
-      file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[9]);
+      file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[10]);
 }
 
 // ===================================================================
@@ -3147,7 +3238,7 @@ void AskLeaderResponse::InternalSwap(AskLeaderResponse* other) {
 ::PROTOBUF_NAMESPACE_ID::Metadata AskLeaderResponse::GetMetadata() const {
   return ::_pbi::AssignDescriptors(
       &descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_getter, &descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_once,
-      file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[10]);
+      file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[11]);
 }
 
 // ===================================================================
@@ -3587,7 +3678,7 @@ void MailboxMessage::InternalSwap(MailboxMessage* other) {
 ::PROTOBUF_NAMESPACE_ID::Metadata MailboxMessage::GetMetadata() const {
   return ::_pbi::AssignDescriptors(
       &descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_getter, &descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_once,
-      file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[11]);
+      file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[12]);
 }
 
 // @@protoc_insertion_point(namespace_scope)
@@ -3615,6 +3706,10 @@ template<> PROTOBUF_NOINLINE ::greptime::v1::meta::FlowStat_FlowStatSizeEntry_Do
 Arena::CreateMaybeMessage< ::greptime::v1::meta::FlowStat_FlowStatSizeEntry_DoNotUse >(Arena* arena) {
   return Arena::CreateMessageInternal< ::greptime::v1::meta::FlowStat_FlowStatSizeEntry_DoNotUse >(arena);
 }
+template<> PROTOBUF_NOINLINE ::greptime::v1::meta::FlowStat_FlowLastExecTimeMapEntry_DoNotUse*
+Arena::CreateMaybeMessage< ::greptime::v1::meta::FlowStat_FlowLastExecTimeMapEntry_DoNotUse >(Arena* arena) {
+  return Arena::CreateMessageInternal< ::greptime::v1::meta::FlowStat_FlowLastExecTimeMapEntry_DoNotUse >(arena);
+}
 template<> PROTOBUF_NOINLINE ::greptime::v1::meta::FlowStat*
 Arena::CreateMaybeMessage< ::greptime::v1::meta::FlowStat >(Arena* arena) {
   return Arena::CreateMessageInternal< ::greptime::v1::meta::FlowStat >(arena);
diff --git a/c++/greptime/v1/meta/heartbeat.pb.h b/c++/greptime/v1/meta/heartbeat.pb.h
index 4dfb01d1..e4495a80 100644
--- a/c++/greptime/v1/meta/heartbeat.pb.h
+++ b/c++/greptime/v1/meta/heartbeat.pb.h
@@ -61,6 +61,9 @@ extern AskLeaderResponseDefaultTypeInternal _AskLeaderResponse_default_instance_
 class FlowStat;
 struct FlowStatDefaultTypeInternal;
 extern FlowStatDefaultTypeInternal _FlowStat_default_instance_;
+class FlowStat_FlowLastExecTimeMapEntry_DoNotUse;
+struct FlowStat_FlowLastExecTimeMapEntry_DoNotUseDefaultTypeInternal;
+extern FlowStat_FlowLastExecTimeMapEntry_DoNotUseDefaultTypeInternal _FlowStat_FlowLastExecTimeMapEntry_DoNotUse_default_instance_;
 class FlowStat_FlowStatSizeEntry_DoNotUse;
 struct FlowStat_FlowStatSizeEntry_DoNotUseDefaultTypeInternal;
 extern FlowStat_FlowStatSizeEntry_DoNotUseDefaultTypeInternal _FlowStat_FlowStatSizeEntry_DoNotUse_default_instance_;
@@ -95,6 +98,7 @@ PROTOBUF_NAMESPACE_OPEN
 template<> ::greptime::v1::meta::AskLeaderRequest* Arena::CreateMaybeMessage<::greptime::v1::meta::AskLeaderRequest>(Arena*);
 template<> ::greptime::v1::meta::AskLeaderResponse* Arena::CreateMaybeMessage<::greptime::v1::meta::AskLeaderResponse>(Arena*);
 template<> ::greptime::v1::meta::FlowStat* Arena::CreateMaybeMessage<::greptime::v1::meta::FlowStat>(Arena*);
+template<> ::greptime::v1::meta::FlowStat_FlowLastExecTimeMapEntry_DoNotUse* Arena::CreateMaybeMessage<::greptime::v1::meta::FlowStat_FlowLastExecTimeMapEntry_DoNotUse>(Arena*);
 template<> ::greptime::v1::meta::FlowStat_FlowStatSizeEntry_DoNotUse* Arena::CreateMaybeMessage<::greptime::v1::meta::FlowStat_FlowStatSizeEntry_DoNotUse>(Arena*);
 template<> ::greptime::v1::meta::GrantedRegion* Arena::CreateMaybeMessage<::greptime::v1::meta::GrantedRegion>(Arena*);
 template<> ::greptime::v1::meta::HeartbeatRequest* Arena::CreateMaybeMessage<::greptime::v1::meta::HeartbeatRequest>(Arena*);
@@ -911,6 +915,30 @@ class FlowStat_FlowStatSizeEntry_DoNotUse : public ::PROTOBUF_NAMESPACE_ID::inte
 
 // -------------------------------------------------------------------
 
+class FlowStat_FlowLastExecTimeMapEntry_DoNotUse : public ::PROTOBUF_NAMESPACE_ID::internal::MapEntry<FlowStat_FlowLastExecTimeMapEntry_DoNotUse, 
+    uint32_t, int64_t,
+    ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_UINT32,
+    ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_INT64> {
+public:
+  typedef ::PROTOBUF_NAMESPACE_ID::internal::MapEntry<FlowStat_FlowLastExecTimeMapEntry_DoNotUse, 
+    uint32_t, int64_t,
+    ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_UINT32,
+    ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_INT64> SuperType;
+  FlowStat_FlowLastExecTimeMapEntry_DoNotUse();
+  explicit PROTOBUF_CONSTEXPR FlowStat_FlowLastExecTimeMapEntry_DoNotUse(
+      ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
+  explicit FlowStat_FlowLastExecTimeMapEntry_DoNotUse(::PROTOBUF_NAMESPACE_ID::Arena* arena);
+  void MergeFrom(const FlowStat_FlowLastExecTimeMapEntry_DoNotUse& other);
+  static const FlowStat_FlowLastExecTimeMapEntry_DoNotUse* internal_default_instance() { return reinterpret_cast<const FlowStat_FlowLastExecTimeMapEntry_DoNotUse*>(&_FlowStat_FlowLastExecTimeMapEntry_DoNotUse_default_instance_); }
+  static bool ValidateKey(void*) { return true; }
+  static bool ValidateValue(void*) { return true; }
+  using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom;
+  ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
+  friend struct ::TableStruct_greptime_2fv1_2fmeta_2fheartbeat_2eproto;
+};
+
+// -------------------------------------------------------------------
+
 class FlowStat final :
     public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:greptime.v1.meta.FlowStat) */ {
  public:
@@ -959,7 +987,7 @@ class FlowStat final :
                &_FlowStat_default_instance_);
   }
   static constexpr int kIndexInFileMessages =
-    5;
+    6;
 
   friend void swap(FlowStat& a, FlowStat& b) {
     a.Swap(&b);
@@ -1036,6 +1064,7 @@ class FlowStat final :
 
   enum : int {
     kFlowStatSizeFieldNumber = 1,
+    kFlowLastExecTimeMapFieldNumber = 2,
   };
   // map<uint32, uint64> flow_stat_size = 1;
   int flow_stat_size_size() const;
@@ -1054,6 +1083,23 @@ class FlowStat final :
   ::PROTOBUF_NAMESPACE_ID::Map< uint32_t, uint64_t >*
       mutable_flow_stat_size();
 
+  // map<uint32, int64> flow_last_exec_time_map = 2;
+  int flow_last_exec_time_map_size() const;
+  private:
+  int _internal_flow_last_exec_time_map_size() const;
+  public:
+  void clear_flow_last_exec_time_map();
+  private:
+  const ::PROTOBUF_NAMESPACE_ID::Map< uint32_t, int64_t >&
+      _internal_flow_last_exec_time_map() const;
+  ::PROTOBUF_NAMESPACE_ID::Map< uint32_t, int64_t >*
+      _internal_mutable_flow_last_exec_time_map();
+  public:
+  const ::PROTOBUF_NAMESPACE_ID::Map< uint32_t, int64_t >&
+      flow_last_exec_time_map() const;
+  ::PROTOBUF_NAMESPACE_ID::Map< uint32_t, int64_t >*
+      mutable_flow_last_exec_time_map();
+
   // @@protoc_insertion_point(class_scope:greptime.v1.meta.FlowStat)
  private:
   class _Internal;
@@ -1067,6 +1113,11 @@ class FlowStat final :
         uint32_t, uint64_t,
         ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_UINT32,
         ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_UINT64> flow_stat_size_;
+    ::PROTOBUF_NAMESPACE_ID::internal::MapField<
+        FlowStat_FlowLastExecTimeMapEntry_DoNotUse,
+        uint32_t, int64_t,
+        ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_UINT32,
+        ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_INT64> flow_last_exec_time_map_;
     mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
   };
   union { Impl_ _impl_; };
@@ -1122,7 +1173,7 @@ class HeartbeatResponse final :
                &_HeartbeatResponse_default_instance_);
   }
   static constexpr int kIndexInFileMessages =
-    6;
+    7;
 
   friend void swap(HeartbeatResponse& a, HeartbeatResponse& b) {
     a.Swap(&b);
@@ -1319,7 +1370,7 @@ class GrantedRegion final :
                &_GrantedRegion_default_instance_);
   }
   static constexpr int kIndexInFileMessages =
-    7;
+    8;
 
   friend void swap(GrantedRegion& a, GrantedRegion& b) {
     a.Swap(&b);
@@ -1478,7 +1529,7 @@ class RegionLease final :
                &_RegionLease_default_instance_);
   }
   static constexpr int kIndexInFileMessages =
-    8;
+    9;
 
   friend void swap(RegionLease& a, RegionLease& b) {
     a.Swap(&b);
@@ -1682,7 +1733,7 @@ class AskLeaderRequest final :
                &_AskLeaderRequest_default_instance_);
   }
   static constexpr int kIndexInFileMessages =
-    9;
+    10;
 
   friend void swap(AskLeaderRequest& a, AskLeaderRequest& b) {
     a.Swap(&b);
@@ -1839,7 +1890,7 @@ class AskLeaderResponse final :
                &_AskLeaderResponse_default_instance_);
   }
   static constexpr int kIndexInFileMessages =
-    10;
+    11;
 
   friend void swap(AskLeaderResponse& a, AskLeaderResponse& b) {
     a.Swap(&b);
@@ -2021,7 +2072,7 @@ class MailboxMessage final :
                &_MailboxMessage_default_instance_);
   }
   static constexpr int kIndexInFileMessages =
-    11;
+    12;
 
   friend void swap(MailboxMessage& a, MailboxMessage& b) {
     a.Swap(&b);
@@ -3159,6 +3210,8 @@ RegionStat::mutable_extensions() {
 
 // -------------------------------------------------------------------
 
+// -------------------------------------------------------------------
+
 // FlowStat
 
 // map<uint32, uint64> flow_stat_size = 1;
@@ -3190,6 +3243,35 @@ FlowStat::mutable_flow_stat_size() {
   return _internal_mutable_flow_stat_size();
 }
 
+// map<uint32, int64> flow_last_exec_time_map = 2;
+inline int FlowStat::_internal_flow_last_exec_time_map_size() const {
+  return _impl_.flow_last_exec_time_map_.size();
+}
+inline int FlowStat::flow_last_exec_time_map_size() const {
+  return _internal_flow_last_exec_time_map_size();
+}
+inline void FlowStat::clear_flow_last_exec_time_map() {
+  _impl_.flow_last_exec_time_map_.Clear();
+}
+inline const ::PROTOBUF_NAMESPACE_ID::Map< uint32_t, int64_t >&
+FlowStat::_internal_flow_last_exec_time_map() const {
+  return _impl_.flow_last_exec_time_map_.GetMap();
+}
+inline const ::PROTOBUF_NAMESPACE_ID::Map< uint32_t, int64_t >&
+FlowStat::flow_last_exec_time_map() const {
+  // @@protoc_insertion_point(field_map:greptime.v1.meta.FlowStat.flow_last_exec_time_map)
+  return _internal_flow_last_exec_time_map();
+}
+inline ::PROTOBUF_NAMESPACE_ID::Map< uint32_t, int64_t >*
+FlowStat::_internal_mutable_flow_last_exec_time_map() {
+  return _impl_.flow_last_exec_time_map_.MutableMap();
+}
+inline ::PROTOBUF_NAMESPACE_ID::Map< uint32_t, int64_t >*
+FlowStat::mutable_flow_last_exec_time_map() {
+  // @@protoc_insertion_point(field_mutable_map:greptime.v1.meta.FlowStat.flow_last_exec_time_map)
+  return _internal_mutable_flow_last_exec_time_map();
+}
+
 // -------------------------------------------------------------------
 
 // HeartbeatResponse
@@ -4202,6 +4284,8 @@ inline MailboxMessage::PayloadCase MailboxMessage::payload_case() const {
 
 // -------------------------------------------------------------------
 
+// -------------------------------------------------------------------
+
 
 // @@protoc_insertion_point(namespace_scope)
 
diff --git a/go/greptime/v1/meta/heartbeat.pb.go b/go/greptime/v1/meta/heartbeat.pb.go
index 7dbdbe04..bd57bbdf 100644
--- a/go/greptime/v1/meta/heartbeat.pb.go
+++ b/go/greptime/v1/meta/heartbeat.pb.go
@@ -390,7 +390,8 @@ type FlowStat struct {
 	// Each flow's in mem state's size in bytes
 	// due to protobuf's key can't be a message, so we use uint32 as the key which
 	// is [`FlowId`]'s inner field `id`
-	FlowStatSize map[uint32]uint64 `protobuf:"bytes,1,rep,name=flow_stat_size,json=flowStatSize,proto3" json:"flow_stat_size,omitempty" protobuf_key:"varint,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"`
+	FlowStatSize        map[uint32]uint64 `protobuf:"bytes,1,rep,name=flow_stat_size,json=flowStatSize,proto3" json:"flow_stat_size,omitempty" protobuf_key:"varint,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"`
+	FlowLastExecTimeMap map[uint32]int64  `protobuf:"bytes,2,rep,name=flow_last_exec_time_map,json=flowLastExecTimeMap,proto3" json:"flow_last_exec_time_map,omitempty" protobuf_key:"varint,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"`
 }
 
 func (x *FlowStat) Reset() {
@@ -432,6 +433,13 @@ func (x *FlowStat) GetFlowStatSize() map[uint32]uint64 {
 	return nil
 }
 
+func (x *FlowStat) GetFlowLastExecTimeMap() map[uint32]int64 {
+	if x != nil {
+		return x.FlowLastExecTimeMap
+	}
+	return nil
+}
+
 type HeartbeatResponse struct {
 	state         protoimpl.MessageState
 	sizeCache     protoimpl.SizeCache
@@ -906,94 +914,105 @@ var file_greptime_v1_meta_heartbeat_proto_rawDesc = []byte{
 	0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01,
 	0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65,
 	0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38,
-	0x01, 0x22, 0x9f, 0x01, 0x0a, 0x08, 0x46, 0x6c, 0x6f, 0x77, 0x53, 0x74, 0x61, 0x74, 0x12, 0x52,
+	0x01, 0x22, 0xd2, 0x02, 0x0a, 0x08, 0x46, 0x6c, 0x6f, 0x77, 0x53, 0x74, 0x61, 0x74, 0x12, 0x52,
 	0x0a, 0x0e, 0x66, 0x6c, 0x6f, 0x77, 0x5f, 0x73, 0x74, 0x61, 0x74, 0x5f, 0x73, 0x69, 0x7a, 0x65,
 	0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x2c, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d,
 	0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x46, 0x6c, 0x6f, 0x77, 0x53, 0x74,
 	0x61, 0x74, 0x2e, 0x46, 0x6c, 0x6f, 0x77, 0x53, 0x74, 0x61, 0x74, 0x53, 0x69, 0x7a, 0x65, 0x45,
 	0x6e, 0x74, 0x72, 0x79, 0x52, 0x0c, 0x66, 0x6c, 0x6f, 0x77, 0x53, 0x74, 0x61, 0x74, 0x53, 0x69,
-	0x7a, 0x65, 0x1a, 0x3f, 0x0a, 0x11, 0x46, 0x6c, 0x6f, 0x77, 0x53, 0x74, 0x61, 0x74, 0x53, 0x69,
-	0x7a, 0x65, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01,
-	0x20, 0x01, 0x28, 0x0d, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c,
-	0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x04, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a,
-	0x02, 0x38, 0x01, 0x22, 0xda, 0x01, 0x0a, 0x11, 0x48, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61,
-	0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x38, 0x0a, 0x06, 0x68, 0x65, 0x61,
+	0x7a, 0x65, 0x12, 0x69, 0x0a, 0x17, 0x66, 0x6c, 0x6f, 0x77, 0x5f, 0x6c, 0x61, 0x73, 0x74, 0x5f,
+	0x65, 0x78, 0x65, 0x63, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x5f, 0x6d, 0x61, 0x70, 0x18, 0x02, 0x20,
+	0x03, 0x28, 0x0b, 0x32, 0x33, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76,
+	0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x46, 0x6c, 0x6f, 0x77, 0x53, 0x74, 0x61, 0x74, 0x2e,
+	0x46, 0x6c, 0x6f, 0x77, 0x4c, 0x61, 0x73, 0x74, 0x45, 0x78, 0x65, 0x63, 0x54, 0x69, 0x6d, 0x65,
+	0x4d, 0x61, 0x70, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x13, 0x66, 0x6c, 0x6f, 0x77, 0x4c, 0x61,
+	0x73, 0x74, 0x45, 0x78, 0x65, 0x63, 0x54, 0x69, 0x6d, 0x65, 0x4d, 0x61, 0x70, 0x1a, 0x3f, 0x0a,
+	0x11, 0x46, 0x6c, 0x6f, 0x77, 0x53, 0x74, 0x61, 0x74, 0x53, 0x69, 0x7a, 0x65, 0x45, 0x6e, 0x74,
+	0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52,
+	0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20,
+	0x01, 0x28, 0x04, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x1a, 0x46,
+	0x0a, 0x18, 0x46, 0x6c, 0x6f, 0x77, 0x4c, 0x61, 0x73, 0x74, 0x45, 0x78, 0x65, 0x63, 0x54, 0x69,
+	0x6d, 0x65, 0x4d, 0x61, 0x70, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65,
+	0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05,
+	0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x05, 0x76, 0x61, 0x6c,
+	0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0xda, 0x01, 0x0a, 0x11, 0x48, 0x65, 0x61, 0x72, 0x74,
+	0x62, 0x65, 0x61, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x38, 0x0a, 0x06,
+	0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x67,
+	0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e,
+	0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x52, 0x06,
+	0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x12, 0x49, 0x0a, 0x0f, 0x6d, 0x61, 0x69, 0x6c, 0x62, 0x6f,
+	0x78, 0x5f, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32,
+	0x20, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65,
+	0x74, 0x61, 0x2e, 0x4d, 0x61, 0x69, 0x6c, 0x62, 0x6f, 0x78, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67,
+	0x65, 0x52, 0x0e, 0x6d, 0x61, 0x69, 0x6c, 0x62, 0x6f, 0x78, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67,
+	0x65, 0x12, 0x40, 0x0a, 0x0c, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x5f, 0x6c, 0x65, 0x61, 0x73,
+	0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69,
+	0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x52, 0x65, 0x67, 0x69, 0x6f,
+	0x6e, 0x4c, 0x65, 0x61, 0x73, 0x65, 0x52, 0x0b, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x4c, 0x65,
+	0x61, 0x73, 0x65, 0x22, 0x5e, 0x0a, 0x0d, 0x47, 0x72, 0x61, 0x6e, 0x74, 0x65, 0x64, 0x52, 0x65,
+	0x67, 0x69, 0x6f, 0x6e, 0x12, 0x1b, 0x0a, 0x09, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x5f, 0x69,
+	0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x04, 0x52, 0x08, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x49,
+	0x64, 0x12, 0x30, 0x0a, 0x04, 0x72, 0x6f, 0x6c, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0e, 0x32,
+	0x1c, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65,
+	0x74, 0x61, 0x2e, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x52, 0x6f, 0x6c, 0x65, 0x52, 0x04, 0x72,
+	0x6f, 0x6c, 0x65, 0x22, 0xd1, 0x01, 0x0a, 0x0b, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x4c, 0x65,
+	0x61, 0x73, 0x65, 0x12, 0x39, 0x0a, 0x07, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x01,
+	0x20, 0x03, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e,
+	0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x47, 0x72, 0x61, 0x6e, 0x74, 0x65, 0x64, 0x52,
+	0x65, 0x67, 0x69, 0x6f, 0x6e, 0x52, 0x07, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x30,
+	0x0a, 0x14, 0x64, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x73, 0x69, 0x6e, 0x63, 0x65,
+	0x5f, 0x65, 0x70, 0x6f, 0x63, 0x68, 0x18, 0x02, 0x20, 0x01, 0x28, 0x04, 0x52, 0x12, 0x64, 0x75,
+	0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x69, 0x6e, 0x63, 0x65, 0x45, 0x70, 0x6f, 0x63, 0x68,
+	0x12, 0x23, 0x0a, 0x0d, 0x6c, 0x65, 0x61, 0x73, 0x65, 0x5f, 0x73, 0x65, 0x63, 0x6f, 0x6e, 0x64,
+	0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0c, 0x6c, 0x65, 0x61, 0x73, 0x65, 0x53, 0x65,
+	0x63, 0x6f, 0x6e, 0x64, 0x73, 0x12, 0x30, 0x0a, 0x14, 0x63, 0x6c, 0x6f, 0x73, 0x65, 0x61, 0x62,
+	0x6c, 0x65, 0x5f, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x73, 0x18, 0x04, 0x20,
+	0x03, 0x28, 0x04, 0x52, 0x12, 0x63, 0x6c, 0x6f, 0x73, 0x65, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x65,
+	0x67, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x73, 0x22, 0x4b, 0x0a, 0x10, 0x41, 0x73, 0x6b, 0x4c, 0x65,
+	0x61, 0x64, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x37, 0x0a, 0x06, 0x68,
+	0x65, 0x61, 0x64, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x67, 0x72,
+	0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x52,
+	0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x52, 0x06, 0x68, 0x65,
+	0x61, 0x64, 0x65, 0x72, 0x22, 0x7d, 0x0a, 0x11, 0x41, 0x73, 0x6b, 0x4c, 0x65, 0x61, 0x64, 0x65,
+	0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x38, 0x0a, 0x06, 0x68, 0x65, 0x61,
 	0x64, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x67, 0x72, 0x65, 0x70,
 	0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x52, 0x65, 0x73,
 	0x70, 0x6f, 0x6e, 0x73, 0x65, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x52, 0x06, 0x68, 0x65, 0x61,
-	0x64, 0x65, 0x72, 0x12, 0x49, 0x0a, 0x0f, 0x6d, 0x61, 0x69, 0x6c, 0x62, 0x6f, 0x78, 0x5f, 0x6d,
-	0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x67,
-	0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e,
-	0x4d, 0x61, 0x69, 0x6c, 0x62, 0x6f, 0x78, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x52, 0x0e,
-	0x6d, 0x61, 0x69, 0x6c, 0x62, 0x6f, 0x78, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x40,
-	0x0a, 0x0c, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x5f, 0x6c, 0x65, 0x61, 0x73, 0x65, 0x18, 0x03,
-	0x20, 0x01, 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e,
-	0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x4c, 0x65,
-	0x61, 0x73, 0x65, 0x52, 0x0b, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x4c, 0x65, 0x61, 0x73, 0x65,
-	0x22, 0x5e, 0x0a, 0x0d, 0x47, 0x72, 0x61, 0x6e, 0x74, 0x65, 0x64, 0x52, 0x65, 0x67, 0x69, 0x6f,
-	0x6e, 0x12, 0x1b, 0x0a, 0x09, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x01,
-	0x20, 0x01, 0x28, 0x04, 0x52, 0x08, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x12, 0x30,
-	0x0a, 0x04, 0x72, 0x6f, 0x6c, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x1c, 0x2e, 0x67,
-	0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e,
-	0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x52, 0x6f, 0x6c, 0x65, 0x52, 0x04, 0x72, 0x6f, 0x6c, 0x65,
-	0x22, 0xd1, 0x01, 0x0a, 0x0b, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x4c, 0x65, 0x61, 0x73, 0x65,
-	0x12, 0x39, 0x0a, 0x07, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28,
-	0x0b, 0x32, 0x1f, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e,
-	0x6d, 0x65, 0x74, 0x61, 0x2e, 0x47, 0x72, 0x61, 0x6e, 0x74, 0x65, 0x64, 0x52, 0x65, 0x67, 0x69,
-	0x6f, 0x6e, 0x52, 0x07, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x30, 0x0a, 0x14, 0x64,
-	0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x73, 0x69, 0x6e, 0x63, 0x65, 0x5f, 0x65, 0x70,
-	0x6f, 0x63, 0x68, 0x18, 0x02, 0x20, 0x01, 0x28, 0x04, 0x52, 0x12, 0x64, 0x75, 0x72, 0x61, 0x74,
-	0x69, 0x6f, 0x6e, 0x53, 0x69, 0x6e, 0x63, 0x65, 0x45, 0x70, 0x6f, 0x63, 0x68, 0x12, 0x23, 0x0a,
-	0x0d, 0x6c, 0x65, 0x61, 0x73, 0x65, 0x5f, 0x73, 0x65, 0x63, 0x6f, 0x6e, 0x64, 0x73, 0x18, 0x03,
-	0x20, 0x01, 0x28, 0x04, 0x52, 0x0c, 0x6c, 0x65, 0x61, 0x73, 0x65, 0x53, 0x65, 0x63, 0x6f, 0x6e,
-	0x64, 0x73, 0x12, 0x30, 0x0a, 0x14, 0x63, 0x6c, 0x6f, 0x73, 0x65, 0x61, 0x62, 0x6c, 0x65, 0x5f,
-	0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x73, 0x18, 0x04, 0x20, 0x03, 0x28, 0x04,
-	0x52, 0x12, 0x63, 0x6c, 0x6f, 0x73, 0x65, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x65, 0x67, 0x69, 0x6f,
-	0x6e, 0x49, 0x64, 0x73, 0x22, 0x4b, 0x0a, 0x10, 0x41, 0x73, 0x6b, 0x4c, 0x65, 0x61, 0x64, 0x65,
-	0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x37, 0x0a, 0x06, 0x68, 0x65, 0x61, 0x64,
-	0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74,
-	0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x52, 0x65, 0x71, 0x75,
-	0x65, 0x73, 0x74, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x52, 0x06, 0x68, 0x65, 0x61, 0x64, 0x65,
-	0x72, 0x22, 0x7d, 0x0a, 0x11, 0x41, 0x73, 0x6b, 0x4c, 0x65, 0x61, 0x64, 0x65, 0x72, 0x52, 0x65,
-	0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x38, 0x0a, 0x06, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72,
-	0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d,
-	0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
-	0x73, 0x65, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x52, 0x06, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72,
-	0x12, 0x2e, 0x0a, 0x06, 0x6c, 0x65, 0x61, 0x64, 0x65, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b,
-	0x32, 0x16, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d,
-	0x65, 0x74, 0x61, 0x2e, 0x50, 0x65, 0x65, 0x72, 0x52, 0x06, 0x6c, 0x65, 0x61, 0x64, 0x65, 0x72,
-	0x22, 0xaa, 0x01, 0x0a, 0x0e, 0x4d, 0x61, 0x69, 0x6c, 0x62, 0x6f, 0x78, 0x4d, 0x65, 0x73, 0x73,
-	0x61, 0x67, 0x65, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x04, 0x52,
-	0x02, 0x69, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x73, 0x75, 0x62, 0x6a, 0x65, 0x63, 0x74, 0x18, 0x02,
-	0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x73, 0x75, 0x62, 0x6a, 0x65, 0x63, 0x74, 0x12, 0x12, 0x0a,
-	0x04, 0x66, 0x72, 0x6f, 0x6d, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x66, 0x72, 0x6f,
-	0x6d, 0x12, 0x0e, 0x0a, 0x02, 0x74, 0x6f, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x02, 0x74,
-	0x6f, 0x12, 0x29, 0x0a, 0x10, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x5f, 0x6d,
-	0x69, 0x6c, 0x6c, 0x69, 0x73, 0x18, 0x05, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0f, 0x74, 0x69, 0x6d,
-	0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x4d, 0x69, 0x6c, 0x6c, 0x69, 0x73, 0x12, 0x14, 0x0a, 0x04,
-	0x6a, 0x73, 0x6f, 0x6e, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x48, 0x00, 0x52, 0x04, 0x6a, 0x73,
-	0x6f, 0x6e, 0x42, 0x09, 0x0a, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x2a, 0x3d, 0x0a,
-	0x0a, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x52, 0x6f, 0x6c, 0x65, 0x12, 0x0a, 0x0a, 0x06, 0x4c,
-	0x65, 0x61, 0x64, 0x65, 0x72, 0x10, 0x00, 0x12, 0x0c, 0x0a, 0x08, 0x46, 0x6f, 0x6c, 0x6c, 0x6f,
-	0x77, 0x65, 0x72, 0x10, 0x01, 0x12, 0x15, 0x0a, 0x11, 0x44, 0x6f, 0x77, 0x6e, 0x67, 0x72, 0x61,
-	0x64, 0x69, 0x6e, 0x67, 0x4c, 0x65, 0x61, 0x64, 0x65, 0x72, 0x10, 0x02, 0x32, 0xbf, 0x01, 0x0a,
-	0x09, 0x48, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x12, 0x5a, 0x0a, 0x09, 0x48, 0x65,
-	0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x12, 0x22, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69,
-	0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x48, 0x65, 0x61, 0x72, 0x74,
-	0x62, 0x65, 0x61, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x23, 0x2e, 0x67, 0x72,
-	0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x48,
-	0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
-	0x22, 0x00, 0x28, 0x01, 0x30, 0x01, 0x12, 0x56, 0x0a, 0x09, 0x41, 0x73, 0x6b, 0x4c, 0x65, 0x61,
-	0x64, 0x65, 0x72, 0x12, 0x22, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76,
-	0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x41, 0x73, 0x6b, 0x4c, 0x65, 0x61, 0x64, 0x65, 0x72,
-	0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x23, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69,
-	0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x41, 0x73, 0x6b, 0x4c, 0x65,
-	0x61, 0x64, 0x65, 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x42, 0x3c,
-	0x5a, 0x3a, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x47, 0x72, 0x65,
-	0x70, 0x74, 0x69, 0x6d, 0x65, 0x54, 0x65, 0x61, 0x6d, 0x2f, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69,
-	0x6d, 0x65, 0x2d, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x2f, 0x67, 0x72, 0x65, 0x70,
-	0x74, 0x69, 0x6d, 0x65, 0x2f, 0x76, 0x31, 0x2f, 0x6d, 0x65, 0x74, 0x61, 0x62, 0x06, 0x70, 0x72,
-	0x6f, 0x74, 0x6f, 0x33,
+	0x64, 0x65, 0x72, 0x12, 0x2e, 0x0a, 0x06, 0x6c, 0x65, 0x61, 0x64, 0x65, 0x72, 0x18, 0x02, 0x20,
+	0x01, 0x28, 0x0b, 0x32, 0x16, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76,
+	0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x50, 0x65, 0x65, 0x72, 0x52, 0x06, 0x6c, 0x65, 0x61,
+	0x64, 0x65, 0x72, 0x22, 0xaa, 0x01, 0x0a, 0x0e, 0x4d, 0x61, 0x69, 0x6c, 0x62, 0x6f, 0x78, 0x4d,
+	0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01,
+	0x28, 0x04, 0x52, 0x02, 0x69, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x73, 0x75, 0x62, 0x6a, 0x65, 0x63,
+	0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x73, 0x75, 0x62, 0x6a, 0x65, 0x63, 0x74,
+	0x12, 0x12, 0x0a, 0x04, 0x66, 0x72, 0x6f, 0x6d, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04,
+	0x66, 0x72, 0x6f, 0x6d, 0x12, 0x0e, 0x0a, 0x02, 0x74, 0x6f, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09,
+	0x52, 0x02, 0x74, 0x6f, 0x12, 0x29, 0x0a, 0x10, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d,
+	0x70, 0x5f, 0x6d, 0x69, 0x6c, 0x6c, 0x69, 0x73, 0x18, 0x05, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0f,
+	0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x4d, 0x69, 0x6c, 0x6c, 0x69, 0x73, 0x12,
+	0x14, 0x0a, 0x04, 0x6a, 0x73, 0x6f, 0x6e, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x48, 0x00, 0x52,
+	0x04, 0x6a, 0x73, 0x6f, 0x6e, 0x42, 0x09, 0x0a, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64,
+	0x2a, 0x3d, 0x0a, 0x0a, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x52, 0x6f, 0x6c, 0x65, 0x12, 0x0a,
+	0x0a, 0x06, 0x4c, 0x65, 0x61, 0x64, 0x65, 0x72, 0x10, 0x00, 0x12, 0x0c, 0x0a, 0x08, 0x46, 0x6f,
+	0x6c, 0x6c, 0x6f, 0x77, 0x65, 0x72, 0x10, 0x01, 0x12, 0x15, 0x0a, 0x11, 0x44, 0x6f, 0x77, 0x6e,
+	0x67, 0x72, 0x61, 0x64, 0x69, 0x6e, 0x67, 0x4c, 0x65, 0x61, 0x64, 0x65, 0x72, 0x10, 0x02, 0x32,
+	0xbf, 0x01, 0x0a, 0x09, 0x48, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x12, 0x5a, 0x0a,
+	0x09, 0x48, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x12, 0x22, 0x2e, 0x67, 0x72, 0x65,
+	0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x48, 0x65,
+	0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x23,
+	0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74,
+	0x61, 0x2e, 0x48, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f,
+	0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x30, 0x01, 0x12, 0x56, 0x0a, 0x09, 0x41, 0x73, 0x6b,
+	0x4c, 0x65, 0x61, 0x64, 0x65, 0x72, 0x12, 0x22, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d,
+	0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x41, 0x73, 0x6b, 0x4c, 0x65, 0x61,
+	0x64, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x23, 0x2e, 0x67, 0x72, 0x65,
+	0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x41, 0x73,
+	0x6b, 0x4c, 0x65, 0x61, 0x64, 0x65, 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22,
+	0x00, 0x42, 0x3c, 0x5a, 0x3a, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f,
+	0x47, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x54, 0x65, 0x61, 0x6d, 0x2f, 0x67, 0x72, 0x65,
+	0x70, 0x74, 0x69, 0x6d, 0x65, 0x2d, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x2f, 0x67,
+	0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2f, 0x76, 0x31, 0x2f, 0x6d, 0x65, 0x74, 0x61, 0x62,
+	0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
 }
 
 var (
@@ -1009,7 +1028,7 @@ func file_greptime_v1_meta_heartbeat_proto_rawDescGZIP() []byte {
 }
 
 var file_greptime_v1_meta_heartbeat_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
-var file_greptime_v1_meta_heartbeat_proto_msgTypes = make([]protoimpl.MessageInfo, 12)
+var file_greptime_v1_meta_heartbeat_proto_msgTypes = make([]protoimpl.MessageInfo, 13)
 var file_greptime_v1_meta_heartbeat_proto_goTypes = []interface{}{
 	(RegionRole)(0),           // 0: greptime.v1.meta.RegionRole
 	(*HeartbeatRequest)(nil),  // 1: greptime.v1.meta.HeartbeatRequest
@@ -1024,15 +1043,16 @@ var file_greptime_v1_meta_heartbeat_proto_goTypes = []interface{}{
 	(*MailboxMessage)(nil),    // 10: greptime.v1.meta.MailboxMessage
 	nil,                       // 11: greptime.v1.meta.RegionStat.ExtensionsEntry
 	nil,                       // 12: greptime.v1.meta.FlowStat.FlowStatSizeEntry
-	(*RequestHeader)(nil),     // 13: greptime.v1.meta.RequestHeader
-	(*Peer)(nil),              // 14: greptime.v1.meta.Peer
-	(*TimeInterval)(nil),      // 15: greptime.v1.meta.TimeInterval
-	(*ResponseHeader)(nil),    // 16: greptime.v1.meta.ResponseHeader
+	nil,                       // 13: greptime.v1.meta.FlowStat.FlowLastExecTimeMapEntry
+	(*RequestHeader)(nil),     // 14: greptime.v1.meta.RequestHeader
+	(*Peer)(nil),              // 15: greptime.v1.meta.Peer
+	(*TimeInterval)(nil),      // 16: greptime.v1.meta.TimeInterval
+	(*ResponseHeader)(nil),    // 17: greptime.v1.meta.ResponseHeader
 }
 var file_greptime_v1_meta_heartbeat_proto_depIdxs = []int32{
-	13, // 0: greptime.v1.meta.HeartbeatRequest.header:type_name -> greptime.v1.meta.RequestHeader
-	14, // 1: greptime.v1.meta.HeartbeatRequest.peer:type_name -> greptime.v1.meta.Peer
-	15, // 2: greptime.v1.meta.HeartbeatRequest.report_interval:type_name -> greptime.v1.meta.TimeInterval
+	14, // 0: greptime.v1.meta.HeartbeatRequest.header:type_name -> greptime.v1.meta.RequestHeader
+	15, // 1: greptime.v1.meta.HeartbeatRequest.peer:type_name -> greptime.v1.meta.Peer
+	16, // 2: greptime.v1.meta.HeartbeatRequest.report_interval:type_name -> greptime.v1.meta.TimeInterval
 	3,  // 3: greptime.v1.meta.HeartbeatRequest.region_stats:type_name -> greptime.v1.meta.RegionStat
 	10, // 4: greptime.v1.meta.HeartbeatRequest.mailbox_message:type_name -> greptime.v1.meta.MailboxMessage
 	2,  // 5: greptime.v1.meta.HeartbeatRequest.info:type_name -> greptime.v1.meta.NodeInfo
@@ -1040,23 +1060,24 @@ var file_greptime_v1_meta_heartbeat_proto_depIdxs = []int32{
 	0,  // 7: greptime.v1.meta.RegionStat.role:type_name -> greptime.v1.meta.RegionRole
 	11, // 8: greptime.v1.meta.RegionStat.extensions:type_name -> greptime.v1.meta.RegionStat.ExtensionsEntry
 	12, // 9: greptime.v1.meta.FlowStat.flow_stat_size:type_name -> greptime.v1.meta.FlowStat.FlowStatSizeEntry
-	16, // 10: greptime.v1.meta.HeartbeatResponse.header:type_name -> greptime.v1.meta.ResponseHeader
-	10, // 11: greptime.v1.meta.HeartbeatResponse.mailbox_message:type_name -> greptime.v1.meta.MailboxMessage
-	7,  // 12: greptime.v1.meta.HeartbeatResponse.region_lease:type_name -> greptime.v1.meta.RegionLease
-	0,  // 13: greptime.v1.meta.GrantedRegion.role:type_name -> greptime.v1.meta.RegionRole
-	6,  // 14: greptime.v1.meta.RegionLease.regions:type_name -> greptime.v1.meta.GrantedRegion
-	13, // 15: greptime.v1.meta.AskLeaderRequest.header:type_name -> greptime.v1.meta.RequestHeader
-	16, // 16: greptime.v1.meta.AskLeaderResponse.header:type_name -> greptime.v1.meta.ResponseHeader
-	14, // 17: greptime.v1.meta.AskLeaderResponse.leader:type_name -> greptime.v1.meta.Peer
-	1,  // 18: greptime.v1.meta.Heartbeat.Heartbeat:input_type -> greptime.v1.meta.HeartbeatRequest
-	8,  // 19: greptime.v1.meta.Heartbeat.AskLeader:input_type -> greptime.v1.meta.AskLeaderRequest
-	5,  // 20: greptime.v1.meta.Heartbeat.Heartbeat:output_type -> greptime.v1.meta.HeartbeatResponse
-	9,  // 21: greptime.v1.meta.Heartbeat.AskLeader:output_type -> greptime.v1.meta.AskLeaderResponse
-	20, // [20:22] is the sub-list for method output_type
-	18, // [18:20] is the sub-list for method input_type
-	18, // [18:18] is the sub-list for extension type_name
-	18, // [18:18] is the sub-list for extension extendee
-	0,  // [0:18] is the sub-list for field type_name
+	13, // 10: greptime.v1.meta.FlowStat.flow_last_exec_time_map:type_name -> greptime.v1.meta.FlowStat.FlowLastExecTimeMapEntry
+	17, // 11: greptime.v1.meta.HeartbeatResponse.header:type_name -> greptime.v1.meta.ResponseHeader
+	10, // 12: greptime.v1.meta.HeartbeatResponse.mailbox_message:type_name -> greptime.v1.meta.MailboxMessage
+	7,  // 13: greptime.v1.meta.HeartbeatResponse.region_lease:type_name -> greptime.v1.meta.RegionLease
+	0,  // 14: greptime.v1.meta.GrantedRegion.role:type_name -> greptime.v1.meta.RegionRole
+	6,  // 15: greptime.v1.meta.RegionLease.regions:type_name -> greptime.v1.meta.GrantedRegion
+	14, // 16: greptime.v1.meta.AskLeaderRequest.header:type_name -> greptime.v1.meta.RequestHeader
+	17, // 17: greptime.v1.meta.AskLeaderResponse.header:type_name -> greptime.v1.meta.ResponseHeader
+	15, // 18: greptime.v1.meta.AskLeaderResponse.leader:type_name -> greptime.v1.meta.Peer
+	1,  // 19: greptime.v1.meta.Heartbeat.Heartbeat:input_type -> greptime.v1.meta.HeartbeatRequest
+	8,  // 20: greptime.v1.meta.Heartbeat.AskLeader:input_type -> greptime.v1.meta.AskLeaderRequest
+	5,  // 21: greptime.v1.meta.Heartbeat.Heartbeat:output_type -> greptime.v1.meta.HeartbeatResponse
+	9,  // 22: greptime.v1.meta.Heartbeat.AskLeader:output_type -> greptime.v1.meta.AskLeaderResponse
+	21, // [21:23] is the sub-list for method output_type
+	19, // [19:21] is the sub-list for method input_type
+	19, // [19:19] is the sub-list for extension type_name
+	19, // [19:19] is the sub-list for extension extendee
+	0,  // [0:19] is the sub-list for field type_name
 }
 
 func init() { file_greptime_v1_meta_heartbeat_proto_init() }
@@ -1196,7 +1217,7 @@ func file_greptime_v1_meta_heartbeat_proto_init() {
 			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
 			RawDescriptor: file_greptime_v1_meta_heartbeat_proto_rawDesc,
 			NumEnums:      1,
-			NumMessages:   12,
+			NumMessages:   13,
 			NumExtensions: 0,
 			NumServices:   1,
 		},
diff --git a/java/src/main/java/greptime/v1/meta/HeartbeatOuterClass.java b/java/src/main/java/greptime/v1/meta/HeartbeatOuterClass.java
index 0f51933a..af55bc4f 100644
--- a/java/src/main/java/greptime/v1/meta/HeartbeatOuterClass.java
+++ b/java/src/main/java/greptime/v1/meta/HeartbeatOuterClass.java
@@ -5106,6 +5106,40 @@ long getFlowStatSizeOrDefault(
 
     long getFlowStatSizeOrThrow(
         int key);
+
+    /**
+     * <code>map&lt;uint32, int64&gt; flow_last_exec_time_map = 2;</code>
+     */
+    int getFlowLastExecTimeMapCount();
+    /**
+     * <code>map&lt;uint32, int64&gt; flow_last_exec_time_map = 2;</code>
+     */
+    boolean containsFlowLastExecTimeMap(
+        int key);
+    /**
+     * Use {@link #getFlowLastExecTimeMapMap()} instead.
+     */
+    @java.lang.Deprecated
+    java.util.Map<java.lang.Integer, java.lang.Long>
+    getFlowLastExecTimeMap();
+    /**
+     * <code>map&lt;uint32, int64&gt; flow_last_exec_time_map = 2;</code>
+     */
+    java.util.Map<java.lang.Integer, java.lang.Long>
+    getFlowLastExecTimeMapMap();
+    /**
+     * <code>map&lt;uint32, int64&gt; flow_last_exec_time_map = 2;</code>
+     */
+
+    long getFlowLastExecTimeMapOrDefault(
+        int key,
+        long defaultValue);
+    /**
+     * <code>map&lt;uint32, int64&gt; flow_last_exec_time_map = 2;</code>
+     */
+
+    long getFlowLastExecTimeMapOrThrow(
+        int key);
   }
   /**
    * Protobuf type {@code greptime.v1.meta.FlowStat}
@@ -5166,6 +5200,19 @@ private FlowStat(
                   flowStatSize__.getKey(), flowStatSize__.getValue());
               break;
             }
+            case 18: {
+              if (!((mutable_bitField0_ & 0x00000002) != 0)) {
+                flowLastExecTimeMap_ = com.google.protobuf.MapField.newMapField(
+                    FlowLastExecTimeMapDefaultEntryHolder.defaultEntry);
+                mutable_bitField0_ |= 0x00000002;
+              }
+              com.google.protobuf.MapEntry<java.lang.Integer, java.lang.Long>
+              flowLastExecTimeMap__ = input.readMessage(
+                  FlowLastExecTimeMapDefaultEntryHolder.defaultEntry.getParserForType(), extensionRegistry);
+              flowLastExecTimeMap_.getMutableMap().put(
+                  flowLastExecTimeMap__.getKey(), flowLastExecTimeMap__.getValue());
+              break;
+            }
             default: {
               if (!parseUnknownField(
                   input, unknownFields, extensionRegistry, tag)) {
@@ -5199,6 +5246,8 @@ protected com.google.protobuf.MapField internalGetMapField(
       switch (number) {
         case 1:
           return internalGetFlowStatSize();
+        case 2:
+          return internalGetFlowLastExecTimeMap();
         default:
           throw new RuntimeException(
               "Invalid map field number: " + number);
@@ -5317,6 +5366,87 @@ public long getFlowStatSizeOrThrow(
       return map.get(key);
     }
 
+    public static final int FLOW_LAST_EXEC_TIME_MAP_FIELD_NUMBER = 2;
+    private static final class FlowLastExecTimeMapDefaultEntryHolder {
+      static final com.google.protobuf.MapEntry<
+          java.lang.Integer, java.lang.Long> defaultEntry =
+              com.google.protobuf.MapEntry
+              .<java.lang.Integer, java.lang.Long>newDefaultInstance(
+                  greptime.v1.meta.HeartbeatOuterClass.internal_static_greptime_v1_meta_FlowStat_FlowLastExecTimeMapEntry_descriptor, 
+                  com.google.protobuf.WireFormat.FieldType.UINT32,
+                  0,
+                  com.google.protobuf.WireFormat.FieldType.INT64,
+                  0L);
+    }
+    private com.google.protobuf.MapField<
+        java.lang.Integer, java.lang.Long> flowLastExecTimeMap_;
+    private com.google.protobuf.MapField<java.lang.Integer, java.lang.Long>
+    internalGetFlowLastExecTimeMap() {
+      if (flowLastExecTimeMap_ == null) {
+        return com.google.protobuf.MapField.emptyMapField(
+            FlowLastExecTimeMapDefaultEntryHolder.defaultEntry);
+      }
+      return flowLastExecTimeMap_;
+    }
+
+    public int getFlowLastExecTimeMapCount() {
+      return internalGetFlowLastExecTimeMap().getMap().size();
+    }
+    /**
+     * <code>map&lt;uint32, int64&gt; flow_last_exec_time_map = 2;</code>
+     */
+
+    @java.lang.Override
+    public boolean containsFlowLastExecTimeMap(
+        int key) {
+      
+      return internalGetFlowLastExecTimeMap().getMap().containsKey(key);
+    }
+    /**
+     * Use {@link #getFlowLastExecTimeMapMap()} instead.
+     */
+    @java.lang.Override
+    @java.lang.Deprecated
+    public java.util.Map<java.lang.Integer, java.lang.Long> getFlowLastExecTimeMap() {
+      return getFlowLastExecTimeMapMap();
+    }
+    /**
+     * <code>map&lt;uint32, int64&gt; flow_last_exec_time_map = 2;</code>
+     */
+    @java.lang.Override
+
+    public java.util.Map<java.lang.Integer, java.lang.Long> getFlowLastExecTimeMapMap() {
+      return internalGetFlowLastExecTimeMap().getMap();
+    }
+    /**
+     * <code>map&lt;uint32, int64&gt; flow_last_exec_time_map = 2;</code>
+     */
+    @java.lang.Override
+
+    public long getFlowLastExecTimeMapOrDefault(
+        int key,
+        long defaultValue) {
+      
+      java.util.Map<java.lang.Integer, java.lang.Long> map =
+          internalGetFlowLastExecTimeMap().getMap();
+      return map.containsKey(key) ? map.get(key) : defaultValue;
+    }
+    /**
+     * <code>map&lt;uint32, int64&gt; flow_last_exec_time_map = 2;</code>
+     */
+    @java.lang.Override
+
+    public long getFlowLastExecTimeMapOrThrow(
+        int key) {
+      
+      java.util.Map<java.lang.Integer, java.lang.Long> map =
+          internalGetFlowLastExecTimeMap().getMap();
+      if (!map.containsKey(key)) {
+        throw new java.lang.IllegalArgumentException();
+      }
+      return map.get(key);
+    }
+
     private byte memoizedIsInitialized = -1;
     @java.lang.Override
     public final boolean isInitialized() {
@@ -5337,6 +5467,12 @@ public void writeTo(com.google.protobuf.CodedOutputStream output)
           internalGetFlowStatSize(),
           FlowStatSizeDefaultEntryHolder.defaultEntry,
           1);
+      com.google.protobuf.GeneratedMessageV3
+        .serializeIntegerMapTo(
+          output,
+          internalGetFlowLastExecTimeMap(),
+          FlowLastExecTimeMapDefaultEntryHolder.defaultEntry,
+          2);
       unknownFields.writeTo(output);
     }
 
@@ -5356,6 +5492,16 @@ public int getSerializedSize() {
         size += com.google.protobuf.CodedOutputStream
             .computeMessageSize(1, flowStatSize__);
       }
+      for (java.util.Map.Entry<java.lang.Integer, java.lang.Long> entry
+           : internalGetFlowLastExecTimeMap().getMap().entrySet()) {
+        com.google.protobuf.MapEntry<java.lang.Integer, java.lang.Long>
+        flowLastExecTimeMap__ = FlowLastExecTimeMapDefaultEntryHolder.defaultEntry.newBuilderForType()
+            .setKey(entry.getKey())
+            .setValue(entry.getValue())
+            .build();
+        size += com.google.protobuf.CodedOutputStream
+            .computeMessageSize(2, flowLastExecTimeMap__);
+      }
       size += unknownFields.getSerializedSize();
       memoizedSize = size;
       return size;
@@ -5373,6 +5519,8 @@ public boolean equals(final java.lang.Object obj) {
 
       if (!internalGetFlowStatSize().equals(
           other.internalGetFlowStatSize())) return false;
+      if (!internalGetFlowLastExecTimeMap().equals(
+          other.internalGetFlowLastExecTimeMap())) return false;
       if (!unknownFields.equals(other.unknownFields)) return false;
       return true;
     }
@@ -5388,6 +5536,10 @@ public int hashCode() {
         hash = (37 * hash) + FLOW_STAT_SIZE_FIELD_NUMBER;
         hash = (53 * hash) + internalGetFlowStatSize().hashCode();
       }
+      if (!internalGetFlowLastExecTimeMap().getMap().isEmpty()) {
+        hash = (37 * hash) + FLOW_LAST_EXEC_TIME_MAP_FIELD_NUMBER;
+        hash = (53 * hash) + internalGetFlowLastExecTimeMap().hashCode();
+      }
       hash = (29 * hash) + unknownFields.hashCode();
       memoizedHashCode = hash;
       return hash;
@@ -5501,6 +5653,8 @@ protected com.google.protobuf.MapField internalGetMapField(
         switch (number) {
           case 1:
             return internalGetFlowStatSize();
+          case 2:
+            return internalGetFlowLastExecTimeMap();
           default:
             throw new RuntimeException(
                 "Invalid map field number: " + number);
@@ -5512,6 +5666,8 @@ protected com.google.protobuf.MapField internalGetMutableMapField(
         switch (number) {
           case 1:
             return internalGetMutableFlowStatSize();
+          case 2:
+            return internalGetMutableFlowLastExecTimeMap();
           default:
             throw new RuntimeException(
                 "Invalid map field number: " + number);
@@ -5544,6 +5700,7 @@ private void maybeForceBuilderInitialization() {
       public Builder clear() {
         super.clear();
         internalGetMutableFlowStatSize().clear();
+        internalGetMutableFlowLastExecTimeMap().clear();
         return this;
       }
 
@@ -5573,6 +5730,8 @@ public greptime.v1.meta.HeartbeatOuterClass.FlowStat buildPartial() {
         int from_bitField0_ = bitField0_;
         result.flowStatSize_ = internalGetFlowStatSize();
         result.flowStatSize_.makeImmutable();
+        result.flowLastExecTimeMap_ = internalGetFlowLastExecTimeMap();
+        result.flowLastExecTimeMap_.makeImmutable();
         onBuilt();
         return result;
       }
@@ -5623,6 +5782,8 @@ public Builder mergeFrom(greptime.v1.meta.HeartbeatOuterClass.FlowStat other) {
         if (other == greptime.v1.meta.HeartbeatOuterClass.FlowStat.getDefaultInstance()) return this;
         internalGetMutableFlowStatSize().mergeFrom(
             other.internalGetFlowStatSize());
+        internalGetMutableFlowLastExecTimeMap().mergeFrom(
+            other.internalGetFlowLastExecTimeMap());
         this.mergeUnknownFields(other.unknownFields);
         onChanged();
         return this;
@@ -5822,6 +5983,134 @@ public Builder putAllFlowStatSize(
             .putAll(values);
         return this;
       }
+
+      private com.google.protobuf.MapField<
+          java.lang.Integer, java.lang.Long> flowLastExecTimeMap_;
+      private com.google.protobuf.MapField<java.lang.Integer, java.lang.Long>
+      internalGetFlowLastExecTimeMap() {
+        if (flowLastExecTimeMap_ == null) {
+          return com.google.protobuf.MapField.emptyMapField(
+              FlowLastExecTimeMapDefaultEntryHolder.defaultEntry);
+        }
+        return flowLastExecTimeMap_;
+      }
+      private com.google.protobuf.MapField<java.lang.Integer, java.lang.Long>
+      internalGetMutableFlowLastExecTimeMap() {
+        onChanged();;
+        if (flowLastExecTimeMap_ == null) {
+          flowLastExecTimeMap_ = com.google.protobuf.MapField.newMapField(
+              FlowLastExecTimeMapDefaultEntryHolder.defaultEntry);
+        }
+        if (!flowLastExecTimeMap_.isMutable()) {
+          flowLastExecTimeMap_ = flowLastExecTimeMap_.copy();
+        }
+        return flowLastExecTimeMap_;
+      }
+
+      public int getFlowLastExecTimeMapCount() {
+        return internalGetFlowLastExecTimeMap().getMap().size();
+      }
+      /**
+       * <code>map&lt;uint32, int64&gt; flow_last_exec_time_map = 2;</code>
+       */
+
+      @java.lang.Override
+      public boolean containsFlowLastExecTimeMap(
+          int key) {
+        
+        return internalGetFlowLastExecTimeMap().getMap().containsKey(key);
+      }
+      /**
+       * Use {@link #getFlowLastExecTimeMapMap()} instead.
+       */
+      @java.lang.Override
+      @java.lang.Deprecated
+      public java.util.Map<java.lang.Integer, java.lang.Long> getFlowLastExecTimeMap() {
+        return getFlowLastExecTimeMapMap();
+      }
+      /**
+       * <code>map&lt;uint32, int64&gt; flow_last_exec_time_map = 2;</code>
+       */
+      @java.lang.Override
+
+      public java.util.Map<java.lang.Integer, java.lang.Long> getFlowLastExecTimeMapMap() {
+        return internalGetFlowLastExecTimeMap().getMap();
+      }
+      /**
+       * <code>map&lt;uint32, int64&gt; flow_last_exec_time_map = 2;</code>
+       */
+      @java.lang.Override
+
+      public long getFlowLastExecTimeMapOrDefault(
+          int key,
+          long defaultValue) {
+        
+        java.util.Map<java.lang.Integer, java.lang.Long> map =
+            internalGetFlowLastExecTimeMap().getMap();
+        return map.containsKey(key) ? map.get(key) : defaultValue;
+      }
+      /**
+       * <code>map&lt;uint32, int64&gt; flow_last_exec_time_map = 2;</code>
+       */
+      @java.lang.Override
+
+      public long getFlowLastExecTimeMapOrThrow(
+          int key) {
+        
+        java.util.Map<java.lang.Integer, java.lang.Long> map =
+            internalGetFlowLastExecTimeMap().getMap();
+        if (!map.containsKey(key)) {
+          throw new java.lang.IllegalArgumentException();
+        }
+        return map.get(key);
+      }
+
+      public Builder clearFlowLastExecTimeMap() {
+        internalGetMutableFlowLastExecTimeMap().getMutableMap()
+            .clear();
+        return this;
+      }
+      /**
+       * <code>map&lt;uint32, int64&gt; flow_last_exec_time_map = 2;</code>
+       */
+
+      public Builder removeFlowLastExecTimeMap(
+          int key) {
+        
+        internalGetMutableFlowLastExecTimeMap().getMutableMap()
+            .remove(key);
+        return this;
+      }
+      /**
+       * Use alternate mutation accessors instead.
+       */
+      @java.lang.Deprecated
+      public java.util.Map<java.lang.Integer, java.lang.Long>
+      getMutableFlowLastExecTimeMap() {
+        return internalGetMutableFlowLastExecTimeMap().getMutableMap();
+      }
+      /**
+       * <code>map&lt;uint32, int64&gt; flow_last_exec_time_map = 2;</code>
+       */
+      public Builder putFlowLastExecTimeMap(
+          int key,
+          long value) {
+        
+        
+        internalGetMutableFlowLastExecTimeMap().getMutableMap()
+            .put(key, value);
+        return this;
+      }
+      /**
+       * <code>map&lt;uint32, int64&gt; flow_last_exec_time_map = 2;</code>
+       */
+
+      public Builder putAllFlowLastExecTimeMap(
+          java.util.Map<java.lang.Integer, java.lang.Long> values) {
+        internalGetMutableFlowLastExecTimeMap().getMutableMap()
+            .putAll(values);
+        return this;
+      }
       @java.lang.Override
       public final Builder setUnknownFields(
           final com.google.protobuf.UnknownFieldSet unknownFields) {
@@ -11477,6 +11766,11 @@ public greptime.v1.meta.HeartbeatOuterClass.MailboxMessage getDefaultInstanceFor
   private static final 
     com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
       internal_static_greptime_v1_meta_FlowStat_FlowStatSizeEntry_fieldAccessorTable;
+  private static final com.google.protobuf.Descriptors.Descriptor
+    internal_static_greptime_v1_meta_FlowStat_FlowLastExecTimeMapEntry_descriptor;
+  private static final 
+    com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
+      internal_static_greptime_v1_meta_FlowStat_FlowLastExecTimeMapEntry_fieldAccessorTable;
   private static final com.google.protobuf.Descriptors.Descriptor
     internal_static_greptime_v1_meta_HeartbeatResponse_descriptor;
   private static final 
@@ -11537,36 +11831,40 @@ public greptime.v1.meta.HeartbeatOuterClass.MailboxMessage getDefaultInstanceFor
       "ta.RegionRole\022@\n\nextensions\030c \003(\0132,.grep" +
       "time.v1.meta.RegionStat.ExtensionsEntry\032" +
       "1\n\017ExtensionsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value" +
-      "\030\002 \001(\014:\0028\001\"\205\001\n\010FlowStat\022D\n\016flow_stat_siz" +
+      "\030\002 \001(\014:\0028\001\"\227\002\n\010FlowStat\022D\n\016flow_stat_siz" +
       "e\030\001 \003(\0132,.greptime.v1.meta.FlowStat.Flow" +
-      "StatSizeEntry\0323\n\021FlowStatSizeEntry\022\013\n\003ke" +
-      "y\030\001 \001(\r\022\r\n\005value\030\002 \001(\004:\0028\001\"\265\001\n\021Heartbeat" +
-      "Response\0220\n\006header\030\001 \001(\0132 .greptime.v1.m" +
-      "eta.ResponseHeader\0229\n\017mailbox_message\030\002 " +
-      "\001(\0132 .greptime.v1.meta.MailboxMessage\0223\n" +
-      "\014region_lease\030\003 \001(\0132\035.greptime.v1.meta.R" +
-      "egionLease\"N\n\rGrantedRegion\022\021\n\tregion_id" +
-      "\030\001 \001(\004\022*\n\004role\030\002 \001(\0162\034.greptime.v1.meta." +
-      "RegionRole\"\222\001\n\013RegionLease\0220\n\007regions\030\001 " +
-      "\003(\0132\037.greptime.v1.meta.GrantedRegion\022\034\n\024" +
-      "duration_since_epoch\030\002 \001(\004\022\025\n\rlease_seco" +
-      "nds\030\003 \001(\004\022\034\n\024closeable_region_ids\030\004 \003(\004\"" +
-      "C\n\020AskLeaderRequest\022/\n\006header\030\001 \001(\0132\037.gr" +
-      "eptime.v1.meta.RequestHeader\"m\n\021AskLeade" +
-      "rResponse\0220\n\006header\030\001 \001(\0132 .greptime.v1." +
-      "meta.ResponseHeader\022&\n\006leader\030\002 \001(\0132\026.gr" +
-      "eptime.v1.meta.Peer\"|\n\016MailboxMessage\022\n\n" +
-      "\002id\030\001 \001(\004\022\017\n\007subject\030\002 \001(\t\022\014\n\004from\030\003 \001(\t" +
-      "\022\n\n\002to\030\004 \001(\t\022\030\n\020timestamp_millis\030\005 \001(\003\022\016" +
-      "\n\004json\030\006 \001(\tH\000B\t\n\007payload*=\n\nRegionRole\022" +
-      "\n\n\006Leader\020\000\022\014\n\010Follower\020\001\022\025\n\021Downgrading" +
-      "Leader\020\0022\277\001\n\tHeartbeat\022Z\n\tHeartbeat\022\".gr" +
-      "eptime.v1.meta.HeartbeatRequest\032#.grepti" +
-      "me.v1.meta.HeartbeatResponse\"\000(\0010\001\022V\n\tAs" +
-      "kLeader\022\".greptime.v1.meta.AskLeaderRequ" +
-      "est\032#.greptime.v1.meta.AskLeaderResponse" +
-      "\"\000B<Z:github.com/GreptimeTeam/greptime-p" +
-      "roto/go/greptime/v1/metab\006proto3"
+      "StatSizeEntry\022T\n\027flow_last_exec_time_map" +
+      "\030\002 \003(\01323.greptime.v1.meta.FlowStat.FlowL" +
+      "astExecTimeMapEntry\0323\n\021FlowStatSizeEntry" +
+      "\022\013\n\003key\030\001 \001(\r\022\r\n\005value\030\002 \001(\004:\0028\001\032:\n\030Flow" +
+      "LastExecTimeMapEntry\022\013\n\003key\030\001 \001(\r\022\r\n\005val" +
+      "ue\030\002 \001(\003:\0028\001\"\265\001\n\021HeartbeatResponse\0220\n\006he" +
+      "ader\030\001 \001(\0132 .greptime.v1.meta.ResponseHe" +
+      "ader\0229\n\017mailbox_message\030\002 \001(\0132 .greptime" +
+      ".v1.meta.MailboxMessage\0223\n\014region_lease\030" +
+      "\003 \001(\0132\035.greptime.v1.meta.RegionLease\"N\n\r" +
+      "GrantedRegion\022\021\n\tregion_id\030\001 \001(\004\022*\n\004role" +
+      "\030\002 \001(\0162\034.greptime.v1.meta.RegionRole\"\222\001\n" +
+      "\013RegionLease\0220\n\007regions\030\001 \003(\0132\037.greptime" +
+      ".v1.meta.GrantedRegion\022\034\n\024duration_since" +
+      "_epoch\030\002 \001(\004\022\025\n\rlease_seconds\030\003 \001(\004\022\034\n\024c" +
+      "loseable_region_ids\030\004 \003(\004\"C\n\020AskLeaderRe" +
+      "quest\022/\n\006header\030\001 \001(\0132\037.greptime.v1.meta" +
+      ".RequestHeader\"m\n\021AskLeaderResponse\0220\n\006h" +
+      "eader\030\001 \001(\0132 .greptime.v1.meta.ResponseH" +
+      "eader\022&\n\006leader\030\002 \001(\0132\026.greptime.v1.meta" +
+      ".Peer\"|\n\016MailboxMessage\022\n\n\002id\030\001 \001(\004\022\017\n\007s" +
+      "ubject\030\002 \001(\t\022\014\n\004from\030\003 \001(\t\022\n\n\002to\030\004 \001(\t\022\030" +
+      "\n\020timestamp_millis\030\005 \001(\003\022\016\n\004json\030\006 \001(\tH\000" +
+      "B\t\n\007payload*=\n\nRegionRole\022\n\n\006Leader\020\000\022\014\n" +
+      "\010Follower\020\001\022\025\n\021DowngradingLeader\020\0022\277\001\n\tH" +
+      "eartbeat\022Z\n\tHeartbeat\022\".greptime.v1.meta" +
+      ".HeartbeatRequest\032#.greptime.v1.meta.Hea" +
+      "rtbeatResponse\"\000(\0010\001\022V\n\tAskLeader\022\".grep" +
+      "time.v1.meta.AskLeaderRequest\032#.greptime" +
+      ".v1.meta.AskLeaderResponse\"\000B<Z:github.c" +
+      "om/GreptimeTeam/greptime-proto/go/grepti" +
+      "me/v1/metab\006proto3"
     };
     descriptor = com.google.protobuf.Descriptors.FileDescriptor
       .internalBuildGeneratedFileFrom(descriptorData,
@@ -11602,13 +11900,19 @@ public greptime.v1.meta.HeartbeatOuterClass.MailboxMessage getDefaultInstanceFor
     internal_static_greptime_v1_meta_FlowStat_fieldAccessorTable = new
       com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
         internal_static_greptime_v1_meta_FlowStat_descriptor,
-        new java.lang.String[] { "FlowStatSize", });
+        new java.lang.String[] { "FlowStatSize", "FlowLastExecTimeMap", });
     internal_static_greptime_v1_meta_FlowStat_FlowStatSizeEntry_descriptor =
       internal_static_greptime_v1_meta_FlowStat_descriptor.getNestedTypes().get(0);
     internal_static_greptime_v1_meta_FlowStat_FlowStatSizeEntry_fieldAccessorTable = new
       com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
         internal_static_greptime_v1_meta_FlowStat_FlowStatSizeEntry_descriptor,
         new java.lang.String[] { "Key", "Value", });
+    internal_static_greptime_v1_meta_FlowStat_FlowLastExecTimeMapEntry_descriptor =
+      internal_static_greptime_v1_meta_FlowStat_descriptor.getNestedTypes().get(1);
+    internal_static_greptime_v1_meta_FlowStat_FlowLastExecTimeMapEntry_fieldAccessorTable = new
+      com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
+        internal_static_greptime_v1_meta_FlowStat_FlowLastExecTimeMapEntry_descriptor,
+        new java.lang.String[] { "Key", "Value", });
     internal_static_greptime_v1_meta_HeartbeatResponse_descriptor =
       getDescriptor().getMessageTypes().get(4);
     internal_static_greptime_v1_meta_HeartbeatResponse_fieldAccessorTable = new
diff --git a/proto/greptime/v1/meta/heartbeat.proto b/proto/greptime/v1/meta/heartbeat.proto
index 5ed016e9..fca23e3a 100644
--- a/proto/greptime/v1/meta/heartbeat.proto
+++ b/proto/greptime/v1/meta/heartbeat.proto
@@ -94,6 +94,7 @@ message FlowStat {
   // due to protobuf's key can't be a message, so we use uint32 as the key which
   // is [`FlowId`]'s inner field `id`
   map<uint32, uint64> flow_stat_size = 1;
+  map<uint32, int64> flow_last_exec_time_map = 2;
 }
 
 message HeartbeatResponse {