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); }