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 <[email protected]> Authored: Wed Apr 18 09:09:09 2012 -0500 Committer: Brandon Williams <[email protected]> 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();
