[
https://issues.apache.org/jira/browse/CASSANDRA-4155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13269446#comment-13269446
]
Michał Michalski commented on CASSANDRA-4155:
-
Not sure if it's the best place to report this, but I can see that the last
changes in ./src/java/org/apache/cassandra/hadoop/ConfigHelper.java did some
mess in this task. 09b4e7bdfb113715b3e1ae0be179415fab79d4b7 has removed all the
setters and getters I added here and 65d51bb747cc5b7f60a58793026529cb4c6bdf1d
has only restored one of them:
{noformat}michal@aperture:~/workspace/cassandra-trunk$ cat missing-code.tmp
commit 65d51bb747cc5b7f60a58793026529cb4c6bdf1d
Author: Brandon Williams brandonwilli...@apache.org
Date: Wed Apr 18 14:44:58 2012 -0500
Fix the fix of the crazy automerge
diff --git a/src/java/org/apache/cassandra/hadoop/ConfigHelper.java
b/src/java/org/apache/cassandra/hadoop/ConfigHelper.java
index 81dbf38..8ec215e 100644
--- a/src/java/org/apache/cassandra/hadoop/ConfigHelper.java
+++ b/src/java/org/apache/cassandra/hadoop/ConfigHelper.java
@@ -304,6 +304,11 @@ public class ConfigHelper
return conf.get(OUTPUT_KEYSPACE_USERNAME_CONFIG);
}
+public static String getOutputKeyspacePassword(Configuration conf)
+{
+return conf.get(OUTPUT_KEYSPACE_PASSWD_CONFIG);
+}
+
public static String getInputColumnFamily(Configuration conf)
{
return conf.get(INPUT_COLUMNFAMILY_CONFIG);
commit 09b4e7bdfb113715b3e1ae0be179415fab79d4b7
Author: Brandon Williams brandonwilli...@apache.org
Date: Wed Apr 18 14:29:38 2012 -0500
Fix crazy automerge
diff --git a/src/java/org/apache/cassandra/hadoop/ConfigHelper.java
b/src/java/org/apache/cassandra/hadoop/ConfigHelper.java
index 68a8761..81dbf38 100644
--- a/src/java/org/apache/cassandra/hadoop/ConfigHelper.java
+++ b/src/java/org/apache/cassandra/hadoop/ConfigHelper.java
@@ -299,36 +299,11 @@ public class ConfigHelper
return conf.get(INPUT_KEYSPACE_PASSWD_CONFIG);
}
-public static void setOutputKeyspaceUserName(Configuration conf, String
username)
-{
-conf.set(OUTPUT_KEYSPACE_USERNAME_CONFIG, username);
-}
-
-public static void setOutputKeyspaceUserName(Configuration conf, String
username)
-{
-conf.set(OUTPUT_KEYSPACE_USERNAME_CONFIG, username);
-}
-
public static String getOutputKeyspaceUserName(Configuration conf)
{
return conf.get(OUTPUT_KEYSPACE_USERNAME_CONFIG);
}
-public static void setOutputKeyspacePassword(Configuration conf, String
password)
-{
-conf.set(OUTPUT_KEYSPACE_PASSWD_CONFIG, password);
-}
-
-public static void setOutputKeyspacePassword(Configuration conf, String
password)
-{
-conf.set(OUTPUT_KEYSPACE_PASSWD_CONFIG, password);
-}
-
-public static String getOutputKeyspacePassword(Configuration conf)
-{
-return conf.get(OUTPUT_KEYSPACE_PASSWD_CONFIG);
-}
-
public static String getInputColumnFamily(Configuration conf)
{
return conf.get(INPUT_COLUMNFAMILY_CONFIG);
{noformat}
Can you fix this or maybe should I prepare another patch against current trunk
for this? Or maybe do it in separate issue?
It really was a crazy automerge ;)
Make possible to authenticate user when loading data to Cassandra with
BulkRecordWriter.
Key: CASSANDRA-4155
URL: https://issues.apache.org/jira/browse/CASSANDRA-4155
Project: Cassandra
Issue Type: Improvement
Reporter: Michał Michalski
Assignee: Michał Michalski
Priority: Minor
Fix For: 1.1.1
Attachments: trunk-4155-nicer-version.txt, trunk-4155-updated-1.txt,
trunk-4155.txt
I need to use the authorization feature (i.e. provided by SimpleAuthenticator
and SimpleAuthority). The problem is that it's impossible now to pass the
credentials (cassandra.output.keyspace.username and
cassandra.output.keyspace.passwd) to org.apache.cassandra.hadoop.ConfigHelper
because of no setters for these variables. Moreover, even if they could be
passed, nothing will change because they are unused - ExternalClient class
from org.apache.cassandra.hadoop.BulkRecordWriter is not making use of them;
it's not even receiving them and no authorization is provided.
The proposed improvement is to make it possible to authenticate user when
loading data to Cassandra with BulkRecordWriter by adding appropriate setters
to ConfigHelper and then passing credentials to ExternalClient class so it
could use it for authorization request.
I have created a patch for this which I attach.
This improvement was made in the way that does not charm existing
ExternalClient interface usage, but I think that it would be