diff --git a/job.go b/job.go
index 9641fd3..e54f239 100644
--- a/job.go
+++ b/job.go
@@ -17,6 +17,10 @@ import (
 )
 
 func createJob(jobTypeID int32, priority int32, userID64 int64, trigger int64, schedule time.Time, payload []byte) (int64, error) {
+	if len(payload) > 20000 {
+		return 0, errors.New("payload too long")
+	}
+
 	stmt, err := db.Prepare(`INSERT INTO obj (obj_type_id, obj_sub_type_id)
 								 VALUES 	 (?          , ?);`)
 	logOnError(err, "createJob : prepare insert obj")
diff --git a/sql.go b/sql.go
index 34c7d2d..89a8560 100644
--- a/sql.go
+++ b/sql.go
@@ -383,7 +383,7 @@ func initDB() {
 							,started		TIMESTAMP
 							,ended			TIMESTAMP
 							,timeout		TIMESTAMP
-							,payload		VARCHAR(4000)
+							,payload		VARCHAR(65532)
 							,FOREIGN KEY (obj_id) REFERENCES obj(id) ON DELETE CASCADE
 							,KEY (is_done)
 							,KEY (in_work)