added managix commands for starting/stopping a node
diff --git a/asterix-installer/src/test/resources/integrationts/fault-tolerance/queries/feeds/IN2-1/in2-1.1.ddl.aql b/asterix-installer/src/test/resources/integrationts/fault-tolerance/queries/feeds/IN2-1/in2-1.1.ddl.aql
new file mode 100644
index 0000000..b204892
--- /dev/null
+++ b/asterix-installer/src/test/resources/integrationts/fault-tolerance/queries/feeds/IN2-1/in2-1.1.ddl.aql
@@ -0,0 +1,29 @@
+drop dataverse feeds if exists;
+create dataverse feeds;
+use dataverse feeds;
+
+create type TwitterUserType as closed {
+ screen-name: string,
+ lang: string,
+ friends_count: int32,
+ statuses_count: int32,
+ name: string,
+ followers_count: int32
+}
+
+create type TweetMessageType as closed {
+ tweetid: string,
+ user: TwitterUserType,
+ sender-location: point,
+ send-time: datetime,
+ referred-topics: {{ string }},
+ message-text: string
+}
+
+create nodegroup feedGroup on asterix_node1;
+
+create feed dataset TwitterFirehoseFeed(TweetMessageType)
+using twitter_firehose
+(("duration"="30"),("tps"="50"),("dataverse-dataset"="feeds:TwitterFirehoseFeed"))
+primary key tweetid on feedGroup;
+
diff --git a/asterix-installer/src/test/resources/integrationts/fault-tolerance/queries/feeds/IN2-1/in2-1.2.update.aql b/asterix-installer/src/test/resources/integrationts/fault-tolerance/queries/feeds/IN2-1/in2-1.2.update.aql
new file mode 100644
index 0000000..382425f
--- /dev/null
+++ b/asterix-installer/src/test/resources/integrationts/fault-tolerance/queries/feeds/IN2-1/in2-1.2.update.aql
@@ -0,0 +1,4 @@
+use dataverse feeds;
+
+begin feed TwitterFirehoseFeed;
+
diff --git a/asterix-installer/src/test/resources/integrationts/fault-tolerance/queries/feeds/IN2-1/in2-1.3.mgx.aql b/asterix-installer/src/test/resources/integrationts/fault-tolerance/queries/feeds/IN2-1/in2-1.3.mgx.aql
new file mode 100644
index 0000000..2724be9
--- /dev/null
+++ b/asterix-installer/src/test/resources/integrationts/fault-tolerance/queries/feeds/IN2-1/in2-1.3.mgx.aql
@@ -0,0 +1 @@
+stopnode -n asterix -nodes node1
diff --git a/asterix-installer/src/test/resources/integrationts/fault-tolerance/queries/feeds/IN2-1/in2-1.4.query.aql b/asterix-installer/src/test/resources/integrationts/fault-tolerance/queries/feeds/IN2-1/in2-1.4.query.aql
new file mode 100644
index 0000000..474835a
--- /dev/null
+++ b/asterix-installer/src/test/resources/integrationts/fault-tolerance/queries/feeds/IN2-1/in2-1.4.query.aql
@@ -0,0 +1,4 @@
+use dataverse feeds;
+
+for $x in dataset Metadata.FeedActivity
+return $x
diff --git a/asterix-installer/src/test/resources/integrationts/fault-tolerance/queries/feeds/IN2-1/in2-1.5.query.aql b/asterix-installer/src/test/resources/integrationts/fault-tolerance/queries/feeds/IN2-1/in2-1.5.query.aql
new file mode 100644
index 0000000..b173136
--- /dev/null
+++ b/asterix-installer/src/test/resources/integrationts/fault-tolerance/queries/feeds/IN2-1/in2-1.5.query.aql
@@ -0,0 +1,14 @@
+use dataverse feeds;
+
+let $c:=count(
+for $x in dataset TwitterFirehoseFeed
+return $x
+)
+
+let $result :=
+if ($c > 20000)
+then
+ true
+else
+ false
+return $result
diff --git a/asterix-installer/src/test/resources/integrationts/fault-tolerance/testsuite.xml b/asterix-installer/src/test/resources/integrationts/fault-tolerance/testsuite.xml
new file mode 100644
index 0000000..859f29a
--- /dev/null
+++ b/asterix-installer/src/test/resources/integrationts/fault-tolerance/testsuite.xml
@@ -0,0 +1,10 @@
+<test-suite xmlns="urn:xml.testframework.asterix.ics.uci.edu" ResultOffsetPath="results" QueryOffsetPath="queries" QueryFileExtension=".aql">
+ <test-group name="fault-tolerance">
+ <test-case FilePath="feeds">
+ <compilation-unit name="IN2-1">
+ <output-dir compare="Text">IN2-1</output-dir>
+ </compilation-unit>
+ </test-case>
+ </test-group>
+</test-suite>
+