fix NPE in MergeProcessor for new 'blocked' relationship
@@ -241,8 +241,10 @@ public abstract class AbstractMergeTable extends AbstractNiFiProcessor {
* This should be called when processing is done for the flow file.
*/
private void release(String blockingValue) {
+ if(StringUtils.isNotBlank(blockingValue)) {
blockingCache.remove(blockingValue);
}
+ }
@Override
