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 {

Reply via email to