fix connection issue in client code
git-svn-id: https://asterixdb.googlecode.com/svn/branches/asterix_stabilization@123 eaa15691-b419-025a-1212-ee371bd00084
diff --git a/asterix-app/src/main/java/edu/uci/ics/asterix/api/aqlj/server/APIClientThreadFactory.java b/asterix-app/src/main/java/edu/uci/ics/asterix/api/aqlj/server/APIClientThreadFactory.java
index 682d774..7f35af6 100644
--- a/asterix-app/src/main/java/edu/uci/ics/asterix/api/aqlj/server/APIClientThreadFactory.java
+++ b/asterix-app/src/main/java/edu/uci/ics/asterix/api/aqlj/server/APIClientThreadFactory.java
@@ -33,7 +33,7 @@
public APIClientThreadFactory(ICCApplicationContext appContext) throws Exception {
this.appContext = appContext;
- hcc = new HyracksConnection("localhost", appContext.getCCContext().getClusterControllerInfo()
+ hcc = new HyracksConnection(appContext.getCCContext().getClusterControllerInfo().getClientNetAddress(), appContext.getCCContext().getClusterControllerInfo()
.getClientNetPort());
}
diff --git a/asterix-app/src/main/java/edu/uci/ics/asterix/api/http/servlet/APIServlet.java b/asterix-app/src/main/java/edu/uci/ics/asterix/api/http/servlet/APIServlet.java
index 7bc454a..49db9c5 100644
--- a/asterix-app/src/main/java/edu/uci/ics/asterix/api/http/servlet/APIServlet.java
+++ b/asterix-app/src/main/java/edu/uci/ics/asterix/api/http/servlet/APIServlet.java
@@ -40,6 +40,7 @@
String printLogicalPlanParam = request.getParameter("print-logical-plan");
String printOptimizedLogicalPlanParam = request.getParameter("print-optimized-logical-plan");
String printJob = request.getParameter("print-job");
+ String strIP = request.getParameter("hyracks-ip");
String strPort = request.getParameter("hyracks-port");
String strDisplayResult = request.getParameter("display-result");
int port = Integer.parseInt(strPort);
@@ -53,7 +54,7 @@
synchronized (context) {
hcc = (IHyracksClientConnection) context.getAttribute(HYRACKS_CONNECTION_ATTR);
if (hcc == null) {
- hcc = new HyracksConnection("localhost", port);
+ hcc = new HyracksConnection(strIP, port);
context.setAttribute(HYRACKS_CONNECTION_ATTR, hcc);
}
}
@@ -109,7 +110,7 @@
} catch (Exception e) {
out.println(e.getMessage());
- }
+ }
}
@Override
@@ -118,6 +119,7 @@
response.setContentType("text/html");
final String form = "<form method=\"post\">"
+ "<center><textarea cols=\"80\" rows=\"25\" name=\"query\" ></textarea><br/>"
+ + "IP Address: <input type = \"text\" name = \"hyracks-ip\" size=\"15\" maxlength=\"35\" value=\"locahost\" /><br/>"
+ "Port: <input type = \"text\" name = \"hyracks-port\" size=\"5\" maxlength=\"5\" value=\"1098\" /><br/>"
+ "<input type = \"checkbox\" name = \"print-expr-tree\" value=\"true\" />print parsed expressions<P>"
+ "<input type = \"checkbox\" name = \"print-rewritten-expr-tree\" value=\"true\" />print rewritten expressions<P>"