cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbel...@apache.org
Subject git commit: BOF still requires CF to be preconfigured
Date Fri, 02 Nov 2012 03:22:22 GMT
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 <jbellis@apache.org>
Authored: Thu Nov 1 22:21:50 2012 -0500
Committer: Jonathan Ellis <jbellis@apache.org>
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


Mime
View raw message