Commit debbc0ae by Madhan Neethiraj

ATLAS-3067: fix for IT failures caused by changes in hive-preprocessor

parent 9e2d3266
...@@ -205,13 +205,17 @@ public class HivePreprocessor { ...@@ -205,13 +205,17 @@ public class HivePreprocessor {
Object inputs = entity.getAttribute(ATTRIBUTE_INPUTS); Object inputs = entity.getAttribute(ATTRIBUTE_INPUTS);
Object outputs = entity.getAttribute(ATTRIBUTE_OUTPUTS); Object outputs = entity.getAttribute(ATTRIBUTE_OUTPUTS);
int inputsCount = (inputs instanceof Collection) ? ((Collection) inputs).size() : 0;
int outputsCount = (outputs instanceof Collection) ? ((Collection) outputs).size() : 0;
removeIgnoredObjectIds(inputs, context); removeIgnoredObjectIds(inputs, context);
removeIgnoredObjectIds(outputs, context); removeIgnoredObjectIds(outputs, context);
boolean isInputsEmpty = isEmpty(inputs); boolean isInputsEmpty = isEmpty(inputs);
boolean isOutputsEmpty = isEmpty(outputs); boolean isOutputsEmpty = isEmpty(outputs);
if (isInputsEmpty || isOutputsEmpty) { // if inputs/outputs became empty due to removal of ignored entities, ignore the process entity as well
if ((inputsCount > 0 && isInputsEmpty) || (outputsCount > 0 && isOutputsEmpty)) {
context.addToIgnoredEntities(entity); context.addToIgnoredEntities(entity);
// since the process entity is ignored, entities referenced by inputs/outputs of this process entity // since the process entity is ignored, entities referenced by inputs/outputs of this process entity
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment