[
https://issues.apache.org/jira/browse/MINIFICPP-2501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Marton Szasz updated MINIFICPP-2501:
------------------------------------
Fix Version/s: 0.99.1
> Add processorStatuses C2 metric node to FlowInformation
> -------------------------------------------------------
>
> Key: MINIFICPP-2501
> URL: https://issues.apache.org/jira/browse/MINIFICPP-2501
> Project: Apache NiFi MiNiFi C++
> Issue Type: New Feature
> Reporter: Gábor Gyimesi
> Assignee: Gábor Gyimesi
> Priority: Major
> Fix For: 0.99.1
>
> Time Spent: 4h
> Remaining Estimate: 0h
>
> NiFi provides processor status information that is published in the C2
> protocol heartbeats in MiNiFi Java:
> https://github.com/apache/nifi/blob/main/c2/c2-protocol/c2-protocol-api/src/main/java/org/apache/nifi/c2/protocol/api/FlowInfo.java#L32
> We should provide the same metrics in C2 (and in other metric publishers) in
> the FlowInformation metric node. To do this the FlowInformation metric node
> should be extended and the serialization appended with the processorStatuses
> JSON node in the following format:
> {code:java}
> "processorStatuses": [
> {
> "id": "5128e3c8-015a-1000-79ca-83af40ec1990",
> "groupId": "2438e3c8-015a-1000-79ca-83af40ec1990",
> "bytesRead": 0,
> "bytesWritten": 0,
> "flowFilesIn": 0,
> "flowFilesOut": 0,
> "bytesIn": 0,
> "bytesOut": 0,
> "invocations": 0,
> "processingNanos": 0,
> "activeThreadCount": -1,
> "terminatedThreadCount": -1
> },
> {
> "id": "4fe2d51d-076a-49b0-88de-5cf5adf52b8f",
> "groupId": "2438e3c8-015a-1000-79ca-83af40ec1990",
> "bytesRead": 0,
> "bytesWritten": 40,
> "flowFilesIn": 0,
> "flowFilesOut": 4,
> "bytesIn": 0,
> "bytesOut": 40,
> "invocations": 4,
> "processingNanos": 1434605,
> "activeThreadCount": -1,
> "terminatedThreadCount": -1
> }
> ], {code}
> We should also extend the general processor metrics with these new
> information.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
