Skip to content

skip big rows#1

Open
swapna267 wants to merge 3 commits into
masterfrom
rowTooBig_clienthandling
Open

skip big rows#1
swapna267 wants to merge 3 commits into
masterfrom
rowTooBig_clienthandling

Conversation

@swapna267

Copy link
Copy Markdown
Owner

No description provided.

import java.util.List;
import java.util.Random;

public class TestSkipBigRowScanner {

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

need to add a category for this test:
@category(MediumTests.class)

// Ok, we are good, let's try to get some results from the main heap.
populateResult(results, this.storeHeap, scannerContext, current);
try {
LOG.info("scanner context progress before:"+scannerContext.getKeepProgress());

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Is this logging just the skipped row? shouldn't there be a more explicit log stating Table and row specific details of the row that was too large?

Copy link
Copy Markdown
Owner Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

oops no just added while debugging something. Will remove.
Removed the logging on printing Rowkey for big rows. Is INFO logging ok for that . Might get huge in some cases.

if (doSkipBigRows) {
LOG.info("Skipping big row during scan.Table:" + htableDescriptor.getTableName() +
" ,rowKey:" + Bytes.toStringBinary(current.getRowArray(),
current.getRowOffset(), current.getRowLength()));

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I'm thinking this should be DEBUG level

populateResult(results, this.storeHeap, scannerContext, current);
} catch(RowTooBigException e) {
if (doSkipBigRows) {
LOG.info("Skipping big row during scan.Table:" + htableDescriptor.getTableName() +

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

space missing before "Table"

@@ -0,0 +1,168 @@
package org.apache.hadoop.hbase.regionserver;

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

ASF license header.

throw e;
}
}

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

seems a lot of repetition. can we factor it out?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants