[
https://issues.apache.org/jira/browse/NIFI-6800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16962068#comment-16962068
]
Mark Payne commented on NIFI-6800:
----------------------------------
Thanks [~ivan1221] that's a great catch! I verified the behavior with the fix
and merged to master.
> StandardProcessSession error - hashmap counter overwritten in
> highThroughputSession
> -----------------------------------------------------------------------------------
>
> Key: NIFI-6800
> URL: https://issues.apache.org/jira/browse/NIFI-6800
> Project: Apache NiFi
> Issue Type: Bug
> Components: Core Framework
> Affects Versions: 1.9.2
> Reporter: Iván Ezequiel Rodriguez
> Assignee: Iván Ezequiel Rodriguez
> Priority: Major
> Labels: bug, core, counters, fix, framework, high, nifi, session
> Time Spent: 1h 20m
> Remaining Estimate: 0h
>
> The error is present until version 1.9.2 and earlier in the class
> StandardProcessSession.java
> The error is on line 3383 in the following code block:
> if (session.countersOnCommit != null)
> { this.countersOnCommit.putAll(session.countersOnCommit); }
> The putALL method is called and the values are not being mixed when it
> comes to existing keys
> As we know hashmap does not allow duplicate keys. So when we merge the maps
> in this way, for duplicate keys in map1 the value is overwitten by value for
> same key in map2.
> This replacement causes the counters to be overwritten when
> highThroughputSession is activated.This situation only happens if the flag
> "immediately" is false in the call at method adjustCounter, since in this way
> the counters are adjusted in the commit and stored in each checkpoint.
> I leave a video showing the error and the request for changes in git with
> the solution in the code that I propose:
> [Nifi Bug StandardProcessSession error - hashmap counter overwritten in
> highThroughputSession|https://youtu.be/DzwEQWmxNKc]
> This video shows a comparison between version 1.9.2 and the version that I
> compiled with the fix myself:
> [NIFI-6800 - FIX -hashmap counter overwritten in
> highThroughputSession|https://youtu.be/zlAQ69WX0tw]
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
