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