I am looking at this at the moment. Cheers, Abdullah.
Amoudi, Abdullah. On Wed, Nov 18, 2015 at 12:00 PM, Yingyi Bu <[email protected]> wrote: > Yes, I have seen it for a while (my change was not to fix the "connection > refused" issue but the build hanging one): > > java.net.ConnectException: Connection refused > > at java.net.PlainSocketImpl.socketConnect(Native Method) > > at > > java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:345) > > 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) > > I will open an issue for that. > > Best, > > Yingyi > > On Wed, Nov 18, 2015 at 11:56 AM, Heri Ramampiaro <[email protected]> > wrote: > > > I started getting an "Connection refused” exception after updating my > > local master with the > > latest one (which seems to include Yingyi's patch as well). Any solution > > to this? > > > > Thanks, > > -heri > > > > > > > > > On Nov 13, 2015, at 6:00 PM, Ian Maxon <[email protected]> wrote: > > > > > > Yingyi's patch worked for me. I was having my changes die in the > > > recovery tests before, but after that it seemed to work just fine. > > > > > > On Fri, Nov 13, 2015 at 8:42 AM, Till Westmann <[email protected]> > wrote: > > >> I’ve filed an issue [1] for this. > > >> I also found that we have 2 classes called FeedMessageService and I > > think > > >> that 1 can be removed [2]. > > >> > > >> Cheers, > > >> Till > > >> > > >> [1] https://issues.apache.org/jira/browse/ASTERIXDB-1175 > > >> [2] https://issues.apache.org/jira/browse/ASTERIXDB-1176 > > >> > > >> > > >> On 13 Nov 2015, at 3:17, abdullah alamoudi wrote: > > >> > > >>> I am also getting this exception. Although, I am not seeing any > > problems > > >>> caused by it. Still, we need to check it. > > >>> > > >>> Amoudi, Abdullah. > > >>> > > >>> On Fri, Nov 13, 2015 at 6:23 AM, Murtadha Hubail < > [email protected]> > > >>> wrote: > > >>> > > >>>> 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 > > >>>> } > > >>>> ); > > >>>> > > >>>> > > >> > > > > >
