Re: Sporadic issue in putting a variable in workflow scope

[Xue Junkai]

User content store node will be created one the job has been scheduled. In
your case, I think the job is not scheduled. This method usually has been
utilized in running task.

Best,

Junkai

On Fri, Nov 9, 2018 at 8:19 AM DImuthu Upeksha <dimuthu.upeks...@gmail.com>
wrote:

> 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
>


-- 
Junkai Xue