chore: add connection id to Process (#245)

* add connection id to Process

Signed-off-by: Lei, HUANG <mrsatangel@gmail.com>

* feat/add-connection-id-to-process-info:
 **Update `server.proto` for ProcessInfo Message**

 - Changed the data type of `id` from `uint64` to `uint32` in the `ProcessInfo` message.
 - Removed the `connection_id` field from the `ProcessInfo` message.

 Affected file:
 - `proto/greptime/v1/frontend/server.proto`

Signed-off-by: Lei, HUANG <mrsatangel@gmail.com>

* feat/add-connection-id-to-process-info:
 Update `process_id` type in `server.proto`

 - Changed the data type of `process_id` from `uint64` to `uint32` in `proto/greptime/v1/frontend/server.proto` to align with system requirements.

Signed-off-by: Lei, HUANG <mrsatangel@gmail.com>

---------

Signed-off-by: Lei, HUANG <mrsatangel@gmail.com>

c++/greptime/v1/frontend/server.pb.cc

@@ -53,7 +53,7 @@ PROTOBUF_CONSTEXPR KillProcessRequest::KillProcessRequest(
     ::_pbi::ConstantInitialized): _impl_{
     /*decltype(_impl_.server_addr_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
   , /*decltype(_impl_.catalog_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
-  , /*decltype(_impl_.process_id_)*/uint64_t{0u}
+  , /*decltype(_impl_.process_id_)*/0u
   , /*decltype(_impl_._cached_size_)*/{}} {}
 struct KillProcessRequestDefaultTypeInternal {
   PROTOBUF_CONSTEXPR KillProcessRequestDefaultTypeInternal()
@@ -84,8 +84,8 @@ PROTOBUF_CONSTEXPR ProcessInfo::ProcessInfo(
   , /*decltype(_impl_.query_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
   , /*decltype(_impl_.client_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
   , /*decltype(_impl_.frontend_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
-  , /*decltype(_impl_.id_)*/uint64_t{0u}
   , /*decltype(_impl_.start_timestamp_)*/int64_t{0}
+  , /*decltype(_impl_.id_)*/0u
   , /*decltype(_impl_._cached_size_)*/{}} {}
 struct ProcessInfoDefaultTypeInternal {
   PROTOBUF_CONSTEXPR ProcessInfoDefaultTypeInternal()
@@ -171,9 +171,9 @@ const char descriptor_table_protodef_greptime_2fv1_2ffrontend_2fserver_2eproto[]
   "4\n\tprocesses\030\001 \003(\0132!.greptime.v1.fronten"
   "d.ProcessInfo\"N\n\022KillProcessRequest\022\023\n\013s"
   "erver_addr\030\001 \001(\t\022\017\n\007catalog\030\002 \001(\t\022\022\n\npro"
-  "cess_id\030\003 \001(\004\"&\n\023KillProcessResponse\022\017\n\007"
+  "cess_id\030\003 \001(\r\"&\n\023KillProcessResponse\022\017\n\007"
   "success\030\001 \001(\010\"\205\001\n\013ProcessInfo\022\n\n\002id\030\001 \001("
-  "\004\022\017\n\007catalog\030\002 \001(\t\022\017\n\007schemas\030\003 \003(\t\022\r\n\005q"
+  "\r\022\017\n\007catalog\030\002 \001(\t\022\017\n\007schemas\030\003 \003(\t\022\r\n\005q"
   "uery\030\004 \001(\t\022\027\n\017start_timestamp\030\005 \001(\003\022\016\n\006c"
   "lient\030\006 \001(\t\022\020\n\010frontend\030\007 \001(\t2\322\001\n\010Fronte"
   "nd\022b\n\013ListProcess\022(.greptime.v1.frontend"
@@ -641,7 +641,7 @@ inline void KillProcessRequest::SharedCtor(
   new (&_impl_) Impl_{
       decltype(_impl_.server_addr_){}
     , decltype(_impl_.catalog_){}
-    , decltype(_impl_.process_id_){uint64_t{0u}}
+    , decltype(_impl_.process_id_){0u}
     , /*decltype(_impl_._cached_size_)*/{}
   };
   _impl_.server_addr_.InitDefault();
@@ -681,7 +681,7 @@ void KillProcessRequest::Clear() {
 
   _impl_.server_addr_.ClearToEmpty();
   _impl_.catalog_.ClearToEmpty();
-  _impl_.process_id_ = uint64_t{0u};
+  _impl_.process_id_ = 0u;
   _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
 }
 
@@ -711,10 +711,10 @@ const char* KillProcessRequest::_InternalParse(const char* ptr, ::_pbi::ParseCon
         } else
           goto handle_unusual;
         continue;
-      // uint64 process_id = 3;
+      // uint32 process_id = 3;
       case 3:
         if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 24)) {
-          _impl_.process_id_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint64(&ptr);
+          _impl_.process_id_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint32(&ptr);
           CHK_(ptr);
         } else
           goto handle_unusual;
@@ -768,10 +768,10 @@ uint8_t* KillProcessRequest::_InternalSerialize(
         2, this->_internal_catalog(), target);
   }
 
-  // uint64 process_id = 3;
+  // uint32 process_id = 3;
   if (this->_internal_process_id() != 0) {
     target = stream->EnsureSpace(target);
-    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(3, this->_internal_process_id(), target);
+    target = ::_pbi::WireFormatLite::WriteUInt32ToArray(3, this->_internal_process_id(), target);
   }
 
   if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
@@ -804,9 +804,9 @@ size_t KillProcessRequest::ByteSizeLong() const {
         this->_internal_catalog());
   }
 
