File tree Expand file tree Collapse file tree 2 files changed +2
-4
lines changed
lance-spark-base_2.12/src
main/java/com/lancedb/lance/spark/write
test/java/com/lancedb/lance/spark/write Expand file tree Collapse file tree 2 files changed +2
-4
lines changed Original file line number Diff line number Diff line change @@ -34,7 +34,7 @@ public class LanceArrowWriter extends ArrowReader {
3434 private final int batchSize ;
3535
3636 @ GuardedBy ("monitor" )
37- private volatile boolean finished ;
37+ private volatile boolean finished = false ;
3838
3939 private final AtomicLong totalBytesRead = new AtomicLong ();
4040 private com .lancedb .lance .spark .arrow .LanceArrowWriter arrowWriter = null ;
@@ -70,8 +70,8 @@ void write(InternalRow row) {
7070 }
7171
7272 void setFinished () {
73- loadToken .release ();
7473 finished = true ;
74+ loadToken .release ();
7575 }
7676
7777 @ Override
Original file line number Diff line number Diff line change 3535
3636import static org .junit .jupiter .api .Assertions .assertEquals ;
3737
38- // TODO: Flaky in CI, needs to fix
39- @ Disabled
4038public class LanceArrowWriterTest {
4139 @ Test
4240 public void test () throws Exception {
You can’t perform that action at this time.
0 commit comments