This commit is contained in:
Alexander Tokmakov 2019-05-28 02:09:35 +03:00 committed by Alexander Tokmakov
parent 7e9c3f2022
commit 89ae562e83
2 changed files with 3 additions and 3 deletions

View File

@ -310,10 +310,10 @@ void TemplateBlockOutputStream::writeSuffix()
writeValue<double, DataTypeFloat64>(watch.elapsedSeconds(), format.formats[j]); writeValue<double, DataTypeFloat64>(watch.elapsedSeconds(), format.formats[j]);
break; break;
case OutputPart::RowsRead: case OutputPart::RowsRead:
writeValue<size_t, DataTypeUInt64>(progress.rows.load(), format.formats[j]); writeValue<size_t, DataTypeUInt64>(progress.read_rows.load(), format.formats[j]);
break; break;
case OutputPart::BytesRead: case OutputPart::BytesRead:
writeValue<size_t, DataTypeUInt64>(progress.bytes.load(), format.formats[j]); writeValue<size_t, DataTypeUInt64>(progress.read_bytes.load(), format.formats[j]);
break; break;
default: default:
break; break;

View File

@ -80,7 +80,7 @@ private:
ParsedTemplateFormat format; ParsedTemplateFormat format;
ParsedTemplateFormat row_format; ParsedTemplateFormat row_format;
size_t rows_before_limit; size_t rows_before_limit = 0;
bool rows_before_limit_set = false; bool rows_before_limit_set = false;
Block totals; Block totals;
Block extremes; Block extremes;