This is an automated email from the ASF dual-hosted git repository.

cshannon pushed a commit to branch elasticity
in repository https://gitbox.apache.org/repos/asf/accumulo.git


The following commit(s) were added to refs/heads/elasticity by this push:
     new 895e0d70eb (#3932) - Fix compilation/test after changes from #3886
895e0d70eb is described below

commit 895e0d70eb1dcf124f7d73d9c77a92869b81bc48
Author: Christopher L. Shannon (cshannon) <christopher.l.shan...@gmail.com>
AuthorDate: Tue Nov 7 08:13:26 2023 -0500

    (#3932) - Fix compilation/test after changes from #3886
---
 .../test/functional/TabletManagementIteratorIT.java         | 13 ++++++++++---
 1 file changed, 10 insertions(+), 3 deletions(-)

diff --git 
a/test/src/main/java/org/apache/accumulo/test/functional/TabletManagementIteratorIT.java
 
b/test/src/main/java/org/apache/accumulo/test/functional/TabletManagementIteratorIT.java
index 7a9b4a74c5..d6b18a7a8c 100644
--- 
a/test/src/main/java/org/apache/accumulo/test/functional/TabletManagementIteratorIT.java
+++ 
b/test/src/main/java/org/apache/accumulo/test/functional/TabletManagementIteratorIT.java
@@ -21,6 +21,7 @@ package org.apache.accumulo.test.functional;
 import static org.junit.jupiter.api.Assertions.assertEquals;
 
 import java.io.IOException;
+import java.nio.file.Path;
 import java.time.Duration;
 import java.util.ArrayList;
 import java.util.Collections;
@@ -32,6 +33,7 @@ import java.util.Map.Entry;
 import java.util.Set;
 import java.util.SortedSet;
 import java.util.TreeSet;
+import java.util.UUID;
 
 import org.apache.accumulo.core.Constants;
 import org.apache.accumulo.core.client.Accumulo;
@@ -67,6 +69,7 @@ import 
org.apache.accumulo.core.metadata.schema.MetadataSchema;
 import org.apache.accumulo.core.metadata.schema.MetadataSchema.TabletsSection;
 import 
org.apache.accumulo.core.metadata.schema.MetadataSchema.TabletsSection.CurrentLocationColumnFamily;
 import 
org.apache.accumulo.core.metadata.schema.MetadataSchema.TabletsSection.HostingColumnFamily;
+import 
org.apache.accumulo.core.metadata.schema.MetadataSchema.TabletsSection.LogColumnFamily;
 import org.apache.accumulo.core.metadata.schema.TabletMetadata;
 import org.apache.accumulo.core.metadata.schema.TabletMetadata.ColumnType;
 import org.apache.accumulo.core.metadata.schema.TabletOperationId;
@@ -86,6 +89,7 @@ import org.slf4j.LoggerFactory;
 
 import com.google.common.collect.Iterables;
 import com.google.common.collect.Sets;
+import com.google.common.net.HostAndPort;
 
 /**
  * Test to ensure that the {@link TabletManagementIterator} properly skips 
over tablet information
@@ -94,6 +98,8 @@ import com.google.common.collect.Sets;
 public class TabletManagementIteratorIT extends AccumuloClusterHarness {
   private final static Logger log = 
LoggerFactory.getLogger(TabletManagementIteratorIT.class);
 
+  private final HostAndPort validHost = HostAndPort.fromParts("default", 8080);
+
   @Override
   protected Duration defaultTimeout() {
     return Duration.ofMinutes(3);
@@ -398,9 +404,10 @@ public class TabletManagementIteratorIT extends 
AccumuloClusterHarness {
         
TableId.of(client.tableOperations().tableIdMap().get(tableNameToModify));
     KeyExtent extent = new KeyExtent(tableIdToModify, new Text("some split"), 
null);
     Mutation m = new Mutation(extent.toMetaRow());
-    LogEntry logEntry = new LogEntry(extent, 55, "lf1");
-    
m.at().family(logEntry.getColumnFamily()).qualifier(logEntry.getColumnQualifier())
-        .timestamp(logEntry.timestamp).put(logEntry.getValue());
+    LogEntry logEntry =
+        new LogEntry(55, Path.of(validHost.toString(), 
UUID.randomUUID().toString()).toString());
+    
m.at().family(LogColumnFamily.NAME).qualifier(logEntry.getColumnQualifier())
+        .timestamp(logEntry.getTimestamp()).put(logEntry.getValue());
     try (BatchWriter bw = client.createBatchWriter(table)) {
       bw.addMutation(m);
     }

Reply via email to