manifoldcf-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kwri...@apache.org
Subject svn commit: r1605630 - /manifoldcf/trunk/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/PipelineManager.java
Date Wed, 25 Jun 2014 22:49:47 GMT
Author: kwright
Date: Wed Jun 25 22:49:46 2014
New Revision: 1605630

URL: http://svn.apache.org/r1605630
Log:
Fix job save

Modified:
    manifoldcf/trunk/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/PipelineManager.java

Modified: manifoldcf/trunk/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/PipelineManager.java
URL: http://svn.apache.org/viewvc/manifoldcf/trunk/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/PipelineManager.java?rev=1605630&r1=1605629&r2=1605630&view=diff
==============================================================================
--- manifoldcf/trunk/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/PipelineManager.java
(original)
+++ manifoldcf/trunk/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/PipelineManager.java
Wed Jun 25 22:49:46 2014
@@ -263,15 +263,18 @@ public class PipelineManager extends org
     {
       IResultRow row = set.getRow(i);
       String outputConnectionName = (String)row.getValue(outputNameField);
-      if (!outputSet.contains(outputConnectionName))
-        throw new ManifoldCFException("Output name '"+outputConnectionName+"' removed from
job; not allowed");
+      boolean isOutputConnection = outputConnectionName != null && outputConnectionName.length()
> 0;
+      if (isOutputConnection)
+      {
+        if (!outputSet.contains(outputConnectionName))
+          throw new ManifoldCFException("Output name '"+outputConnectionName+"' removed from
job; not allowed");
+      }
       String transformationConnectionName = (String)row.getValue(transformationNameField);
       Long prerequisite = (Long)row.getValue(prerequisiteField);
       String spec = (String)row.getValue(connectionSpecField);
       if (spec == null)
         spec = "";
       int prerequisiteValue = (prerequisite==null)?-1:(int)prerequisite.longValue();
-      boolean isOutputConnection = outputConnectionName != null && outputConnectionName.length()
> 0;
       if (job.getPipelineStagePrerequisite(i) != prerequisiteValue)
         return false;
       if (job.getPipelineStageIsOutputConnection(i) != isOutputConnection)



Mime
View raw message