Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NIFI-13862: Ensure that when FlowFile Repository is checkpointed, we always call the onGlobalSync() method to ensure that any transient claims that may have been provided (such as those from Stateless NiFi) get dealt with appropriately. 

This closes #9375

Signed-off-by: Joseph Witt <joewitt@apache.org>
This commit is contained in:
Mark Payne 2024-10-10 13:39:22 -04:00 committed by Joseph Witt
parent ade260266e
commit c97510aa66
No known key found for this signature in database
GPG Key ID: 9093BF854F811A1A
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
nifi-commons/nifi-write-ahead-log/src/main/java/org/apache/nifi/wali/SequentialAccessWriteAheadLog.java
View File

@ -17,6 +17,12 @@
package org.apache.nifi.wali;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.wali.SerDeFactory;
import org.wali.SyncListener;
import org.wali.WriteAheadRepository;
import java.io.File;
import java.io.IOException;
import java.util.Arrays;
@ -32,11 +38,6 @@ import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReadWriteLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;
import java.util.regex.Pattern;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.wali.SerDeFactory;
import org.wali.SyncListener;
import org.wali.WriteAheadRepository;
/**
* <p>
@ -265,6 +266,7 @@ public class SequentialAccessWriteAheadLog<T> implements WriteAheadRepository<T>
final JournalSummary journalSummary = journal.getSummary();
if (journalSummary.getTransactionCount() == 0 && journal.isHealthy()) {
logger.debug("Will not checkpoint Write-Ahead Log because no updates have occurred since last checkpoint");
syncListener.onGlobalSync();
return snapshot.getRecordCount();
}