Updated Branches: refs/heads/trunk a57c472a1 -> 78d6f64f3
BOF still requires CF to be preconfigured Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/78d6f64f Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/78d6f64f Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/78d6f64f Branch: refs/heads/trunk Commit: 78d6f64f33c592890051c690ddf5d26b7b2af027 Parents: a57c472 Author: Jonathan Ellis <[email protected]> Authored: Thu Nov 1 22:21:50 2012 -0500 Committer: Jonathan Ellis <[email protected]> Committed: Thu Nov 1 22:21:50 2012 -0500 ---------------------------------------------------------------------- .../apache/cassandra/hadoop/BulkOutputFormat.java | 6 ++++-- 1 files changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/78d6f64f/src/java/org/apache/cassandra/hadoop/BulkOutputFormat.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/hadoop/BulkOutputFormat.java b/src/java/org/apache/cassandra/hadoop/BulkOutputFormat.java index f4ad9d9..7a6a1d7 100644 --- a/src/java/org/apache/cassandra/hadoop/BulkOutputFormat.java +++ b/src/java/org/apache/cassandra/hadoop/BulkOutputFormat.java @@ -37,8 +37,10 @@ public class BulkOutputFormat extends OutputFormat<ByteBuffer,List<Mutation>> private void checkOutputSpecs(Configuration conf) { - if (ConfigHelper.getOutputKeyspace(conf) == null) - throw new UnsupportedOperationException("You must set the keyspace with setOutputKeyspace()"); + if (ConfigHelper.getOutputKeyspace(conf) == null || ConfigHelper.getOutputColumnFamily(conf) == null) + { + throw new UnsupportedOperationException("you must set the keyspace and columnfamily with setColumnFamily()"); + } } @Override
