[hotfix] Set finish before notifying load in LanceArrowWriter setFinished method (#1985)

xx789633 · web-flow · commit 64971b1738af · 2025-11-18T14:48:45.000+08:00
diff --git a/fluss-lake/fluss-lake-lance/src/main/java/org/apache/fluss/lake/lance/tiering/LanceArrowWriter.java b/fluss-lake/fluss-lake-lance/src/main/java/org/apache/fluss/lake/lance/tiering/LanceArrowWriter.java
@@ -38,7 +38,7 @@ public class LanceArrowWriter extends ArrowReader {
     private final RowType rowType;
     private final int batchSize;
 
-    private volatile boolean finished;
+    private volatile boolean finished = false;
 
     private final AtomicLong totalBytesRead = new AtomicLong();
     private ArrowWriter arrowWriter = null;
@@ -74,8 +74,8 @@ void write(LogRecord row) {
     }
 
     void setFinished() {
-        loadToken.release();
         finished = true;
+        loadToken.release();
     }
 
     @Override

Original file line number	Diff line number	Diff line change
`@@ -38,7 +38,7 @@ public class LanceArrowWriter extends ArrowReader {`
`38`	`38`	`private final RowType rowType;`
`39`	`39`	`private final int batchSize;`
`40`	`40`
`41`		`- private volatile boolean finished;`
	`41`	`+ private volatile boolean finished = false;`
`42`	`42`
`43`	`43`	`private final AtomicLong totalBytesRead = new AtomicLong();`
`44`	`44`	`private ArrowWriter arrowWriter = null;`
`@@ -74,8 +74,8 @@ void write(LogRecord row) {`
`74`	`74`	`}`
`75`	`75`
`76`	`76`	`void setFinished() {`
`77`		`- loadToken.release();`
`78`	`77`	`finished = true;`
	`78`	`+ loadToken.release();`
`79`	`79`	`}`
`80`	`80`
`81`	`81`	`@Override`