[
https://issues.apache.org/jira/browse/NIFI-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15723491#comment-15723491
]
ASF GitHub Bot commented on NIFI-3133:
--------------------------------------
Github user mcgilman commented on a diff in the pull request:
https://github.com/apache/nifi/pull/1297#discussion_r90964719
--- Diff:
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java
---
@@ -4034,19 +4034,29 @@ public Authorizable createDataAuthorizable(final
String componentId) {
authorizable = new
DataAuthorizable(connection.getSource());
}
} else {
- // authorizable for remote group ports should be the
remote process group
- if (connectable instanceof RemoteGroupPort) {
- authorizable = new DataAuthorizable(((RemoteGroupPort)
connectable).getRemoteProcessGroup());
- } else {
- authorizable = new DataAuthorizable(connectable);
- }
+ authorizable = new DataAuthorizable(connectable);
}
}
return authorizable;
}
@Override
+ public Authorizable createRemoteDataAuthorizable(String
remoteGroupPortId) {
+ final DataAuthorizable authorizable;
+
+ final RemoteGroupPort remoteGroupPort =
getRootGroup().findRemoteGroupPort(remoteGroupPortId);
+ if (remoteGroupPort == null) {
+ throw new ResourceNotFoundException("The component that
generated this event is no longer part of the data flow.");
--- End diff --
With the refactoring it is just events. However, there is still one spot
that is unused that can now be removed. I'll update.
> Unable to empty queue connected to a RPG
> ----------------------------------------
>
> Key: NIFI-3133
> URL: https://issues.apache.org/jira/browse/NIFI-3133
> Project: Apache NiFi
> Issue Type: Bug
> Components: Core Framework
> Reporter: Matt Gilman
> Assignee: Matt Gilman
> Priority: Critical
> Fix For: 1.2.0
>
>
> Unable to empty a queue in a connection where the source or destination is a
> Remote Process Group. Appears to be using the policy of the port instead of
> the RPG which is used for other configuration.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
