svn commit: r1306042 - in /pig/trunk: CHANGES.txt src/org/apache/pig/backend/hadoop/hbase/HBaseStorage.java

[jc...@apache.org]

Author: jcoveney
Date: Tue Mar 27 23:00:01 2012
New Revision: 1306042

URL: http://svn.apache.org/viewvc?rev=1306042&view=rev
Log:
[trunk] PIG-2619: HBaseStorage constructs a Scan with cacheBlocks = false

Modified:
    pig/trunk/CHANGES.txt
    pig/trunk/src/org/apache/pig/backend/hadoop/hbase/HBaseStorage.java

Modified: pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1306042&r1=1306041&r2=1306042&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Tue Mar 27 23:00:01 2012
@@ -24,6 +24,8 @@ INCOMPATIBLE CHANGES
 
 IMPROVEMENTS
 
+PIG-2619: HBaseStorage constructs a Scan with cacheBlocks = false
+
 PIG-2604: Pig should print its build info at runtime (traviscrawford via dvryaboy)
 
 PIG-2573: Automagically setting parallelism based on input file size does not work with HCatalog (traviscrawford via julien)

Modified: pig/trunk/src/org/apache/pig/backend/hadoop/hbase/HBaseStorage.java
URL: http://svn.apache.org/viewvc/pig/trunk/src/org/apache/pig/backend/hadoop/hbase/HBaseStorage.java?rev=1306042&r1=1306041&r2=1306042&view=diff
==============================================================================
--- pig/trunk/src/org/apache/pig/backend/hadoop/hbase/HBaseStorage.java (original)
+++ pig/trunk/src/org/apache/pig/backend/hadoop/hbase/HBaseStorage.java Tue Mar 27 23:00:01 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")));