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: pr-unsubscr...@cassandra.apache.org For additional commands, e-mail: pr-h...@cassandra.apache.org