diff --git a/service-configuration/src/main/java/com/lanyuanxiaoyao/service/configuration/entity/info/JobIdAndAlias.java b/service-configuration/src/main/java/com/lanyuanxiaoyao/service/configuration/entity/info/JobIdAndAlias.java
index 8799288..8348377 100644
--- a/service-configuration/src/main/java/com/lanyuanxiaoyao/service/configuration/entity/info/JobIdAndAlias.java
+++ b/service-configuration/src/main/java/com/lanyuanxiaoyao/service/configuration/entity/info/JobIdAndAlias.java
@@ -34,11 +34,29 @@ public class JobIdAndAlias {
         this.alias = alias;
     }
 
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) return true;
+        if (o == null || getClass() != o.getClass()) return false;
+
+        JobIdAndAlias that = (JobIdAndAlias) o;
+
+        if (!id.equals(that.id)) return false;
+        return alias.equals(that.alias);
+    }
+
+    @Override
+    public int hashCode() {
+        int result = id.hashCode();
+        result = 31 * result + alias.hashCode();
+        return result;
+    }
+
     @Override
     public String toString() {
         return "JobIdAndAlias{" +
-                "id=" + id +
-                ", alias='" + alias + '\'' +
-                '}';
+               "id=" + id +
+               ", alias='" + alias + '\'' +
+               '}';
     }
 }
diff --git a/service-configuration/src/main/java/com/lanyuanxiaoyao/service/configuration/entity/info/TableInfoSearchCache.java b/service-configuration/src/main/java/com/lanyuanxiaoyao/service/configuration/entity/info/TableInfoSearchCache.java
index 0f3c1c1..f59eae1 100644
--- a/service-configuration/src/main/java/com/lanyuanxiaoyao/service/configuration/entity/info/TableInfoSearchCache.java
+++ b/service-configuration/src/main/java/com/lanyuanxiaoyao/service/configuration/entity/info/TableInfoSearchCache.java
@@ -64,6 +64,30 @@ public class TableInfoSearchCache {
         this.topic = topic;
     }
 
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) return true;
+        if (o == null || getClass() != o.getClass()) return false;
+
+        TableInfoSearchCache that = (TableInfoSearchCache) o;
+
+        if (!flinkJobId.equals(that.flinkJobId)) return false;
+        if (!alias.equals(that.alias)) return false;
+        if (!hdfs.equals(that.hdfs)) return false;
+        if (!pulsar.equals(that.pulsar)) return false;
+        return topic.equals(that.topic);
+    }
+
+    @Override
+    public int hashCode() {
+        int result = flinkJobId.hashCode();
+        result = 31 * result + alias.hashCode();
+        result = 31 * result + hdfs.hashCode();
+        result = 31 * result + pulsar.hashCode();
+        result = 31 * result + topic.hashCode();
+        return result;
+    }
+
     @Override
     public String toString() {
         return "TableInfoSearchCache{" +