You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@fluo.apache.org by mw...@apache.org on 2017/10/06 16:10:36 UTC
[fluo-yarn] branch master updated: Fixes due upstream changes in
Fluo (#9)
This is an automated email from the ASF dual-hosted git repository.
mwalch pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/fluo-yarn.git
The following commit(s) were added to refs/heads/master by this push:
new 322e03f Fixes due upstream changes in Fluo (#9)
322e03f is described below
commit 322e03ff51dd1fda18c529d4e6d65e4b33faf2cd
Author: Mike Walch <mw...@apache.org>
AuthorDate: Fri Oct 6 12:10:34 2017 -0400
Fixes due upstream changes in Fluo (#9)
* Fixes due to changes in Fluo command line
---
core/src/main/java/org/apache/fluo/yarn/core/FluoYarnLauncher.java | 5 +++--
distribution/bin/fluo-yarn | 4 ++--
2 files changed, 5 insertions(+), 4 deletions(-)
diff --git a/core/src/main/java/org/apache/fluo/yarn/core/FluoYarnLauncher.java b/core/src/main/java/org/apache/fluo/yarn/core/FluoYarnLauncher.java
index 7da612e..838bd13 100644
--- a/core/src/main/java/org/apache/fluo/yarn/core/FluoYarnLauncher.java
+++ b/core/src/main/java/org/apache/fluo/yarn/core/FluoYarnLauncher.java
@@ -108,12 +108,12 @@ public class FluoYarnLauncher {
BundledJarRunner.Arguments oracleArgs =
new BundledJarRunner.Arguments.Builder().setJarFileName(env.getBundledJarName())
.setLibFolder("lib").setMainClassName("org.apache.fluo.command.FluoOracle")
- .setMainArgs(new String[] {CONN_PROPS, appName}).createArguments();
+ .setMainArgs(new String[] {"-a", appName}).createArguments();
BundledJarRunner.Arguments workerArgs =
new BundledJarRunner.Arguments.Builder().setJarFileName(env.getBundledJarName())
.setLibFolder("lib").setMainClassName("org.apache.fluo.command.FluoWorker")
- .setMainArgs(new String[] {CONN_PROPS, appName}).createArguments();
+ .setMainArgs(new String[] {"-a", appName}).createArguments();
TwillRunnerService twillRunner =
new YarnTwillRunnerService(env.getYarnConfiguration(), env.getZookeepers());
@@ -122,6 +122,7 @@ public class FluoYarnLauncher {
TwillPreparer preparer =
twillRunner.prepare(new FluoYarnApp(env))
.addJVMOptions("-Dlog4j.configuration=file:$PWD/" + LOG4J_PROPS)
+ .addJVMOptions(("-Dfluo.conn.props=" + CONN_PROPS))
.withArguments(ORACLE_ID, oracleArgs.toArray())
.withArguments(WORKER_ID, workerArgs.toArray());
diff --git a/distribution/bin/fluo-yarn b/distribution/bin/fluo-yarn
index 5c78307..e719380 100755
--- a/distribution/bin/fluo-yarn
+++ b/distribution/bin/fluo-yarn
@@ -53,7 +53,7 @@ function print_usage {
function build_bundled_jar {
app_dir=$lib/apps/$app
mkdir -p "$app_dir/lib"
- $FLUO_HOME/bin/fluo get-jars "$app" "$app_dir/lib"
+ $FLUO_HOME/bin/fluo get-jars -a "$app" -d "$app_dir/lib"
fluo_classpath=$FLUO_CLASSPATH
@@ -88,7 +88,7 @@ start)
print_usage
exit 1
fi
- app_status=$($FLUO_HOME/bin/fluo status $app)
+ app_status=$($FLUO_HOME/bin/fluo status -a $app)
if [[ "$app_status" == "RUNNING" ]]; then
echo "Fluo appplication '$app' is already running!"
exit 1
--
To stop receiving notification emails like this one, please contact
['"commits@fluo.apache.org" <co...@fluo.apache.org>'].