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(-)
