[jira] [Updated] (GOBBLIN-963) Inconsistent TaskContext/TaskState created for TaskIFaceWrapper in GobblinMultiTaskAttempt

["Chen Guo (Jira)" <ji...@apache.org>]

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

Chen Guo updated GOBBLIN-963:
-----------------------------
    Issue Type: Bug  (was: New Feature)

> Inconsistent TaskContext/TaskState created for TaskIFaceWrapper in GobblinMultiTaskAttempt
> ------------------------------------------------------------------------------------------
>
>                 Key: GOBBLIN-963
>                 URL: https://issues.apache.org/jira/browse/GOBBLIN-963
>             Project: Apache Gobblin
>          Issue Type: Bug
>            Reporter: Chen Guo
>            Priority: Major
>
> Currently in GobblinMultiTaskAttempt, when we call createTaskRunnable, we rely on a TaskFactory to create a task and return a wrapper for that task. However, when we create the wrapper, we initialized the TaskContext twice. 
>  # For the task creation
>  # For the task wrapper creation
> These two TaskContexts, which generate two copies of TaskState, will cause inconsistency in the following operation. The task state update within the task won't be reflected in TaskWrapper.
>  
> Specifically, this is the buggy line of code
> {code:java}
> return new TaskIFaceWrapper(taskFactoryOpt.get().createTask(new TaskContext(workUnitState)),
>  new TaskContext(workUnitState), countDownLatch, this.taskStateTracker);
> {code}
> Ideally, we should create the TaskContext once, and reuse the same TaskContext.
>  
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)