This is an automated email from the ASF dual-hosted git repository. dlmarion pushed a commit to branch 2.1 in repository https://gitbox.apache.org/repos/asf/accumulo.git
The following commit(s) were added to refs/heads/2.1 by this push: new fe1999035c Remove ScanServerIT.testScannerTimeout disabled test (#4028) fe1999035c is described below commit fe1999035cdf2f398fa595fc8b9ff682d78daadf Author: Dave Marion <dlmar...@apache.org> AuthorDate: Wed Dec 6 11:30:50 2023 -0500 Remove ScanServerIT.testScannerTimeout disabled test (#4028) Removing test based on discussion in #2606. --- .../org/apache/accumulo/test/ScanServerIT.java | 30 ---------------------- 1 file changed, 30 deletions(-) diff --git a/test/src/main/java/org/apache/accumulo/test/ScanServerIT.java b/test/src/main/java/org/apache/accumulo/test/ScanServerIT.java index 528fd7f441..ad6a38ea72 100644 --- a/test/src/main/java/org/apache/accumulo/test/ScanServerIT.java +++ b/test/src/main/java/org/apache/accumulo/test/ScanServerIT.java @@ -20,7 +20,6 @@ package org.apache.accumulo.test; import static org.apache.accumulo.harness.AccumuloITBase.MINI_CLUSTER_ONLY; import static org.junit.jupiter.api.Assertions.assertEquals; -import static org.junit.jupiter.api.Assertions.assertFalse; import static org.junit.jupiter.api.Assertions.assertNotNull; import static org.junit.jupiter.api.Assertions.assertThrows; @@ -52,7 +51,6 @@ import org.apache.accumulo.test.functional.ReadWriteIT; import org.apache.accumulo.test.functional.SlowIterator; import org.junit.jupiter.api.AfterAll; import org.junit.jupiter.api.BeforeAll; -import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Tag; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Timeout; @@ -166,34 +164,6 @@ public class ScanServerIT extends SharedMiniClusterBase { } } - @Test - @Disabled("Scanner.setTimeout does not work, issue #2606") - @Timeout(value = 20) - public void testScannerTimeout() throws Exception { - // Configure the client to use different scan server selector property values - Properties props = getClientProps(); - String profiles = "[{'isDefault':true,'maxBusyTimeout':'1s', 'busyTimeoutMultiplier':8, " - + "'attemptPlans':[{'servers':'3', 'busyTimeout':'100ms'}," - + "{'servers':'100%', 'busyTimeout':'100ms'}]}]"; - props.put(ClientProperty.SCAN_SERVER_SELECTOR_OPTS_PREFIX.getKey() + "profiles", profiles); - - String tableName = getUniqueNames(1)[0]; - try (AccumuloClient client = Accumulo.newClient().from(props).build()) { - createTableAndIngest(client, tableName, null, 10, 10, "colf"); - try (Scanner scanner = client.createScanner(tableName, Authorizations.EMPTY)) { - IteratorSetting slow = new IteratorSetting(30, "slow", SlowIterator.class); - SlowIterator.setSleepTime(slow, 30000); - SlowIterator.setSeekSleepTime(slow, 30000); - scanner.addScanIterator(slow); - scanner.setRange(new Range()); - scanner.setConsistencyLevel(ConsistencyLevel.EVENTUAL); - scanner.setTimeout(10, TimeUnit.SECONDS); - assertFalse(scanner.stream().findAny().isPresent(), - "The scanner should not see any entries"); - } - } - } - @Test @Timeout(value = 20) public void testBatchScannerTimeout() throws Exception {