Hi Helix Folks,

I'm having this sporadic issue in some tasks of our workflows when we try
to store a value in the workflow context and I have added both code section
and error message below. Do you have an idea what's causing this? Please
let me know if you need further information. We are using Helix 0.8.2

public void sendNextJob(String jobId) {
    putUserContent(WORKFLOW_STARTED, "TRUE", Scope.WORKFLOW);
    if (jobId != null) {
        putUserContent(NEXT_JOB, jobId, Scope.WORKFLOW);
    }
}

Failed to setup environment of task
TASK_55096de4-2cb6-4b09-84fd-7fdddba93435
java.lang.NullPointerException: null
        at org.apache.helix.task.TaskUtil$1.update(TaskUtil.java:358)
        at org.apache.helix.task.TaskUtil$1.update(TaskUtil.java:356)
        at
org.apache.helix.manager.zk.HelixGroupCommit.commit(HelixGroupCommit.java:126)
        at
org.apache.helix.manager.zk.ZkCacheBaseDataAccessor.update(ZkCacheBaseDataAccessor.java:306)
        at
org.apache.helix.store.zk.AutoFallbackPropertyStore.update(AutoFallbackPropertyStore.java:61)
        at
org.apache.helix.task.TaskUtil.addWorkflowJobUserContent(TaskUtil.java:356)
        at
org.apache.helix.task.UserContentStore.putUserContent(UserContentStore.java:78)
        at
org.apache.airavata.helix.core.AbstractTask.sendNextJob(AbstractTask.java:136)
        at org.apache.airavata.helix.core.OutPort.invoke(OutPort.java:42)
        at
org.apache.airavata.helix.core.AbstractTask.onSuccess(AbstractTask.java:123)
        at
org.apache.airavata.helix.impl.task.AiravataTask.onSuccess(AiravataTask.java:97)
        at
org.apache.airavata.helix.impl.task.env.EnvSetupTask.onRun(EnvSetupTask.java:52)
        at
org.apache.airavata.helix.impl.task.AiravataTask.onRun(AiravataTask.java:349)
        at
org.apache.airavata.helix.core.AbstractTask.run(AbstractTask.java:92)
        at org.apache.helix.task.TaskRunner.run(TaskRunner.java:71)
        at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
        at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
        at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:748)

Thanks
Dimuthu

Reply via email to