diff -r 8af7c6d86efb -r a964c40adbe3 server/mssteps.py
--- a/server/mssteps.py	Tue Jul 10 10:33:19 2012 +0200
+++ b/server/mssteps.py	Tue Jul 10 15:07:52 2012 +0200
@@ -159,7 +159,9 @@
         if self.outputtable:
             self.plan.create_temp_table(self.outputtable)
             sql = 'INSERT INTO %s %s' % (self.outputtable, sql)
-        return self.plan.sqlexec(sql, self.plan.args)
+            self.plan.syssource.doexec(self.plan.session, sql, self.plan.args)
+        else:
+            return self.plan.sqlexec(sql, self.plan.args)
 
     def get_sql(self):
         self.inputmap = inputmap = self.children[-1].outputmap