Permalink
Browse files

Fix for the fix-- make sure we're consistent in our use of longs

  • Loading branch information...
1 parent 8337f1b commit df78bcb01018fefd3ecdca12837c37113ad6fc8c @jwills jwills committed Apr 7, 2012
Showing with 2 additions and 2 deletions.
  1. +2 −2 src/main/java/com/cloudera/crunch/impl/mr/collect/PGroupedTableImpl.java
View
4 src/main/java/com/cloudera/crunch/impl/mr/collect/PGroupedTableImpl.java
@@ -55,8 +55,8 @@
public void configureShuffle(Job job) {
ptype.configureShuffle(job, groupingOptions);
if (groupingOptions == null || groupingOptions.getNumReducers() <= 0) {
- long bytesPerTask = job.getConfiguration().getInt("crunch.bytes.per.reduce.task",
- (1000 * 1000 * 1000));
+ long bytesPerTask = job.getConfiguration().getLong("crunch.bytes.per.reduce.task",
+ (1000L * 1000L * 1000L));
int numReduceTasks = 1 + (int) (getSize() / bytesPerTask);
if (numReduceTasks > 0) {
job.setNumReduceTasks(numReduceTasks);

0 comments on commit df78bcb

Please sign in to comment.