mirror of
https://github.com/xcat2/confluent.git
synced 2026-08-03 16:07:00 +00:00
b081c17b55
The loop that drains the importer's remaining output reads a byte at a time but clears currline on every iteration, one level out from where the earlier loop clears it. currline is therefore never longer than a single byte, so the percentage and ERROR: branches can never match and the tail of an import is silently discarded. Clear it only once a line has been consumed, as the earlier loop does.