You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ps...@apache.org on 2022/10/17 07:41:21 UTC
[hbase] branch branch-2.4 updated: HBASE-27431 Remove TestRemoteTable.testLimitedScan (#4832)
This is an automated email from the ASF dual-hosted git repository.
psomogyi pushed a commit to branch branch-2.4
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/branch-2.4 by this push:
new 8d81f87cad7 HBASE-27431 Remove TestRemoteTable.testLimitedScan (#4832)
8d81f87cad7 is described below
commit 8d81f87cad7c611793b775d7af8ceb482c131552
Author: Peter Somogyi <ps...@apache.org>
AuthorDate: Mon Oct 17 09:38:45 2022 +0200
HBASE-27431 Remove TestRemoteTable.testLimitedScan (#4832)
Signed-off-by: Duo Zhang <zh...@apache.org>
---
.../hadoop/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 a6b40d040b8..06c672c5a2f 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
@@ -573,47 +573,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<Put> 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<Result> 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.