From: František Dvořák Date: Wed, 4 Mar 2015 20:00:53 +0000 (+0100) Subject: Fix inserting new jobs. X-Git-Url: http://scientific.zcu.cz/git/?a=commitdiff_plain;h=edea93e0beb93fe832af6ca76b3836b68b6066e2;p=hadoop-jobstat.git Fix inserting new jobs. --- diff --git a/jobs.py b/jobs.py index 359d629..00b3988 100755 --- a/jobs.py +++ b/jobs.py @@ -321,7 +321,7 @@ for id, job in jobs.iteritems(): if debug: print '[db] job %s updated' % id else: - st.execute("INSERT INTO job (id, user, status, start, finish) VALUES('%s', %s, %s)" %(id, job.user, job.status, dbint(job.start), dbint(job.finish))) + st.execute("INSERT INTO job (id, user, status, start, finish) VALUES('%s', '%s', '%s', %s, %s)" %(id, job.user, job.status, dbint(job.start), dbint(job.finish))) if debug: print '[db] job %s inserted' % id if job.mapred: if data and data[3] == job.mapred['submitTime'] and data[8] == job.mapred['mapsTotal'] and data[9] == job.mapred['reducesTotal']: