You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by jc...@apache.org on 2012/03/28 00:59:21 UTC
svn commit: r1306041 - in /pig/branches/branch-0.10: CHANGES.txt
src/org/apache/pig/backend/hadoop/hbase/HBaseStorage.java
Author: jcoveney
Date: Tue Mar 27 22:59:21 2012
New Revision: 1306041
URL: http://svn.apache.org/viewvc?rev=1306041&view=rev
Log:
[0.10] PIG-2619: HBaseStorage constructs a Scan with cacheBlocks = false
Modified:
pig/branches/branch-0.10/CHANGES.txt
pig/branches/branch-0.10/src/org/apache/pig/backend/hadoop/hbase/HBaseStorage.java
Modified: pig/branches/branch-0.10/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.10/CHANGES.txt?rev=1306041&r1=1306040&r2=1306041&view=diff
==============================================================================
--- pig/branches/branch-0.10/CHANGES.txt (original)
+++ pig/branches/branch-0.10/CHANGES.txt Tue Mar 27 22:59:21 2012
@@ -24,6 +24,8 @@ INCOMPATIBLE CHANGES
IMPROVEMENTS
+PIG-2619: HBaseStorage constructs a Scan with cacheBlocks = false (andy lindeman via jcoveney)
+
PIG-1270: Push limit into loader (daijy)
PIG-2604: Pig should print its build info at runtime (traviscrawford via dvryaboy)
Modified: pig/branches/branch-0.10/src/org/apache/pig/backend/hadoop/hbase/HBaseStorage.java
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.10/src/org/apache/pig/backend/hadoop/hbase/HBaseStorage.java?rev=1306041&r1=1306040&r2=1306041&view=diff
==============================================================================
--- pig/branches/branch-0.10/src/org/apache/pig/backend/hadoop/hbase/HBaseStorage.java (original)
+++ pig/branches/branch-0.10/src/org/apache/pig/backend/hadoop/hbase/HBaseStorage.java Tue Mar 27 22:59:21 2012
@@ -329,6 +329,10 @@ public class HBaseStorage extends LoadFu
private void initScan() {
scan = new Scan();
+
+ // Map-reduce jobs should not run with cacheBlocks
+ scan.setCacheBlocks(false);
+
// Set filters, if any.
if (configuredOptions_.hasOption("gt")) {
gt_ = Bytes.toBytesBinary(Utils.slashisize(configuredOptions_.getOptionValue("gt")));