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)