-  // uint64 process_id = 3;
+  // uint32 process_id = 3;
   if (this->_internal_process_id() != 0) {
-    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(this->_internal_process_id());
+    total_size += ::_pbi::WireFormatLite::UInt32SizePlusOne(this->_internal_process_id());
   }
 
   return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_);
@@ -1071,8 +1071,8 @@ ProcessInfo::ProcessInfo(const ProcessInfo& from)
     , decltype(_impl_.query_){}
     , decltype(_impl_.client_){}
     , decltype(_impl_.frontend_){}
-    , decltype(_impl_.id_){}
     , decltype(_impl_.start_timestamp_){}
+    , decltype(_impl_.id_){}
     , /*decltype(_impl_._cached_size_)*/{}};
 
   _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
@@ -1108,9 +1108,9 @@ ProcessInfo::ProcessInfo(const ProcessInfo& from)
     _this->_impl_.frontend_.Set(from._internal_frontend(), 
       _this->GetArenaForAllocation());
   }
-  ::memcpy(&_impl_.id_, &from._impl_.id_,
+  ::memcpy(&_impl_.start_timestamp_, &from._impl_.start_timestamp_,
-    static_cast<size_t>(reinterpret_cast<char*>(&_impl_.start_timestamp_) -
+    static_cast<size_t>(reinterpret_cast<char*>(&_impl_.id_) -
-    reinterpret_cast<char*>(&_impl_.id_)) + sizeof(_impl_.start_timestamp_));
+    reinterpret_cast<char*>(&_impl_.start_timestamp_)) + sizeof(_impl_.id_));
   // @@protoc_insertion_point(copy_constructor:greptime.v1.frontend.ProcessInfo)
 }
 
@@ -1124,8 +1124,8 @@ inline void ProcessInfo::SharedCtor(
     , decltype(_impl_.query_){}
     , decltype(_impl_.client_){}
     , decltype(_impl_.frontend_){}
-    , decltype(_impl_.id_){uint64_t{0u}}
     , decltype(_impl_.start_timestamp_){int64_t{0}}
+    , decltype(_impl_.id_){0u}
     , /*decltype(_impl_._cached_size_)*/{}
   };
   _impl_.catalog_.InitDefault();
