From bd2140fc083548c74c937161335c0d199522a259 Mon Sep 17 00:00:00 2001 From: Peter Somogyi Date: Mon, 17 Oct 2022 09:38:45 +0200 Subject: [PATCH] HBASE-27431 Remove TestRemoteTable.testLimitedScan (#4832) Signed-off-by: Duo Zhang --- .../hbase/rest/client/TestRemoteTable.java | 41 ------------------- 1 file changed, 41 deletions(-) diff --git a/hbase-rest/src/test/java/org/apache/hadoop/hbase/rest/client/TestRemoteTable.java b/hbase-rest/src/test/java/org/apache/hadoop/hbase/rest/client/TestRemoteTable.java index de1bb561327..3a19934d749 100644 --- a/hbase-rest/src/test/java/org/apache/hadoop/hbase/rest/client/TestRemoteTable.java +++ b/hbase-rest/src/test/java/org/apache/hadoop/hbase/rest/client/TestRemoteTable.java @@ -574,47 +574,6 @@ public class TestRemoteTable { assertTrue(response.hasBody()); } - /** - * Tests scanner with limitation limit the number of rows each scanner scan fetch at life time The - * number of rows returned should be equal to the limit - */ - @Test - public void testLimitedScan() throws Exception { - int numTrials = 100; - int limit = 60; - - // Truncate the test table for inserting test scenarios rows keys - TEST_UTIL.getAdmin().disableTable(TABLE); - TEST_UTIL.getAdmin().truncateTable(TABLE, false); - String row = "testrow"; - - try (Table table = TEST_UTIL.getConnection().getTable(TABLE)) { - List puts = new ArrayList<>(); - Put put = null; - for (int i = 1; i <= numTrials; i++) { - put = new Put(Bytes.toBytes(row + i)); - put.addColumn(COLUMN_1, QUALIFIER_1, TS_2, Bytes.toBytes("testvalue" + i)); - puts.add(put); - } - table.put(puts); - } - - remoteTable = - new RemoteHTable(new Client(new Cluster().add("localhost", REST_TEST_UTIL.getServletPort())), - TEST_UTIL.getConfiguration(), TABLE.toBytes()); - - Scan scan = new Scan(); - scan.setLimit(limit); - ResultScanner scanner = remoteTable.getScanner(scan); - Iterator resultIterator = scanner.iterator(); - int counter = 0; - while (resultIterator.hasNext()) { - resultIterator.next(); - counter++; - } - assertEquals(limit, counter); - } - /** * Tests keeping a HBase scanner alive for long periods of time. Each call to next() should reset * the ConnectionCache timeout for the scanner's connection.