You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@tajo.apache.org by "Jinho Kim (JIRA)" <ji...@apache.org> on 2014/03/14 03:32:43 UTC

[jira] [Updated] (TAJO-686) Integration test aborted

     [ https://issues.apache.org/jira/browse/TAJO-686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jinho Kim updated TAJO-686:
---------------------------

    Attachment: TAJO-686.patch

I've attached the patch. please review this.

> Integration test aborted
> ------------------------
>
>                 Key: TAJO-686
>                 URL: https://issues.apache.org/jira/browse/TAJO-686
>             Project: Tajo
>          Issue Type: Test
>          Components: build
>    Affects Versions: 0.8-incubating, 1.0-incubating
>            Reporter: Jinho Kim
>            Assignee: Jinho Kim
>            Priority: Minor
>         Attachments: TAJO-686.patch
>
>
> This issue is caused by calling thread.notify before thread.wait
> {code}
> final Object monitor = new Object();
>         RpcCallback<WorkerResourceAllocationResponse> callBack = new RpcCallback<WorkerResourceAllocationResponse>() {
>           @Override
>           public void run(WorkerResourceAllocationResponse response) {
>             TestTajoResourceManager.this.response = response;
>             synchronized(monitor) {
>               monitor.notifyAll();
>             }
>           }
>         };
>         tajoWorkerResourceManager.allocateWorkerResources(request, callBack);
>         Thread.sleep(1000); //  this is reproduced a bug
>         synchronized(monitor) {
>           monitor.wait();
>         }
> {code}
> {noformat}
> 2014-03-14 10:44:48,610 INFO  rm.TajoWorkerResourceManager (TajoWorkerResourceManager.java:run(278)) - WorkerResourceAllocationThread start
> 2014-03-14 10:44:48,666 INFO  rpc.RpcChannelFactory (RpcChannelFactory.java:createServerChannelFactory(81)) - Create TajoResourceTrackerProtocol-1 ServerSocketChannelFactory. Worker:3
> 2014-03-14 10:44:48,749 INFO  rpc.NettyServerBase (NettyServerBase.java:start(105)) - Rpc (TajoResourceTrackerProtocol) listens on /127.0.0.1:15246
> 2014-03-14 10:44:48,751 INFO  rm.TajoResourceTracker (TajoResourceTracker.java:serviceInit(97)) - TajoResourceTracker starts up (localhost/127.0.0.1:15246)
> 2014-03-14 10:44:48,780 INFO  rm.Worker (Worker.java:transition(222)) - Worker with slots=m:5120,d:5.0,c:1, used=m:0,d:0.0,c:0 is joined to Tajo cluster
> 2014-03-14 10:44:48,780 INFO  rm.Worker (Worker.java:handle(288)) - host1:21000:12345 Node Transitioned from NEW to RUNNING
> 2014-03-14 10:44:48,781 INFO  rm.Worker (Worker.java:transition(222)) - Worker with slots=m:5120,d:5.0,c:1, used=m:0,d:0.0,c:0 is joined to Tajo cluster
> 2014-03-14 10:44:48,781 INFO  rm.Worker (Worker.java:handle(288)) - host2:21000:12345 Node Transitioned from NEW to RUNNING
> 2014-03-14 10:44:48,782 INFO  rm.Worker (Worker.java:transition(222)) - Worker with slots=m:5120,d:5.0,c:1, used=m:0,d:0.0,c:0 is joined to Tajo cluster
> 2014-03-14 10:44:48,782 INFO  rm.Worker (Worker.java:handle(288)) - host3:21000:12345 Node Transitioned from NEW to RUNNING
> 2014-03-14 10:44:48,783 INFO  rm.Worker (Worker.java:transition(222)) - Worker with slots=m:5120,d:5.0,c:1, used=m:0,d:0.0,c:0 is joined to Tajo cluster
> 2014-03-14 10:44:48,783 INFO  rm.Worker (Worker.java:handle(288)) - host4:21000:12345 Node Transitioned from NEW to RUNNING
> 2014-03-14 10:44:48,784 INFO  rm.Worker (Worker.java:transition(222)) - Worker with slots=m:5120,d:5.0,c:1, used=m:0,d:0.0,c:0 is joined to Tajo cluster
> 2014-03-14 10:44:48,784 INFO  rm.Worker (Worker.java:handle(288)) - host5:21000:12345 Node Transitioned from NEW to RUNNING
> 2014-03-14 10:47:28,752 INFO  rm.Worker (Worker.java:transition(257)) - Deactivating Node host1:21000:12345 as it is now LOST
> 2014-03-14 10:47:28,752 INFO  rm.Worker (Worker.java:handle(288)) - host1:21000:12345 Node Transitioned from RUNNING to LOST
> 2014-03-14 10:47:28,755 INFO  rm.Worker (Worker.java:transition(257)) - Deactivating Node host5:21000:12345 as it is now LOST
> 2014-03-14 10:47:28,755 INFO  rm.Worker (Worker.java:handle(288)) - host5:21000:12345 Node Transitioned from RUNNING to LOST
> 2014-03-14 10:47:28,756 INFO  rm.Worker (Worker.java:transition(257)) - Deactivating Node host4:21000:12345 as it is now LOST
> 2014-03-14 10:47:28,756 INFO  rm.Worker (Worker.java:handle(288)) - host4:21000:12345 Node Transitioned from RUNNING to LOST
> 2014-03-14 10:47:28,756 INFO  rm.Worker (Worker.java:transition(257)) - Deactivating Node host3:21000:12345 as it is now LOST
> 2014-03-14 10:47:28,757 INFO  rm.Worker (Worker.java:handle(288)) - host3:21000:12345 Node Transitioned from RUNNING to LOST
> 2014-03-14 10:47:28,757 INFO  rm.Worker (Worker.java:transition(257)) - Deactivating Node host2:21000:12345 as it is now LOST
> 2014-03-14 10:47:28,758 INFO  rm.Worker (Worker.java:handle(288)) - host2:21000:12345 Node Transitioned from RUNNING to LOST
> {noformat}



--
This message was sent by Atlassian JIRA
(v6.2#6252)