We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a7aab8b commit 3ba8ff6Copy full SHA for 3ba8ff6
fluss-server/src/main/java/org/apache/fluss/server/log/LogLoader.java
@@ -179,7 +179,7 @@ private int recoverSegment(LogSegment segment) throws IOException {
179
* overflow
180
*/
181
private Tuple2<Long, Long> recoverLog() throws IOException {
182
- if (!isCleanShutdown) {
+ if (true) {
183
List<LogSegment> unflushed =
184
logSegments.values(recoveryPointCheckpoint, Long.MAX_VALUE);
185
int numUnflushed = unflushed.size();
0 commit comments