Author: thejas
Date: Mon Aug 23 20:46:53 2010
New Revision: 988307
URL: http://svn.apache.org/viewvc?rev=988307&view=rev
Log:
PIG-1447: Tune memory usage of InternalCachedBag
Modified:
hadoop/pig/trunk/CHANGES.txt
hadoop/pig/trunk/src/org/apache/pig/data/InternalCachedBag.java
hadoop/pig/trunk/src/org/apache/pig/data/InternalDistinctBag.java
hadoop/pig/trunk/src/org/apache/pig/data/InternalSortedBag.java
Modified: hadoop/pig/trunk/CHANGES.txt
URL:
http://svn.apache.org/viewvc/hadoop/pig/trunk/CHANGES.txt?rev=988307&r1=988306&r2=988307&view=diff
==============================================================================
--- hadoop/pig/trunk/CHANGES.txt (original)
+++ hadoop/pig/trunk/CHANGES.txt Mon Aug 23 20:46:53 2010
@@ -26,6 +26,8 @@ PIG-1249: Safe-guards against misconfigu
IMPROVEMENTS
+PIG-1447: Tune memory usage of InternalCachedBag (thejas)
+
PIG-1505: support jars and scripts in dfs (anhi via rding)
PIG-1334: Make pig artifacts available through maven (niraj via rding)
Modified: hadoop/pig/trunk/src/org/apache/pig/data/InternalCachedBag.java
URL:
http://svn.apache.org/viewvc/hadoop/pig/trunk/src/org/apache/pig/data/InternalCachedBag.java?rev=988307&r1=988306&r2=988307&view=diff
==============================================================================
--- hadoop/pig/trunk/src/org/apache/pig/data/InternalCachedBag.java (original)
+++ hadoop/pig/trunk/src/org/apache/pig/data/InternalCachedBag.java Mon Aug 23
20:46:53 2010
@@ -55,7 +55,7 @@ public class InternalCachedBag extends D
}
public InternalCachedBag(int bagCount) {
- float percent = 0.1F;
+ float percent = 0.2F;
if (PigMapReduce.sJobConf != null) {
String usage =
PigMapReduce.sJobConf.get("pig.cachedbag.memusage");
Modified: hadoop/pig/trunk/src/org/apache/pig/data/InternalDistinctBag.java
URL:
http://svn.apache.org/viewvc/hadoop/pig/trunk/src/org/apache/pig/data/InternalDistinctBag.java?rev=988307&r1=988306&r2=988307&view=diff
==============================================================================
--- hadoop/pig/trunk/src/org/apache/pig/data/InternalDistinctBag.java (original)
+++ hadoop/pig/trunk/src/org/apache/pig/data/InternalDistinctBag.java Mon Aug
23 20:46:53 2010
@@ -81,7 +81,7 @@ public class InternalDistinctBag extends
public InternalDistinctBag(int bagCount, double percent) {
if (percent < 0) {
- percent = 0.1F;
+ percent = 0.2F;
if (PigMapReduce.sJobConf != null) {
String usage =
PigMapReduce.sJobConf.get("pig.cachedbag.memusage");
if (usage != null) {
Modified: hadoop/pig/trunk/src/org/apache/pig/data/InternalSortedBag.java
URL:
http://svn.apache.org/viewvc/hadoop/pig/trunk/src/org/apache/pig/data/InternalSortedBag.java?rev=988307&r1=988306&r2=988307&view=diff
==============================================================================
--- hadoop/pig/trunk/src/org/apache/pig/data/InternalSortedBag.java (original)
+++ hadoop/pig/trunk/src/org/apache/pig/data/InternalSortedBag.java Mon Aug 23
20:46:53 2010
@@ -98,7 +98,7 @@ public class InternalSortedBag extends S
public InternalSortedBag(int bagCount, double percent, Comparator<Tuple>
comp) {
if (percent < 0) {
- percent = 0.1F;
+ percent = 0.2F;
if (PigMapReduce.sJobConf != null) {
String usage =
PigMapReduce.sJobConf.get("pig.cachedbag.memusage");
if (usage != null) {
