Asterix Test Failures

[Murtadha Hubail]

Hi Yingyi,

I think this merge (https://asterix-gerrit.ics.uci.edu/#/c/487/ 
<https://asterix-gerrit.ics.uci.edu/#/c/487/>) caused Asterix recovery test 
cases to get stuck when duplicate key exception happens.

Could you please have a look at it? You can reproduce it with the statements 
below.

@Others,
I’m also getting the below exception on the current master every time I start 
AsterixHyracksIntegrationUtil or during tests. Is anyone experiencing the same?

java.net.ConnectException: Connection refused
        at java.net.PlainSocketImpl.socketConnect(Native Method)
        at 
java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
        at 
java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
        at 
java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
        at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
        at java.net.Socket.connect(Socket.java:589)
        at java.net.Socket.connect(Socket.java:538)
        at java.net.Socket.<init>(Socket.java:434)
        at java.net.Socket.<init>(Socket.java:211)
        at 
org.apache.asterix.common.feeds.FeedMessageService$FeedMessageHandler.run(FeedMessageService.java:101)
        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at java.lang.Thread.run(Thread.java:745)

-Murtadha

drop dataverse recovery if exists;
create dataverse recovery;
use dataverse recovery;

/* For raw Fragile data */
create type FragileTypeRaw as closed {
  row_id: int32,
  sid: int32,
  date: string,
  day: int32,
  time: string,
  bpm: int32,
  RR: float
};

/* For cleaned Fragile data */
create type FragileType as closed {
  row_id: int32,
  sid: int32,
  date: date,
  day: int32,
  time: time,
  bpm: int32,
  RR: float
};

/* Create dataset for loading raw Fragile data */
create dataset Fragile_raw (FragileTypeRaw)
primary key row_id;

/* Create dataset for cleaned Fragile data */
create dataset Fragile (FragileType)
primary key row_id;

use dataverse recovery;

load dataset Fragile_raw using 
"org.apache.asterix.external.dataset.adapter.NCFileSystemAdapter"
(("path"="127.0.0.1://data/csv/fragile_01.csv"),("format"="delimited-text"),("delimiter"=","))
 pre-sorted;

use dataverse recovery;

/* Load Fragile data from raw dataset into cleaned dataset */
insert into dataset Fragile (
  for $t in dataset Fragile_raw
  return {
    "row_id": $t.row_id % 28000,
    "sid": $t.sid,
    "date": date($t.date),
    "day": $t.day,
    "time": parse-time($t.time, "h:m:s"),
    "bpm": $t.bpm,
    "RR": $t.RR
  }
);