[
https://issues.apache.org/jira/browse/NIFI-6800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Iván Ezequiel Rodriguez updated NIFI-6800:
------------------------------------------
External issue URL: https://github.com/apache/nifi/pull/3837 (was:
https://youtu.be/DzwEQWmxNKc)
> 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: 0.5h
> Remaining Estimate: 0h
>
> 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 message was sent by Atlassian Jira
(v8.3.4#803005)