@@ -1179,9 +1179,9 @@ void ProcessInfo::Clear() {
   _impl_.query_.ClearToEmpty();
   _impl_.client_.ClearToEmpty();
   _impl_.frontend_.ClearToEmpty();
-  ::memset(&_impl_.id_, 0, static_cast<size_t>(
+  ::memset(&_impl_.start_timestamp_, 0, static_cast<size_t>(
-      reinterpret_cast<char*>(&_impl_.start_timestamp_) -
+      reinterpret_cast<char*>(&_impl_.id_) -
-      reinterpret_cast<char*>(&_impl_.id_)) + sizeof(_impl_.start_timestamp_));
+      reinterpret_cast<char*>(&_impl_.start_timestamp_)) + sizeof(_impl_.id_));
   _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
 }
 
@@ -1191,10 +1191,10 @@ const char* ProcessInfo::_InternalParse(const char* ptr, ::_pbi::ParseContext* c
     uint32_t tag;
     ptr = ::_pbi::ReadTag(ptr, &tag);
     switch (tag >> 3) {
-      // uint64 id = 1;
+      // uint32 id = 1;
       case 1:
         if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 8)) {
-          _impl_.id_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint64(&ptr);
+          _impl_.id_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint32(&ptr);
           CHK_(ptr);
         } else
           goto handle_unusual;
@@ -1291,10 +1291,10 @@ uint8_t* ProcessInfo::_InternalSerialize(
   uint32_t cached_has_bits = 0;
   (void) cached_has_bits;
 
-  // uint64 id = 1;
+  // uint32 id = 1;
   if (this->_internal_id() != 0) {
     target = stream->EnsureSpace(target);
-    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(1, this->_internal_id(), target);
+    target = ::_pbi::WireFormatLite::WriteUInt32ToArray(1, this->_internal_id(), target);
   }
 
   // string catalog = 2;
@@ -1405,16 +1405,16 @@ size_t ProcessInfo::ByteSizeLong() const {
         this->_internal_frontend());
   }
 
-  // uint64 id = 1;
-  if (this->_internal_id() != 0) {
-    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(this->_internal_id());
-  }
-
   // int64 start_timestamp = 5;
   if (this->_internal_start_timestamp() != 0) {
     total_size += ::_pbi::WireFormatLite::Int64SizePlusOne(this->_internal_start_timestamp());
   }
 
+  // uint32 id = 1;
+  if (this->_internal_id() != 0) {
+    total_size += ::_pbi::WireFormatLite::UInt32SizePlusOne(this->_internal_id());
+  }
+
   return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_);
 }
 
@@ -1446,12 +1446,12 @@ void ProcessInfo::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PR
   if (!from._internal_frontend().empty()) {
     _this->_internal_set_frontend(from._internal_frontend());
   }
-  if (from._internal_id() != 0) {
-    _this->_internal_set_id(from._internal_id());
-  }
   if (from._internal_start_timestamp() != 0) {
     _this->_internal_set_start_timestamp(from._internal_start_timestamp());
   }
+  if (from._internal_id() != 0) {
+    _this->_internal_set_id(from._internal_id());
+  }
   _this->_internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
 }
 
@@ -1489,11 +1489,11 @@ void ProcessInfo::InternalSwap(ProcessInfo* other) {
       &other->_impl_.frontend_, rhs_arena
   );
   ::PROTOBUF_NAMESPACE_ID::internal::memswap<
