Github user jasobrown commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/184#discussion_r160496553
--- Diff: src/java/org/apache/cassandra/hadoop/ConfigHelper.java ---
@@ -349,6 +350,16 @@ public static String
getOutputInitialAddress(Configuration conf)
return conf.get(OUTPUT_INITIAL_ADDRESS);
}
+ public static void setOutputInitialPort(Configuration conf, Integer
port)
+ {
+ conf.set(OUTPUT_INITIAL_PORT, port.toString());
+ }
+
+ public static Integer getOutputInitialPort(Configuration conf)
+ {
+ return Integer.valueOf(conf.get(OUTPUT_INITIAL_PORT, "7000"));
--- End diff --
Is this the correct thing to do, hard code `7000`?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
