diff --git a/job.go b/job.go index cfde274..a9f7e63 100644 --- a/job.go +++ b/job.go @@ -222,7 +222,7 @@ func loadCurrentJobs() ([]Job, error) { zb := bytes.NewReader(zpayload) zr, err := zlib.NewReader(zb) if err != nil { - logOnError(err, "loadCurrentJobs : zlib.NewReader.") + logOnError(err, "loadCurrentJobs : zlib.NewReader") continue } b := new(bytes.Buffer) diff --git a/obj.go b/obj.go index 76ff814..9cff5d8 100644 --- a/obj.go +++ b/obj.go @@ -1049,7 +1049,7 @@ func loadObjJob() error { zb := bytes.NewReader(zpayload) zr, err := zlib.NewReader(zb) if err != nil { - logOnError(err, "loadObjJob : zlib.NewReader.") + logOnError(err, "loadObjJob : zlib.NewReader") continue } b := new(bytes.Buffer) diff --git a/sql.go b/sql.go index 7644abc..ee8d8c1 100644 --- a/sql.go +++ b/sql.go @@ -385,7 +385,7 @@ func initDB() { ,started TIMESTAMP ,ended TIMESTAMP ,timeout TIMESTAMP - ,payload VARCHAR(65532) + ,payload VARBINARY(20000) ,FOREIGN KEY (obj_id) REFERENCES obj(id) ON DELETE CASCADE ,KEY (is_done) ,KEY (in_work)