From 4eced9b3c99ea818ecef15631662de6f274e70cc Mon Sep 17 00:00:00 2001
From: Rishabh Singh <6513075+findingrish@users.noreply.github.com>
Date: Sat, 22 Jun 2024 04:10:12 +0530
Subject: [PATCH] Fix CentralizedDatasourceSchema group IT failure  (#16636)

* Fix build

* Update datasource name in ITSystemTableBatchIndexTaskTest
---
 .../druid/tests/indexer/ITSystemTableBatchIndexTaskTest.java  | 2 +-
 .../resources/indexer/sys_segment_batch_index_queries.json    | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/integration-tests/src/test/java/org/apache/druid/tests/indexer/ITSystemTableBatchIndexTaskTest.java b/integration-tests/src/test/java/org/apache/druid/tests/indexer/ITSystemTableBatchIndexTaskTest.java
index f15081509a08..f98626ad9b59 100644
--- a/integration-tests/src/test/java/org/apache/druid/tests/indexer/ITSystemTableBatchIndexTaskTest.java
+++ b/integration-tests/src/test/java/org/apache/druid/tests/indexer/ITSystemTableBatchIndexTaskTest.java
@@ -37,7 +37,7 @@ public class ITSystemTableBatchIndexTaskTest extends AbstractITBatchIndexTest
   private static final Logger LOG = new Logger(ITSystemTableBatchIndexTaskTest.class);
   private static final String INDEX_TASK = "/indexer/wikipedia_index_task.json";
   private static final String SYSTEM_QUERIES_RESOURCE = "/indexer/sys_segment_batch_index_queries.json";
-  private static final String INDEX_DATASOURCE = "wikipedia_index_test";
+  private static final String INDEX_DATASOURCE = "sys_segment_wikipedia_index_test";
 
   @Test
   public void testIndexData() throws Exception
diff --git a/integration-tests/src/test/resources/indexer/sys_segment_batch_index_queries.json b/integration-tests/src/test/resources/indexer/sys_segment_batch_index_queries.json
index 931ad8957781..b0746e0cab4b 100644
--- a/integration-tests/src/test/resources/indexer/sys_segment_batch_index_queries.json
+++ b/integration-tests/src/test/resources/indexer/sys_segment_batch_index_queries.json
@@ -1,7 +1,7 @@
 [
   {
     "query": {
-      "query": "SELECT count(*) FROM sys.segments WHERE datasource LIKE 'wikipedia_index_test%'"
+      "query": "SELECT count(*) FROM sys.segments WHERE datasource LIKE 'sys_segment_wikipedia_index_test%'"
     },
     "expectedResults": [
       {
@@ -24,7 +24,7 @@
   },
   {
     "query": {
-      "query": "SELECT status AS status FROM sys.tasks WHERE datasource LIKE 'wikipedia_index_test%' GROUP BY 1"
+      "query": "SELECT status AS status FROM sys.tasks WHERE datasource LIKE 'sys_segment_wikipedia_index_test%' GROUP BY 1"
     },
     "expectedResults": [
       {