We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 2f719e7 commit 304b370Copy full SHA for 304b370
src/Series.cpp
@@ -575,6 +575,11 @@ void Series::flushRankTable(FlushLevel l)
575
[asRawPtr](char *) { delete asRawPtr; }};
576
writeDataset(std::move(put), /* num_lines = */ size);
577
}
578
+
579
+ // Must ensure that the Writable is consistently set to written on all
580
+ // ranks
581
+ series.m_rankTable.m_attributable.setWritten(
582
+ true, EnqueueAsynchronously::OnlyAsync);
583
return;
584
585
#endif
0 commit comments