Skip to content

Commit

Permalink
vendor: update tipb (#7055)
Browse files Browse the repository at this point in the history
  • Loading branch information
zz-jason authored and coocood committed Jul 15, 2018
1 parent 419e5cf commit 2945ddd
Show file tree
Hide file tree
Showing 6 changed files with 1,612 additions and 662 deletions.
2 changes: 1 addition & 1 deletion distsql/distsql_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -149,7 +149,7 @@ func (s *testSuite) TestAnalyze(c *C) {

bytes, err := response.NextRaw(context.TODO())
c.Assert(err, IsNil)
c.Assert(len(bytes), Equals, 14)
c.Assert(len(bytes), Equals, 16)

err = response.Close()
c.Assert(err, IsNil)
Expand Down
2 changes: 0 additions & 2 deletions distsql/stream.go
Original file line number Diff line number Diff line change
Expand Up @@ -84,8 +84,6 @@ func (r *streamResult) readDataFromResponse(ctx context.Context, resp kv.Respons
r.ctx.GetSessionVars().StmtCtx.AppendWarning(terror.ClassTiKV.New(terror.ErrCode(warning.Code), warning.Msg))
}

// TODO: Check stream.GetEncodeType() here if we support tipb.EncodeType_TypeArrow some day.

err = result.Unmarshal(stream.Data)
if err != nil {
return false, errors.Trace(err)
Expand Down
7 changes: 3 additions & 4 deletions store/mockstore/mocktikv/cop_handler_dag.go
Original file line number Diff line number Diff line change
Expand Up @@ -480,10 +480,9 @@ func (mock *mockCopStreamClient) Recv() (*coprocessor.Response, error) {
}
}
streamResponse := tipb.StreamResponse{
Error: toPBError(err),
EncodeType: tipb.EncodeType_TypeDefault,
Data: data,
Warnings: Warnings,
Error: toPBError(err),
Data: data,
Warnings: Warnings,
}
// The counts was the output count of each executor, but now it is the scan count of each range,
// so we need a flag to tell them apart.
Expand Down
97 changes: 74 additions & 23 deletions vendor/github.com/pingcap/tipb/go-binlog/pump.pb.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Loading

0 comments on commit 2945ddd

Please sign in to comment.