From 82dd841f7b523de96dac65626defb0f10275df7d Mon Sep 17 00:00:00 2001
From: Abhishek Balaji Radhakrishnan <abhishek.rb19@gmail.com>
Date: Wed, 13 Mar 2024 12:02:45 +0530
Subject: [PATCH] use common function.

---
 .../IndexerSQLMetadataStorageCoordinator.java         | 11 +----------
 1 file changed, 1 insertion(+), 10 deletions(-)

diff --git a/server/src/main/java/org/apache/druid/metadata/IndexerSQLMetadataStorageCoordinator.java b/server/src/main/java/org/apache/druid/metadata/IndexerSQLMetadataStorageCoordinator.java
index 3d8939c3e52..44d09c7da4f 100644
--- a/server/src/main/java/org/apache/druid/metadata/IndexerSQLMetadataStorageCoordinator.java
+++ b/server/src/main/java/org/apache/druid/metadata/IndexerSQLMetadataStorageCoordinator.java
@@ -419,16 +419,7 @@ public class IndexerSQLMetadataStorageCoordinator implements IndexerMetadataStor
       @Nullable final DataSourceMetadata endMetadata
   ) throws IOException
   {
-    if (segments.isEmpty()) {
-      throw new IllegalArgumentException("segment set must not be empty");
-    }
-
-    final String dataSource = segments.iterator().next().getDataSource();
-    for (DataSegment segment : segments) {
-      if (!dataSource.equals(segment.getDataSource())) {
-        throw new IllegalArgumentException("segments must all be from the same dataSource");
-      }
-    }
+    verifySegmentsToCommit(segments);
 
     if ((startMetadata == null && endMetadata != null) || (startMetadata != null && endMetadata == null)) {
       throw new IllegalArgumentException("start/end metadata pair must be either null or non-null");