diff --git a/tephra-hbase-compat-0.94/src/main/java/co/cask/tephra/hbase94/coprocessor/TransactionProcessor.java b/tephra-hbase-compat-0.94/src/main/java/co/cask/tephra/hbase94/coprocessor/TransactionProcessor.java index 30d712d6..a3976c0b 100644 --- a/tephra-hbase-compat-0.94/src/main/java/co/cask/tephra/hbase94/coprocessor/TransactionProcessor.java +++ b/tephra-hbase-compat-0.94/src/main/java/co/cask/tephra/hbase94/coprocessor/TransactionProcessor.java @@ -147,7 +147,7 @@ public void preGet(ObserverContext e, Get get, Lis if (LOG.isTraceEnabled()) { LOG.trace("Applying filter to GET for transaction " + tx.getWritePointer()); } - get.setMaxVersions(tx.excludesSize() + 1); + get.setMaxVersions(); get.setTimeRange(TxUtils.getOldestVisibleTimestamp(ttlByFamily, tx), TxUtils.getMaxVisibleTimestamp(tx)); Filter newFilter = Filters.combine(getTransactionFilter(tx, ScanType.USER_SCAN), get.getFilter()); get.setFilter(newFilter); @@ -162,7 +162,7 @@ public RegionScanner preScannerOpen(ObserverContext e, Get get, L throws IOException { Transaction tx = txCodec.getFromOperation(get); if (tx != null) { - get.setMaxVersions(tx.excludesSize() + 1); + get.setMaxVersions(); get.setTimeRange(TxUtils.getOldestVisibleTimestamp(ttlByFamily, tx), TxUtils.getMaxVisibleTimestamp(tx)); Filter newFilter = Filters.combine(getTransactionFilter(tx, ScanType.USER_SCAN), get.getFilter()); get.setFilter(newFilter); @@ -154,7 +154,7 @@ public RegionScanner preScannerOpen(ObserverContext e, Get get, L throws IOException { Transaction tx = txCodec.getFromOperation(get); if (tx != null) { - get.setMaxVersions(tx.excludesSize() + 1); + get.setMaxVersions(); get.setTimeRange(TxUtils.getOldestVisibleTimestamp(ttlByFamily, tx), TxUtils.getMaxVisibleTimestamp(tx)); Filter newFilter = Filters.combine(getTransactionFilter(tx, ScanType.USER_SCAN), get.getFilter()); get.setFilter(newFilter); @@ -154,7 +154,7 @@ public RegionScanner preScannerOpen(ObserverContext