Formatting

NationalSecurityAgency · Aug 22, 2024 · 67f37e0 · 67f37e0
1 parent 76db89f
commit 67f37e0
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/warehouse/core/src/main/java/datawave/mr/bulk/BulkInputFormat.java b/warehouse/core/src/main/java/datawave/mr/bulk/BulkInputFormat.java
@@ -78,7 +78,6 @@
 import com.google.common.collect.ArrayListMultimap;
 import com.google.common.collect.Multimap;
 
-
 import datawave.accumulo.inmemory.InMemoryAccumuloClient;
 import datawave.accumulo.inmemory.InMemoryInstance;
 import datawave.accumulo.inmemory.impl.InMemoryTabletLocator;
@@ -92,7 +91,6 @@
 import datawave.util.TextUtil;
 import datawave.util.threads.DatawaveUncaughtExceptionHandler;
 
-
 public class BulkInputFormat extends InputFormat<Key,Value> {
 
     protected static final Logger log = Logger.getLogger(BulkInputFormat.class);
@@ -1087,7 +1085,8 @@ protected static TabletLocator getTabletLocator(Configuration conf) throws Table
         Properties props = Accumulo.newClientProperties().to(conf.get(INSTANCE_NAME), conf.get(ZOOKEEPERS))
                         .as(getUsername(conf), new PasswordToken(getPassword(conf))).build();
         ClientInfo info = ClientInfo.from(props);
-        ClientContext context = new ClientContext(SingletonReservation.noop(), info, ClientConfConverter.toAccumuloConf(info.getProperties()), new DatawaveUncaughtExceptionHandler());
+        DatawaveUncaughtExceptionHandler dueHandler = new DatawaveUncaughtExceptionHandler();
+        ClientContext context = new ClientContext(SingletonReservation.noop(), info, ClientConfConverter.toAccumuloConf(info.getProperties()), dueHandler);
         return TabletLocator.getLocator(context, context.getTableId(tableName));
     }
 
@@ -1128,8 +1127,9 @@ public List<InputSplit> getSplits(JobContext job) throws IOException {
                     // its possible that the cache could contain complete, but old information about a tables tablets... so clear it
                     tl.invalidateCache();
                     ClientInfo info = ClientInfo.from(cbHelper.newClientProperties());
+                    DatawaveUncaughtExceptionHandler dueHandler = new DatawaveUncaughtExceptionHandler();
                     ClientContext context = new ClientContext(SingletonReservation.noop(), info, ClientConfConverter.toAccumuloConf(info.getProperties()),
-                            new DatawaveUncaughtExceptionHandler());
+                            dueHandler);
                     while (!tl.binRanges(context, ranges, binnedRanges).isEmpty()) {
                         if (!(client instanceof InMemoryAccumuloClient)) {
                             if (tableId == null)