You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@nifi.apache.org by ex...@apache.org on 2022/03/25 17:46:20 UTC

[nifi] branch main updated (2ac90a6 -> 63f02c9)

This is an automated email from the ASF dual-hosted git repository.

exceptionfactory pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git.


    from 2ac90a6  NIFI-7262 Added debug logging for the generated query in PutCassandraRecord. (#5898)
     add 63f02c9  NIFI-9835: Fixed threading bug in which NioAsyncLoadBalanceClient calls LoadBalanceSession.isComplete() followed by LoadBalanceSession.isCanceled() but it's possible for the complete flag to change before the canceled flag (they are not updated atomically). So changed to use a single LoadBalanceSessionState enum that represents the state. Also made the private StandardProcessSession.commit(boolean) method synchronized. When a processor is terminated (as is the case in Of [...]

No new revisions were added by this update.

Summary of changes:
 .../repository/StandardProcessSession.java         |  2 +-
 .../client/async/nio/LoadBalanceSession.java       | 72 ++++++++++------------
 .../async/nio/NioAsyncLoadBalanceClient.java       |  9 +--
 .../client/async/nio/TestLoadBalanceSession.java   |  2 +-
 .../nifi/processors/standard/MergeRecord.java      |  2 +-
 5 files changed, 42 insertions(+), 45 deletions(-)