Reapply "Use Virtual Thread"

This reverts commit 769e571.

Author: mohityadav766

openmetadata-service/src/main/java/org/openmetadata/service/apps/bundles/searchIndex/SearchIndexExecutor.java

@@ -455,16 +455,16 @@ private int initializeQueueAndExecutors(ThreadConfiguration threadConfig, int en
     producersDone.set(false);
 
     jobExecutor =
-        Executors.newFixedThreadPool(entityCount, Thread.ofPlatform().name("job-", 0).factory());
+        Executors.newFixedThreadPool(entityCount, Thread.ofVirtual().name("job-", 0).factory());
 
     int finalNumConsumers = Math.min(threadConfig.numConsumers(), MAX_CONSUMER_THREADS);
     consumerExecutor =
         Executors.newFixedThreadPool(
-            finalNumConsumers, Thread.ofPlatform().name("consumer-", 0).factory());
+            finalNumConsumers, Thread.ofVirtual().name("consumer-", 0).factory());
 
     producerExecutor =
         Executors.newFixedThreadPool(
-            threadConfig.numProducers(), Thread.ofPlatform().name("producer-", 0).factory());
+            threadConfig.numProducers(), Thread.ofVirtual().name("producer-", 0).factory());
 
     return effectiveQueueSize;
   }

openmetadata-service/src/main/java/org/openmetadata/service/apps/bundles/searchIndex/distributed/DistributedJobStatsAggregator.java

@@ -114,7 +114,7 @@ public void start() {
     if (running.compareAndSet(false, true)) {
       scheduler =
           Executors.newSingleThreadScheduledExecutor(
-              Thread.ofPlatform()
+              Thread.ofVirtual()
                   .name("stats-aggregator-" + jobId.toString().substring(0, 8))
                   .factory());
 

openmetadata-service/src/main/java/org/openmetadata/service/apps/bundles/searchIndex/distributed/PartitionWorker.java

@@ -158,7 +158,8 @@ public PartitionResult processPartition(SearchIndexPartition partition) {
           successCount.addAndGet(batchResult.successCount());
           failedCount.addAndGet(batchResult.failedCount());
           warningsCount.addAndGet(batchResult.warningsCount());
-          processedCount.addAndGet(batchResult.successCount() + batchResult.failedCount());
+          processedCount.addAndGet(
+              batchResult.successCount() + batchResult.failedCount() + batchResult.warningsCount());
 
           currentOffset += currentBatchSize;
 

openmetadata-service/src/main/java/org/openmetadata/service/apps/bundles/searchIndex/distributed/PollingJobNotifier.java

@@ -70,7 +70,7 @@ public void start() {
 
     scheduler =
         Executors.newSingleThreadScheduledExecutor(
-            Thread.ofPlatform().name("job-notifier-poll").factory());
+            Thread.ofVirtual().name("job-notifier-poll").factory());
 
     // Schedule with fixed delay of 1 second, but actual polling is controlled by interval logic
     scheduler.scheduleWithFixedDelay(