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