Expression Injection not working on some processors
@@ -115,7 +115,7 @@ public class PropertyExpressionResolver {
public List<NifiProperty> resolvePropertyExpressions(List<NifiProperty> properties, @Nullable final FeedMetadata metadata, List<NifiProperty> skip) {
if (metadata != null && properties != null) {
return properties.stream()
- .filter(p -> skip == null || (skip != null && !skip.stream().anyMatch(s -> s.getKey().equalsIgnoreCase(p.getKey()))))
+ .filter(p -> skip == null || (skip != null && !skip.stream().anyMatch(s -> s.getProcessorName().equalsIgnoreCase(p.getProcessorName()) && s.getProcessorType().equalsIgnoreCase(p.getProcessorType()) && s.getKey().equalsIgnoreCase(p.getKey()))))
.filter(property -> resolveExpression(metadata, property))
.collect(Collectors.toList());
} else {
@@ -124,7 +124,6 @@ public class PropertyExpressionResolver {
}
-
public Map<String, Object> getStaticConfigProperties() {
Map<String, Object> props = environmentProperties.getPropertiesStartingWith(configPropertyPrefix);
if(props == null){
