commit | 3ac1e1c4338379e73b260a424b8eb53d737a12ff | [log] [tgz] |
---|---|---|
author | madhusudancs@gmail.com <madhusudancs@gmail.com@123451ca-8445-de46-9d55-352943316053> | Fri Mar 08 07:02:34 2013 +0000 |
committer | madhusudancs@gmail.com <madhusudancs@gmail.com@123451ca-8445-de46-9d55-352943316053> | Fri Mar 08 07:02:34 2013 +0000 |
tree | 4201fea357d5e7647865b15d707ba0ccec08ba8f | |
parent | 6ce767f2a66308f4a76ad23c0eb1af2c89b6a9fd [diff] |
Add the additional datasetIPAddress parameter required for the NCConfig in all the tests and implement the basic infrastructure required to run hyracks integration tests using ResultWriterOperatorDescriptor. git-svn-id: https://hyracks.googlecode.com/svn/branches/fullstack_hyracks_result_distribution@3061 123451ca-8445-de46-9d55-352943316053
diff --git a/src/test/java/edu/uci/ics/hivesterix/perf/base/AbstractPerfTestSuiteClass.java b/src/test/java/edu/uci/ics/hivesterix/perf/base/AbstractPerfTestSuiteClass.java index 8d50f47..3d66f59 100644 --- a/src/test/java/edu/uci/ics/hivesterix/perf/base/AbstractPerfTestSuiteClass.java +++ b/src/test/java/edu/uci/ics/hivesterix/perf/base/AbstractPerfTestSuiteClass.java
@@ -115,6 +115,7 @@ ncConfig.clusterNetIPAddress = ipAddress; ncConfig.ccPort = clientPort; ncConfig.dataIPAddress = "127.0.0.1"; + ncConfig.datasetIPAddress = "127.0.0.1"; ncConfig.nodeId = "nc" + i; NodeControllerService nc = new NodeControllerService(ncConfig); nc.start();
diff --git a/src/test/java/edu/uci/ics/hivesterix/test/base/AbstractTestSuiteClass.java b/src/test/java/edu/uci/ics/hivesterix/test/base/AbstractTestSuiteClass.java index ca2731b..64ad495 100644 --- a/src/test/java/edu/uci/ics/hivesterix/test/base/AbstractTestSuiteClass.java +++ b/src/test/java/edu/uci/ics/hivesterix/test/base/AbstractTestSuiteClass.java
@@ -118,6 +118,7 @@ ncConfig.clusterNetIPAddress = ipAddress; ncConfig.ccPort = netPort; ncConfig.dataIPAddress = "127.0.0.1"; + ncConfig.datasetIPAddress = "127.0.0.1"; ncConfig.nodeId = "nc" + i; NodeControllerService nc = new NodeControllerService(ncConfig); nc.start();