Skip to content

Commit

Permalink
Fixed naming problem which caused table to not be read properly
Browse files Browse the repository at this point in the history
  • Loading branch information
EtienneBerubeShopify committed Aug 17, 2021
1 parent 8722226 commit 8061908
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions ferry.go
Original file line number Diff line number Diff line change
Expand Up @@ -1188,8 +1188,8 @@ func (f *Ferry) initializeTotalRowsAndBytes() {
f.StateTracker.UpdateTotalBytesPerTable(table.Name, 0)
f.StateTracker.UpdateTotalRowsPerTable(table.Name, 0)
} else {
f.StateTracker.UpdateTotalBytesPerTable(table.Name, uint64(totalBytes))
f.StateTracker.UpdateTotalRowsPerTable(table.Name, uint64(totalRows))
f.StateTracker.UpdateTotalBytesPerTable(table.String(), uint64(totalBytes))
f.StateTracker.UpdateTotalRowsPerTable(table.String(), uint64(totalRows))
}

}
Expand Down

0 comments on commit 8061908

Please sign in to comment.