diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/reporting/AbstractEventAccess.java b/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/reporting/AbstractEventAccess.java index 2345472f7646..1d0df564f07d 100644 --- a/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/reporting/AbstractEventAccess.java +++ b/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/reporting/AbstractEventAccess.java @@ -53,6 +53,7 @@ import org.apache.nifi.groups.RemoteProcessGroup; import org.apache.nifi.processor.Relationship; import org.apache.nifi.provenance.ProvenanceEventRecord; +import org.apache.nifi.registry.flow.RegisteredFlowSnapshotMetadata; import org.apache.nifi.registry.flow.VersionControlInformation; import org.apache.nifi.registry.flow.VersionedFlowState; import org.apache.nifi.registry.flow.VersionedFlowStatus; @@ -540,6 +541,12 @@ ProcessGroupStatus getGroupStatus(final ProcessGroup group, final RepositoryStat final VersionControlInformation vci = group.getVersionControlInformation(); if (vci != null) { + final RegisteredFlowSnapshotMetadata registeredFlowSnapshotMetadata = new RegisteredFlowSnapshotMetadata(); + registeredFlowSnapshotMetadata.setBranch(vci.getBranch()); + registeredFlowSnapshotMetadata.setBucketIdentifier(vci.getBucketIdentifier()); + registeredFlowSnapshotMetadata.setFlowIdentifier(vci.getFlowIdentifier()); + registeredFlowSnapshotMetadata.setVersion(vci.getVersion()); + status.setRegisteredFlowSnapshotMetadata(registeredFlowSnapshotMetadata); try { final VersionedFlowStatus flowStatus = vci.getStatus(); if (flowStatus != null && flowStatus.getState() != null) {