| Index: logdog/common/storage/bigtable/storage.go
|
| diff --git a/logdog/common/storage/bigtable/storage.go b/logdog/common/storage/bigtable/storage.go
|
| index 00dd18344fa78a726a4ce2c11a58313563ec4373..5357baa8f563c6237417f40ab2ef3fa7882d5870 100644
|
| --- a/logdog/common/storage/bigtable/storage.go
|
| +++ b/logdog/common/storage/bigtable/storage.go
|
| @@ -411,6 +411,7 @@ func (w *rowWriter) append(d []byte) (appended bool) {
|
|
|
| func (w *rowWriter) flush(ctx context.Context, raw btTable, index types.MessageIndex,
|
| project cfgtypes.ProjectName, path types.StreamPath) (int, error) {
|
| +
|
| flushCount := w.count
|
| if flushCount == 0 {
|
| return 0, nil
|
|
|