Re: [gt-user] problem in listening ws-gram job

[Martin Feller]

Hi,

What GT version are you using?

Martin

Ufuk Utku Turuncoglu wrote:

Hi,

I try to listen job state but i get following error,

[run] Container failed to initialize. Caused by org.apache.axis.ConfigurationException: Configuration file directory './etc' does not exist or is not a directory or is not readable. [run] org.apache.axis.ConfigurationException: Configuration file directory './etc' does not exist or is not a directory or is not readable. [run] at org.apache.axis.configuration.DirProvider.<init>(DirProvider.java:73) [run] at org.globus.wsrf.container.ServiceDispatcher.<init>(ServiceDispatcher.java:85)

i also add globus location into VM arguments. In this case the previous error message disappear but new one occurs,

java.lang.ClassCastException: org.apache.naming.ResourceRef

at org.globus.wsrf.NotificationConsumerManager.initializeConsumerHome(NotificationConsumerManager.java:95) at org.globus.wsrf.impl.notification.ClientNotificationConsumerManager.startListening(ClientNotificationConsumerManager.java:66)

   at org.earth.actors.grid.MyGramJob.submit(MyGramJob.java:329)
   at org.earth.actors.grid.GRAMExecuteCmd.fire(GRAMExecuteCmd.java:172)
   at ptolemy.actor.AtomicActor.iterate(AtomicActor.java:434)

at ptolemy.actor.sched.StaticSchedulingDirector.fire(StaticSchedulingDirector.java:188)

   at ptolemy.actor.CompositeActor.fire(CompositeActor.java:417)
   at ptolemy.actor.Manager.iterate(Manager.java:725)
   at ptolemy.actor.Manager.execute(Manager.java:349)
   at ptolemy.actor.Manager.run(Manager.java:1147)
   at ptolemy.actor.Manager$3.run(Manager.java:1188)

the following code (without notifConsumerManager.startListening() part) send job to remote machine without error. I just only copy the part of the code that causes error.

   CreateManagedJobInputType jobInput = new CreateManagedJobInputType();
             try {

jobInput.setJobID(new AttributedURI("uuid:" + UUIDGenFactory.getUUIDGen()));

       } catch (MalformedURIException e) {
           // TODO Auto-generated catch block
           e.printStackTrace();
       }
             int TERM_TIME = 20;
       Calendar termTime = Calendar.getInstance();
       termTime.add(Calendar.MINUTE, TERM_TIME);

System.out.println("Termination time to set: "+TERM_TIME+" minutes");

             jobInput.setInitialTerminationTime(termTime);
         JobDescriptionType jobDescription = this.jobDescription;
       if (multiJob) {
           jobInput.setMultiJob((MultiJobDescriptionType) jobDescription);
       } else {
           jobInput.setJob(jobDescription);
       }

NotificationConsumerManager notifConsumerManager = NotificationConsumerManager.getInstance();

       try {
           notifConsumerManager.startListening();
       } catch (ContainerException e1) {
           // TODO Auto-generated catch block
           e1.printStackTrace();
       }
            System.out.println(">>"+this.factoryPort.toString()+"<<");

       CreateManagedJobOutputType createResponse = null;
       try {

createResponse = this.factoryPort.createManagedJob(jobInput);

       } catch (BaseFaultType e) {
           // TODO Auto-generated catch block
           e.printStackTrace();
       } catch (RemoteException e) {
           // TODO Auto-generated catch block
           e.printStackTrace();
       }
       this.jobEndpoint = createResponse.getManagedJobEndpoint();
             try {
           this.jobPort = ManagedJobClientHelper.getPort(jobEndpoint);
           setStubSecurityProperties((Stub)jobPort);
       } catch (Exception e) {
           // TODO Auto-generated catch block
           e.printStackTrace();
       }

any suggestion will be helpful.

best regards,

--ufuk