-      PROTOBUF_FIELD_OFFSET(ProcessInfo, _impl_.start_timestamp_)
+      PROTOBUF_FIELD_OFFSET(ProcessInfo, _impl_.id_)
-      + sizeof(ProcessInfo::_impl_.start_timestamp_)
+      + sizeof(ProcessInfo::_impl_.id_)
-      - PROTOBUF_FIELD_OFFSET(ProcessInfo, _impl_.id_)>(
+      - PROTOBUF_FIELD_OFFSET(ProcessInfo, _impl_.start_timestamp_)>(
-          reinterpret_cast<char*>(&_impl_.id_),
+          reinterpret_cast<char*>(&_impl_.start_timestamp_),
-          reinterpret_cast<char*>(&other->_impl_.id_));
+          reinterpret_cast<char*>(&other->_impl_.start_timestamp_));
 }
 
 ::PROTOBUF_NAMESPACE_ID::Metadata ProcessInfo::GetMetadata() const {

c++/greptime/v1/frontend/server.pb.h

@@ -541,13 +541,13 @@ class KillProcessRequest final :
   std::string* _internal_mutable_catalog();
   public:
 
-  // uint64 process_id = 3;
+  // uint32 process_id = 3;
   void clear_process_id();
-  uint64_t process_id() const;
+  uint32_t process_id() const;
-  void set_process_id(uint64_t value);
+  void set_process_id(uint32_t value);
   private:
-  uint64_t _internal_process_id() const;
+  uint32_t _internal_process_id() const;
-  void _internal_set_process_id(uint64_t value);
+  void _internal_set_process_id(uint32_t value);
   public:
 
   // @@protoc_insertion_point(class_scope:greptime.v1.frontend.KillProcessRequest)
@@ -560,7 +560,7 @@ class KillProcessRequest final :
   struct Impl_ {
     ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr server_addr_;
     ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr catalog_;
-    uint64_t process_id_;
+    uint32_t process_id_;
     mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
   };
   union { Impl_ _impl_; };
@@ -842,8 +842,8 @@ class ProcessInfo final :
     kQueryFieldNumber = 4,
     kClientFieldNumber = 6,
     kFrontendFieldNumber = 7,
-    kIdFieldNumber = 1,
     kStartTimestampFieldNumber = 5,
+    kIdFieldNumber = 1,
   };
   // repeated string schemas = 3;
   int schemas_size() const;
@@ -925,15 +925,6 @@ class ProcessInfo final :
   std::string* _internal_mutable_frontend();
   public:
 
-  // uint64 id = 1;
-  void clear_id();
-  uint64_t id() const;
-  void set_id(uint64_t value);
-  private:
-  uint64_t _internal_id() const;
-  void _internal_set_id(uint64_t value);
-  public:
-
   // int64 start_timestamp = 5;
   void clear_start_timestamp();
   int64_t start_timestamp() const;
@@ -943,6 +934,15 @@ class ProcessInfo final :
   void _internal_set_start_timestamp(int64_t value);
   public:
 
+  // uint32 id = 1;
+  void clear_id();
+  uint32_t id() const;
+  void set_id(uint32_t value);
+  private:
+  uint32_t _internal_id() const;
+  void _internal_set_id(uint32_t value);
+  public:
+
   // @@protoc_insertion_point(class_scope:greptime.v1.frontend.ProcessInfo)
  private:
   class _Internal;
@@ -956,8 +956,8 @@ class ProcessInfo final :
     ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr query_;
     ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr client_;
     ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr frontend_;
-    uint64_t id_;
     int64_t start_timestamp_;
+    uint32_t id_;
     mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
   };
   union { Impl_ _impl_; };
@@ -1172,22 +1172,22 @@ inline void KillProcessRequest::set_allocated_catalog(std::string* catalog) {
   // @@protoc_insertion_point(field_set_allocated:greptime.v1.frontend.KillProcessRequest.catalog)
 }
 
-// uint64 process_id = 3;
+// uint32 process_id = 3;
 inline void KillProcessRequest::clear_process_id() {
-  _impl_.process_id_ = uint64_t{0u};
+  _impl_.process_id_ = 0u;
 }
