diff --git a/catalog-rest-service/src/main/java/org/openmetadata/catalog/jdbi3/FeedRepository.java b/catalog-rest-service/src/main/java/org/openmetadata/catalog/jdbi3/FeedRepository.java index 231fa185842..2984db72c12 100644 --- a/catalog-rest-service/src/main/java/org/openmetadata/catalog/jdbi3/FeedRepository.java +++ b/catalog-rest-service/src/main/java/org/openmetadata/catalog/jdbi3/FeedRepository.java @@ -198,7 +198,11 @@ public class FeedRepository { List posts = thread.getPosts(); // Remove the post to be deleted from the posts list posts = posts.stream().filter(p -> !p.getId().equals(post.getId())).collect(Collectors.toList()); - thread.withUpdatedAt(System.currentTimeMillis()).withUpdatedBy(userName).withPosts(posts); + thread + .withUpdatedAt(System.currentTimeMillis()) + .withUpdatedBy(userName) + .withPosts(posts) + .withPostsCount(posts.size()); // update the json document dao.feedDAO().update(thread.getId().toString(), JsonUtils.pojoToJson(thread)); diff --git a/catalog-rest-service/src/test/java/org/openmetadata/catalog/resources/feeds/FeedResourceTest.java b/catalog-rest-service/src/test/java/org/openmetadata/catalog/resources/feeds/FeedResourceTest.java index 66e2f7207d1..23adfb7c9b2 100644 --- a/catalog-rest-service/src/test/java/org/openmetadata/catalog/resources/feeds/FeedResourceTest.java +++ b/catalog-rest-service/src/test/java/org/openmetadata/catalog/resources/feeds/FeedResourceTest.java @@ -483,6 +483,10 @@ public class FeedResourceTest extends CatalogApplicationTest { // Check if get posts API returns the post PostList postList = listPosts(thread.getId().toString(), AUTH_HEADERS); assertTrue(postList.getData().isEmpty()); + + // validate posts count + Thread getThread = getThread(thread.getId(), AUTH_HEADERS); + assertEquals(0, getThread.getPostsCount()); } @Test