abdullah alamoudi has uploaded a new change for review.
https://asterix-gerrit.ics.uci.edu/1354
Change subject: Fix Installer tests on Local machines
......................................................................
Fix Installer tests on Local machines
Change-Id: Idcb10e0e72d6a60d91fe1845567bac1208991f93
---
M
asterixdb/asterix-app/src/main/java/org/apache/asterix/hyracks/bootstrap/CCApplicationEntryPoint.java
M
asterixdb/asterix-events/src/main/java/org/apache/asterix/event/management/EventExecutor.java
M asterixdb/asterix-events/src/main/resources/events/cc_start/cc_start.sh
M asterixdb/asterix-events/src/main/resources/events/node_join/nc_join.sh
M
asterixdb/asterix-installer/src/main/java/org/apache/asterix/installer/command/ConfigureCommand.java
M
asterixdb/asterix-installer/src/main/java/org/apache/asterix/installer/command/DeleteCommand.java
M
asterixdb/asterix-installer/src/test/java/org/apache/asterix/installer/test/AsterixLifecycleIT.java
7 files changed, 15 insertions(+), 7 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb
refs/changes/54/1354/1
diff --git
a/asterixdb/asterix-app/src/main/java/org/apache/asterix/hyracks/bootstrap/CCApplicationEntryPoint.java
b/asterixdb/asterix-app/src/main/java/org/apache/asterix/hyracks/bootstrap/CCApplicationEntryPoint.java
index aff6a75..1a03bce 100644
---
a/asterixdb/asterix-app/src/main/java/org/apache/asterix/hyracks/bootstrap/CCApplicationEntryPoint.java
+++
b/asterixdb/asterix-app/src/main/java/org/apache/asterix/hyracks/bootstrap/CCApplicationEntryPoint.java
@@ -88,6 +88,7 @@
@Override
public void start(ICCApplicationContext ccAppCtx, String[] args) throws
Exception {
+ System.err.println("Start Called");
final ClusterControllerService controllerService =
(ClusterControllerService) ccAppCtx.getControllerService();
IMessageBroker messageBroker = new CCMessageBroker(controllerService);
this.appCtx = ccAppCtx;
diff --git
a/asterixdb/asterix-events/src/main/java/org/apache/asterix/event/management/EventExecutor.java
b/asterixdb/asterix-events/src/main/java/org/apache/asterix/event/management/EventExecutor.java
index ebeea63..98d680b 100644
---
a/asterixdb/asterix-events/src/main/java/org/apache/asterix/event/management/EventExecutor.java
+++
b/asterixdb/asterix-events/src/main/java/org/apache/asterix/event/management/EventExecutor.java
@@ -22,6 +22,7 @@
import java.io.File;
import java.io.IOException;
import java.io.StringWriter;
+import java.lang.ProcessBuilder.Redirect;
import java.util.ArrayList;
import java.util.List;
@@ -44,7 +45,7 @@
public void executeEvent(Node node, String script, List<String> args,
boolean isDaemon, Cluster cluster,
Pattern pattern, IOutputHandler outputHandler,
AsterixEventServiceClient client) throws IOException {
- List<String> pargs = new ArrayList<String>();
+ List<String> pargs = new ArrayList<>();
pargs.add("/bin/bash");
pargs.add(client.getEventsHomeDir() + File.separator +
AsterixEventServiceUtil.EVENT_DIR + File.separator
+ EXECUTE_SCRIPT);
@@ -89,6 +90,9 @@
pb.environment().put(ARGS, argBuffer.toString());
pb.environment().put(DAEMON, Boolean.toString(isDaemon));
+ pb.redirectOutput(Redirect.INHERIT);
+ pb.redirectError(Redirect.INHERIT);
+
Process p = pb.start();
if (!isDaemon) {
BufferedInputStream bis = new
BufferedInputStream(p.getInputStream());
diff --git
a/asterixdb/asterix-events/src/main/resources/events/cc_start/cc_start.sh
b/asterixdb/asterix-events/src/main/resources/events/cc_start/cc_start.sh
index c761744..c33ba6c 100644
--- a/asterixdb/asterix-events/src/main/resources/events/cc_start/cc_start.sh
+++ b/asterixdb/asterix-events/src/main/resources/events/cc_start/cc_start.sh
@@ -74,4 +74,4 @@
LOG START: $DATE
--------------------------------------------------------------------------------
EOF
-$ASTERIX_HOME/bin/asterixcc echo $ccArgs &>> $LOG_DIR/cc.log
\ No newline at end of file
+$ASTERIX_HOME/bin/asterixcc echo $ccArgs >> $LOG_DIR/cc.log 2>&1
\ No newline at end of file
diff --git
a/asterixdb/asterix-events/src/main/resources/events/node_join/nc_join.sh
b/asterixdb/asterix-events/src/main/resources/events/node_join/nc_join.sh
index 1a3de9a..7f86379 100644
--- a/asterixdb/asterix-events/src/main/resources/events/node_join/nc_join.sh
+++ b/asterixdb/asterix-events/src/main/resources/events/node_join/nc_join.sh
@@ -34,4 +34,4 @@
LOG START: $DATE
--------------------------------------------------------------------------------
EOF
-$ASTERIX_HOME/bin/asterixnc -node-id $NC_ID -cc-host $CC_HOST -cc-port
$CLUSTER_NET_PORT -cluster-net-ip-address $IP_LOCATION -data-ip-address
$IP_LOCATION -iodevices $IO_DEVICES -result-ip-address $IP_LOCATION --
$INITIAL_RUN_FLAG &>> $LOG_DIR/${NC_ID}.log
+$ASTERIX_HOME/bin/asterixnc -node-id $NC_ID -cc-host $CC_HOST -cc-port
$CLUSTER_NET_PORT -cluster-net-ip-address $IP_LOCATION -data-ip-address
$IP_LOCATION -iodevices $IO_DEVICES -result-ip-address $IP_LOCATION --
$INITIAL_RUN_FLAG >> $LOG_DIR/${NC_ID}.log 2>&1
diff --git
a/asterixdb/asterix-installer/src/main/java/org/apache/asterix/installer/command/ConfigureCommand.java
b/asterixdb/asterix-installer/src/main/java/org/apache/asterix/installer/command/ConfigureCommand.java
index eaf6cf4..aeb118f 100644
---
a/asterixdb/asterix-installer/src/main/java/org/apache/asterix/installer/command/ConfigureCommand.java
+++
b/asterixdb/asterix-installer/src/main/java/org/apache/asterix/installer/command/ConfigureCommand.java
@@ -72,7 +72,11 @@
cluster.setIodevices(configureIoDevices(cluster.getIodevices(),
workingDir));
cluster.setLogDir(configureDirectory(cluster.getLogDir(), workingDir));
cluster.setTxnLogDir(configureDirectory(cluster.getTxnLogDir(),
workingDir));
- cluster.setJavaHome(System.getProperty("java.home"));
+ String javaHome = System.getProperty("java.home");
+ if (javaHome.endsWith(File.separator + "jre")) {
+ javaHome = javaHome.substring(0, javaHome.indexOf(File.separator +
"jre"));
+ }
+ cluster.setJavaHome(javaHome);
for (Node node : cluster.getNode()) {
node.setIodevices(configureIoDevices(node.getIodevices(),
workingDir));
diff --git
a/asterixdb/asterix-installer/src/main/java/org/apache/asterix/installer/command/DeleteCommand.java
b/asterixdb/asterix-installer/src/main/java/org/apache/asterix/installer/command/DeleteCommand.java
index 4e446f8..043d48a 100644
---
a/asterixdb/asterix-installer/src/main/java/org/apache/asterix/installer/command/DeleteCommand.java
+++
b/asterixdb/asterix-installer/src/main/java/org/apache/asterix/installer/command/DeleteCommand.java
@@ -18,8 +18,6 @@
*/
package org.apache.asterix.installer.command;
-import org.kohsuke.args4j.Option;
-
import org.apache.asterix.event.model.AsterixInstance;
import org.apache.asterix.event.model.AsterixInstance.State;
import org.apache.asterix.event.schema.pattern.Patterns;
@@ -28,6 +26,7 @@
import org.apache.asterix.event.service.ServiceProvider;
import org.apache.asterix.event.util.PatternCreator;
import org.apache.asterix.installer.driver.InstallerDriver;
+import org.kohsuke.args4j.Option;
public class DeleteCommand extends AbstractCommand {
diff --git
a/asterixdb/asterix-installer/src/test/java/org/apache/asterix/installer/test/AsterixLifecycleIT.java
b/asterixdb/asterix-installer/src/test/java/org/apache/asterix/installer/test/AsterixLifecycleIT.java
index 52e75cc..04e73ed 100644
---
a/asterixdb/asterix-installer/src/test/java/org/apache/asterix/installer/test/AsterixLifecycleIT.java
+++
b/asterixdb/asterix-installer/src/test/java/org/apache/asterix/installer/test/AsterixLifecycleIT.java
@@ -72,7 +72,7 @@
@Parameters
public static Collection<Object[]> tests() throws Exception {
- Collection<Object[]> testArgs = new ArrayList<Object[]>();
+ Collection<Object[]> testArgs = new ArrayList<>();
return testArgs;
}
--
To view, visit https://asterix-gerrit.ics.uci.edu/1354
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: Idcb10e0e72d6a60d91fe1845567bac1208991f93
Gerrit-PatchSet: 1
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: abdullah alamoudi <[email protected]>
