fix(test): chunk PopulateDBConfiguration bulk inserts and fail fast on errors

Bulk requests of 1500+ channels with rich property payloads exceeded the
default ES circuit-breaker limit (~102 MiB), causing 429/413 rejections in
CI. Split channel inserts into batches of 1000 and throw on bulk errors
rather than logging and continuing with a silently empty index.

Same fail-fast treatment applied to checkBulkResponse (properties/tags).

Author: anderslindho

src/main/java/org/phoebus/channelfinder/configuration/PopulateDBConfiguration.java

@@ -225,28 +225,27 @@ private void checkBulkResponse(BulkRequest.Builder br) {
     try {
       BulkResponse results = client.bulk(br.build());
       if (results.errors()) {
-        logger.log(Level.SEVERE, "CreateDB Bulk had errors");
+        StringBuilder errors = new StringBuilder("CreateDB bulk had errors:");
         for (BulkResponseItem item : results.items()) {
           if (item.error() != null) {
-            logger.log(Level.SEVERE, () -> item.error().reason());
+            errors.append("\n  ").append(item.error().reason());
           }
         }
+        throw new RuntimeException(errors.toString());
       }
     } catch (IOException e) {
-      logger.log(Level.WARNING, "CreateDB Bulk operation failed.", e);
+      throw new RuntimeException("CreateDB bulk operation failed", e);
     }
   }
 
   private void bulkInsertAllChannels(Collection<Channel> channels) {
+    logger.info("Bulk inserting channels");
     try {
-      logger.info("Bulk inserting channels");
-
       bulkInsertChannels(channels);
-      channels.clear();
-
-    } catch (Exception e) {
-      logger.log(Level.WARNING, e.getMessage(), e);
+    } catch (IOException e) {
+      throw new RuntimeException("Failed to bulk insert channels into test database", e);
     }
+    channels.clear();
   }
 
   private void createBOChannels(Collection<Channel> channels, int freq) {
@@ -400,32 +399,43 @@ private Collection<Channel> insertSRCell(String cell) {
     return result;
   }
 
-  private void bulkInsertChannels(Collection<Channel> result) throws IOException {
-    long start = System.currentTimeMillis();
-    BulkRequest.Builder br = new BulkRequest.Builder();
-    for (Channel channel : result) {
-      br.operations(
-          op ->
-              op.index(
-                  IndexOperation.of(
-                      i ->
-                          i.index(esService.getES_CHANNEL_INDEX())
-                              .id(channel.getName())
-                              .document(channel))));
-    }
-    String prepare = "|Prepare: " + (System.currentTimeMillis() - start) + "|";
-    start = System.currentTimeMillis();
-    br.refresh(Refresh.True);
-
-    BulkResponse srResult = client.bulk(br.build());
-    String execute = "|Execute: " + (System.currentTimeMillis() - start) + "|";
-    logger.log(Level.INFO, () -> "Inserted cell " + prepare + " " + execute);
-    if (srResult.errors()) {
-      logger.log(Level.SEVERE, "Bulk insert had errors");
-      for (BulkResponseItem item : srResult.items()) {
-        if (item.error() != null) {
-          logger.log(Level.SEVERE, () -> item.error().reason());
+  private static final int BULK_INSERT_BATCH_SIZE = 1000;
+
+  private void bulkInsertChannels(Collection<Channel> channels) throws IOException {
+    List<Channel> list = new ArrayList<>(channels);
+    for (int offset = 0; offset < list.size(); offset += BULK_INSERT_BATCH_SIZE) {
+      List<Channel> batch =
+          list.subList(offset, Math.min(offset + BULK_INSERT_BATCH_SIZE, list.size()));
+      int batchCount = batch.size();
+      long t0 = System.currentTimeMillis();
+      BulkRequest.Builder br = new BulkRequest.Builder();
+      for (Channel channel : batch) {
+        br.operations(
+            op ->
+                op.index(
+                    IndexOperation.of(
+                        i ->
+                            i.index(esService.getES_CHANNEL_INDEX())
+                                .id(channel.getName())
+                                .document(channel))));
+      }
+      String prepare = "|Prepare: " + (System.currentTimeMillis() - t0) + "|";
+      t0 = System.currentTimeMillis();
+      br.refresh(Refresh.True);
+      BulkResponse result = client.bulk(br.build());
+      String execute = "|Execute: " + (System.currentTimeMillis() - t0) + "|";
+      logger.log(
+          Level.INFO,
+          () -> "Inserted batch (" + batchCount + " channels) " + prepare + " " + execute);
+      if (result.errors()) {
+        StringBuilder errors = new StringBuilder("Bulk insert batch had errors:");
+        for (BulkResponseItem item : result.items()) {
+          if (item.error() != null) {
+            errors.append("\n  ").append(item.error().reason());
+          }
         }
+        logger.log(Level.SEVERE, errors.toString());
+        throw new IOException(errors.toString());
       }
     }
   }