You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sh...@apache.org on 2015/11/11 22:52:06 UTC

airavata git commit: Fixed NPE from output data streaming logic

Repository: airavata
Updated Branches:
  refs/heads/develop 69ecb6801 -> 30d230c44


Fixed NPE from output data streaming logic


Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/30d230c4
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/30d230c4
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/30d230c4

Branch: refs/heads/develop
Commit: 30d230c44e11aa7f4c3649dc1e5bcb82695a9846
Parents: 69ecb68
Author: Shameera Rathnayaka <sh...@gmail.com>
Authored: Wed Nov 11 16:51:59 2015 -0500
Committer: Shameera Rathnayaka <sh...@gmail.com>
Committed: Wed Nov 11 16:51:59 2015 -0500

----------------------------------------------------------------------
 .../src/main/java/org/apache/airavata/gfac/impl/GFacEngineImpl.java | 1 -
 1 file changed, 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/airavata/blob/30d230c4/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/impl/GFacEngineImpl.java
----------------------------------------------------------------------
diff --git a/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/impl/GFacEngineImpl.java b/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/impl/GFacEngineImpl.java
index 9669d99..96d3302 100644
--- a/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/impl/GFacEngineImpl.java
+++ b/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/impl/GFacEngineImpl.java
@@ -274,7 +274,6 @@ public class GFacEngineImpl implements GFacEngine {
                                         streamingTaskModel.setCreationTime(AiravataUtils.getCurrentTimestamp().getTime());
                                         streamingTaskModel.setParentProcessId(processContext.getProcessId());
                                         TaskContext streamingTaskContext = getTaskContext(processContext);
-                                        streamingTaskContext.setTaskStatus(new TaskStatus(TaskState.CREATED));
                                         DataStagingTaskModel submodel = new DataStagingTaskModel();
                                         submodel.setType(DataStageType.OUPUT);
                                         submodel.setProcessOutput(output);