was not using HEADERS_KEY in HeaderColumnFamilyChooser, switched to u…

…se it while querying the context
Vijay2win · Jan 19, 2013 · 981bd79 · 981bd79
1 parent 60a92cb
commit 981bd79
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/org/apache/flume/cassandra/HeaderColumnFamilyChooser.java b/src/main/java/org/apache/flume/cassandra/HeaderColumnFamilyChooser.java
@@ -58,6 +58,6 @@ public void configure(final Context context) {
     Preconditions.checkArgument(context.getString(HEADERS_KEY) != null, "chooser.headers must be defined");
 
     joiner = Joiner.on(context.getString(JOINER_KEY, "_")).skipNulls();
-    headersKeys = HEADER_KEY_SPLITTER.split(context.getString("chooser.headers"));
+    headersKeys = HEADER_KEY_SPLITTER.split(context.getString(HEADERS_KEY));
   }
 }