-inline uint64_t KillProcessRequest::_internal_process_id() const {
+inline uint32_t KillProcessRequest::_internal_process_id() const {
   return _impl_.process_id_;
 }
-inline uint64_t KillProcessRequest::process_id() const {
+inline uint32_t KillProcessRequest::process_id() const {
   // @@protoc_insertion_point(field_get:greptime.v1.frontend.KillProcessRequest.process_id)
   return _internal_process_id();
 }
-inline void KillProcessRequest::_internal_set_process_id(uint64_t value) {
+inline void KillProcessRequest::_internal_set_process_id(uint32_t value) {
   
   _impl_.process_id_ = value;
 }
-inline void KillProcessRequest::set_process_id(uint64_t value) {
+inline void KillProcessRequest::set_process_id(uint32_t value) {
   _internal_set_process_id(value);
   // @@protoc_insertion_point(field_set:greptime.v1.frontend.KillProcessRequest.process_id)
 }
@@ -1220,22 +1220,22 @@ inline void KillProcessResponse::set_success(bool value) {
 
 // ProcessInfo
 
-// uint64 id = 1;
+// uint32 id = 1;
 inline void ProcessInfo::clear_id() {
-  _impl_.id_ = uint64_t{0u};
+  _impl_.id_ = 0u;
 }
-inline uint64_t ProcessInfo::_internal_id() const {
+inline uint32_t ProcessInfo::_internal_id() const {
   return _impl_.id_;
 }
-inline uint64_t ProcessInfo::id() const {
+inline uint32_t ProcessInfo::id() const {
   // @@protoc_insertion_point(field_get:greptime.v1.frontend.ProcessInfo.id)
   return _internal_id();
 }
-inline void ProcessInfo::_internal_set_id(uint64_t value) {
+inline void ProcessInfo::_internal_set_id(uint32_t value) {
   
   _impl_.id_ = value;
 }
-inline void ProcessInfo::set_id(uint64_t value) {
+inline void ProcessInfo::set_id(uint32_t value) {
   _internal_set_id(value);
   // @@protoc_insertion_point(field_set:greptime.v1.frontend.ProcessInfo.id)
 }

java/src/main/java/io/greptime/v1/frontend/Server.java

@@ -1428,10 +1428,10 @@ public final class Server {
      * ID of process to kill.
      * </pre>
      *
-     * <code>uint64 process_id = 3;</code>
+     * <code>uint32 process_id = 3;</code>
      * @return The processId.
      */
-    long getProcessId();
+    int getProcessId();
   }
   /**
    * Protobuf type {@code greptime.v1.frontend.KillProcessRequest}
@@ -1494,7 +1494,7 @@ public final class Server {
             }
             case 24: {
 
-              processId_ = input.readUInt64();
+              processId_ = input.readUInt32();
               break;
             }
             default: {
@@ -1624,17 +1624,17 @@ public final class Server {
     }
 
     public static final int PROCESS_ID_FIELD_NUMBER = 3;
-    private long processId_;
+    private int processId_;
     /**
      * <pre>
      * ID of process to kill.
      * </pre>
      *
-     * <code>uint64 process_id = 3;</code>
+     * <code>uint32 process_id = 3;</code>
      * @return The processId.
      */
     @java.lang.Override
-    public long getProcessId() {
+    public int getProcessId() {
       return processId_;
     }
 
@@ -1658,8 +1658,8 @@ public final class Server {
       if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(catalog_)) {
         com.google.protobuf.GeneratedMessageV3.writeString(output, 2, catalog_);
       }
-      if (processId_ != 0L) {
+      if (processId_ != 0) {
-        output.writeUInt64(3, processId_);
+        output.writeUInt32(3, processId_);
       }
       unknownFields.writeTo(output);
     }
@@ -1676,9 +1676,9 @@ public final class Server {
       if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(catalog_)) {
         size += com.google.protobuf.GeneratedMessageV3.computeStringSize(2, catalog_);
       }
-      if (processId_ != 0L) {
+      if (processId_ != 0) {
         size += com.google.protobuf.CodedOutputStream
-          .computeUInt64Size(3, processId_);
+          .computeUInt32Size(3, processId_);
       }
       size += unknownFields.getSerializedSize();
       memoizedSize = size;
@@ -1717,8 +1717,7 @@ public final class Server {
       hash = (37 * hash) + CATALOG_FIELD_NUMBER;
       hash = (53 * hash) + getCatalog().hashCode();
       hash = (37 * hash) + PROCESS_ID_FIELD_NUMBER;
-      hash = (53 * hash) + com.google.protobuf.Internal.hashLong(
+      hash = (53 * hash) + getProcessId();
-          getProcessId());
       hash = (29 * hash) + unknownFields.hashCode();
       memoizedHashCode = hash;
       return hash;
@@ -1856,7 +1855,7 @@ public final class Server {
 
         catalog_ = "";
 
-        processId_ = 0L;
+        processId_ = 0;
 
         return this;
       }
@@ -1943,7 +1942,7 @@ public final class Server {
           catalog_ = other.catalog_;
           onChanged();
         }
-        if (other.getProcessId() != 0L) {
+        if (other.getProcessId() != 0) {
           setProcessId(other.getProcessId());
         }
         this.mergeUnknownFields(other.unknownFields);
@@ -2167,17 +2166,17 @@ public final class Server {
         return this;
       }
 
-      private long processId_ ;
+      private int processId_ ;
       /**
        * <pre>
        * ID of process to kill.
        * </pre>
        *
-       * <code>uint64 process_id = 3;</code>
+       * <code>uint32 process_id = 3;</code>
        * @return The processId.
        */
       @java.lang.Override
-      public long getProcessId() {
+      public int getProcessId() {
         return processId_;
       }
       /**
@@ -2185,11 +2184,11 @@ public final class Server {
        * ID of process to kill.
        * </pre>
        *
-       * <code>uint64 process_id = 3;</code>
+       * <code>uint32 process_id = 3;</code>
        * @param value The processId to set.
        * @return This builder for chaining.
        */
-      public Builder setProcessId(long value) {
+      public Builder setProcessId(int value) {
         
         processId_ = value;
         onChanged();
@@ -2200,12 +2199,12 @@ public final class Server {
        * ID of process to kill.
        * </pre>
        *
-       * <code>uint64 process_id = 3;</code>
+       * <code>uint32 process_id = 3;</code>
        * @return This builder for chaining.
        */
       public Builder clearProcessId() {
         
-        processId_ = 0L;
+        processId_ = 0;
         onChanged();
         return this;
       }
@@ -2782,10 +2781,10 @@ public final class Server {
      * ID.
      * </pre>
      *
-     * <code>uint64 id = 1;</code>
+     * <code>uint32 id = 1;</code>
      * @return The id.
      */
-    long getId();
+    int getId();
 
     /**
      * <pre>
@@ -2971,7 +2970,7 @@ public final class Server {
               break;
             case 8: {
 
-              id_ = input.readUInt64();
+              id_ = input.readUInt32();
               break;
             }
             case 18: {
@@ -3050,17 +3049,17 @@ public final class Server {
     }
 
     public static final int ID_FIELD_NUMBER = 1;
-    private long id_;
+    private int id_;
     /**
      * <pre>
      * ID.
      * </pre>
      *
-     * <code>uint64 id = 1;</code>
+     * <code>uint32 id = 1;</code>
      * @return The id.
      */
     @java.lang.Override
-    public long getId() {
+    public int getId() {
       return id_;
     }
 
@@ -3328,8 +3327,8 @@ public final class Server {
     @java.lang.Override
     public void writeTo(com.google.protobuf.CodedOutputStream output)
                         throws java.io.IOException {
-      if (id_ != 0L) {
+      if (id_ != 0) {
-        output.writeUInt64(1, id_);
+        output.writeUInt32(1, id_);
       }
       if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(catalog_)) {
         com.google.protobuf.GeneratedMessageV3.writeString(output, 2, catalog_);
@@ -3358,9 +3357,9 @@ public final class Server {
       if (size != -1) return size;
 
       size = 0;
-      if (id_ != 0L) {
+      if (id_ != 0) {
         size += com.google.protobuf.CodedOutputStream
-          .computeUInt64Size(1, id_);
+          .computeUInt32Size(1, id_);
       }
       if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(catalog_)) {
         size += com.google.protobuf.GeneratedMessageV3.computeStringSize(2, catalog_);
@@ -3427,8 +3426,7 @@ public final class Server {
       int hash = 41;
       hash = (19 * hash) + getDescriptor().hashCode();
       hash = (37 * hash) + ID_FIELD_NUMBER;
-      hash = (53 * hash) + com.google.protobuf.Internal.hashLong(
+      hash = (53 * hash) + getId();
-          getId());
       hash = (37 * hash) + CATALOG_FIELD_NUMBER;
       hash = (53 * hash) + getCatalog().hashCode();
       if (getSchemasCount() > 0) {
@@ -3577,7 +3575,7 @@ public final class Server {
       @java.lang.Override
       public Builder clear() {
         super.clear();
-        id_ = 0L;
+        id_ = 0;
 
         catalog_ = "";
 
@@ -3677,7 +3675,7 @@ public final class Server {
 
       public Builder mergeFrom(io.greptime.v1.frontend.Server.ProcessInfo other) {
         if (other == io.greptime.v1.frontend.Server.ProcessInfo.getDefaultInstance()) return this;
-        if (other.getId() != 0L) {
+        if (other.getId() != 0) {
           setId(other.getId());
         }
         if (!other.getCatalog().isEmpty()) {
@@ -3739,17 +3737,17 @@ public final class Server {
       }
       private int bitField0_;
 
-      private long id_ ;
+      private int id_ ;
       /**
        * <pre>
        * ID.
        * </pre>
        *
-       * <code>uint64 id = 1;</code>
+       * <code>uint32 id = 1;</code>
        * @return The id.
        */
       @java.lang.Override
-      public long getId() {
+      public int getId() {
         return id_;
       }
       /**
@@ -3757,11 +3755,11 @@ public final class Server {
        * ID.
        * </pre>
        *
-       * <code>uint64 id = 1;</code>
+       * <code>uint32 id = 1;</code>
        * @param value The id to set.
        * @return This builder for chaining.
        */
-      public Builder setId(long value) {
+      public Builder setId(int value) {
         
         id_ = value;
         onChanged();
@@ -3772,12 +3770,12 @@ public final class Server {
        * ID.
        * </pre>
        *
-       * <code>uint64 id = 1;</code>
+       * <code>uint32 id = 1;</code>
        * @return This builder for chaining.
        */
       public Builder clearId() {
         
-        id_ = 0L;
+        id_ = 0;
         onChanged();
         return this;
       }
@@ -4447,9 +4445,9 @@ public final class Server {
       "4\n\tprocesses\030\001 \003(\0132!.greptime.v1.fronten" +
       "d.ProcessInfo\"N\n\022KillProcessRequest\022\023\n\013s" +
       "erver_addr\030\001 \001(\t\022\017\n\007catalog\030\002 \001(\t\022\022\n\npro" +
-      "cess_id\030\003 \001(\004\"&\n\023KillProcessResponse\022\017\n\007" +
+      "cess_id\030\003 \001(\r\"&\n\023KillProcessResponse\022\017\n\007" +
       "success\030\001 \001(\010\"\205\001\n\013ProcessInfo\022\n\n\002id\030\001 \001(" +
-      "\004\022\017\n\007catalog\030\002 \001(\t\022\017\n\007schemas\030\003 \003(\t\022\r\n\005q" +
+      "\r\022\017\n\007catalog\030\002 \001(\t\022\017\n\007schemas\030\003 \003(\t\022\r\n\005q" +
       "uery\030\004 \001(\t\022\027\n\017start_timestamp\030\005 \001(\003\022\016\n\006c" +
       "lient\030\006 \001(\t\022\020\n\010frontend\030\007 \001(\t2\322\001\n\010Fronte" +
       "nd\022b\n\013ListProcess\022(.greptime.v1.frontend" +

proto/greptime/v1/frontend/server.proto

@@ -41,7 +41,7 @@ message KillProcessRequest {
   // Catalog of process to kill.
   string catalog = 2;
   // ID of process to kill.
-  uint64 process_id = 3;
+  uint32 process_id = 3;
 }
 
 message KillProcessResponse {
@@ -51,7 +51,7 @@ message KillProcessResponse {
 
 message ProcessInfo {
   // ID.
-  uint64 id = 1;
+  uint32 id = 1;
   // Catalog of process.
   string catalog = 2;
   // Involved schemas.