asterixdb-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Murtadha Hubail <hubail...@gmail.com>
Subject Asterix Test Failures
Date Fri, 13 Nov 2015 03:23:37 GMT
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
  }
);


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message