cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From brandonwilli...@apache.org
Subject [2/3] git commit: Fix typo in BRW config. Patch by Michal Michalski, reviewed by brandonwilliams for CASSANDRA-4166
Date Wed, 18 Apr 2012 14:10:33 GMT
Fix typo in BRW config.
Patch by Michal Michalski, reviewed by brandonwilliams for
CASSANDRA-4166


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/01a8c1c5
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/01a8c1c5
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/01a8c1c5

Branch: refs/heads/trunk
Commit: 01a8c1c5f5f90e50ba0598e88879d725a7cd3673
Parents: 57de08a
Author: Brandon Williams <brandonwilliams@apache.org>
Authored: Wed Apr 18 09:09:09 2012 -0500
Committer: Brandon Williams <brandonwilliams@apache.org>
Committed: Wed Apr 18 09:09:09 2012 -0500

----------------------------------------------------------------------
 .../apache/cassandra/hadoop/BulkRecordWriter.java  |    2 +-
 1 files changed, 1 insertions(+), 1 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/01a8c1c5/src/java/org/apache/cassandra/hadoop/BulkRecordWriter.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/hadoop/BulkRecordWriter.java b/src/java/org/apache/cassandra/hadoop/BulkRecordWriter.java
index e430e9b..83646fb 100644
--- a/src/java/org/apache/cassandra/hadoop/BulkRecordWriter.java
+++ b/src/java/org/apache/cassandra/hadoop/BulkRecordWriter.java
@@ -100,7 +100,7 @@ implements org.apache.hadoop.mapred.RecordWriter<ByteBuffer,List<Mutation>>
         Config.setOutboundBindAny(true);
         this.conf = conf;
         DatabaseDescriptor.setStreamThroughputOutboundMegabitsPerSec(Integer.valueOf(conf.get(STREAM_THROTTLE_MBITS,
"0")));
-        maxFailures = Integer.valueOf(conf.get(MAX_FAILED_HOSTS, "O"));
+        maxFailures = Integer.valueOf(conf.get(MAX_FAILED_HOSTS, "0"));
         String keyspace = ConfigHelper.getOutputKeyspace(conf);
         outputdir = new File(getOutputLocation() + File.separator + keyspace + File.separator
+ ConfigHelper.getOutputColumnFamily(conf)); //dir must be named by ks/cf for the loader
         outputdir.mkdirs();


Mime
View raw message