asterixdb-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Yingyi Bu <buyin...@gmail.com>
Subject Re: Asterix Test Failures
Date Fri, 13 Nov 2015 04:01:11 GMT
OK, I'll reproduce that.
Thanks!

Best,
Yingyi

On Thu, Nov 12, 2015 at 7:23 PM, Murtadha Hubail <hubailmor@gmail.com>
wrote:

> Hi Yingyi,
>
> I think this merge (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