Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
wshwsh12 committed Jan 2, 2020
1 parent 90e8081 commit 6483d74
Show file tree
Hide file tree
Showing 3 changed files with 0 additions and 12 deletions.
1 change: 0 additions & 1 deletion executor/sort.go
Original file line number Diff line number Diff line change
Expand Up @@ -289,7 +289,6 @@ func (e *SortExec) fetchRowChunks(ctx context.Context) error {
}
e.rowChunks.Add(chk)
if atomic.LoadUint32(&e.exceeded) == 1 {
fmt.Println(e.rowChunks.Len())
err := e.generatePartition()
if err != nil {
return err
Expand Down
6 changes: 0 additions & 6 deletions executor/sort_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -51,10 +51,4 @@ func (s *testSuite) TestSortInDisk(c *C) {
for i := 0; i < 1024; i++ {
c.Assert(result.Rows()[i][0].(string), Equals, fmt.Sprint(i))
}

tk.MustExec("set @@tidb_mem_quota_query=500;")
result = tk.MustQuery("select * from t order by c1")
for i := 0; i < 1024; i++ {
c.Assert(result.Rows()[i][0].(string), Equals, fmt.Sprint(i))
}
}
5 changes: 0 additions & 5 deletions util/chunk/disk.go
Original file line number Diff line number Diff line change
Expand Up @@ -143,11 +143,6 @@ func (l *ListInDisk) NumChunks() int {
return len(l.offsets)
}

// GetOffsetOfRow returns the offset of a row in the ListInDisk.
func (l *ListInDisk) GetOffsetOfRow(ptr RowPtr) int64 {
return l.offsets[ptr.ChkIdx][ptr.RowIdx]
}

// Close releases the disk resource.
func (l *ListInDisk) Close() error {
if l.disk != nil {
Expand Down

0 comments on commit 6483d74

Please sign in to comment.