hawq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From r...@apache.org
Subject incubator-hawq git commit: HAWQ-638. gpload bugfix using pip installed PyGreSQL
Date Sun, 10 Apr 2016 06:45:41 GMT
Repository: incubator-hawq
Updated Branches:
  refs/heads/master 1bcd79f70 -> a57cc9523


HAWQ-638. gpload bugfix using pip installed PyGreSQL


Project: http://git-wip-us.apache.org/repos/asf/incubator-hawq/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-hawq/commit/a57cc952
Tree: http://git-wip-us.apache.org/repos/asf/incubator-hawq/tree/a57cc952
Diff: http://git-wip-us.apache.org/repos/asf/incubator-hawq/diff/a57cc952

Branch: refs/heads/master
Commit: a57cc9523f97e471a69b658556c989d13ad88661
Parents: 1bcd79f
Author: xunzhang <xunzhangthu@gmail.com>
Authored: Thu Apr 7 22:01:59 2016 +0800
Committer: rlei <rlei@pivotal.io>
Committed: Sun Apr 10 14:45:04 2016 +0800

----------------------------------------------------------------------
 tools/bin/gpload.py | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-hawq/blob/a57cc952/tools/bin/gpload.py
----------------------------------------------------------------------
diff --git a/tools/bin/gpload.py b/tools/bin/gpload.py
index 454da7a..295ccbe 100755
--- a/tools/bin/gpload.py
+++ b/tools/bin/gpload.py
@@ -702,7 +702,7 @@ def notice_processor(self):
        return
 
     theNotices = self.db.notices()
-    r = re.compile("^NOTICE:  Found (\d) data formatting errors.*")
+    r = re.compile("^NOTICE:  Found (\d+) data formatting errors.*")
     messageNumber = 0
     m = None
     while messageNumber < len(theNotices) and m == None:
@@ -2279,7 +2279,8 @@ class gpload:
 
 
     def count_errors(self):
-        notice_processor(self)
+        if hasattr(self.db, 'notices'):
+            notice_processor(self)
         if self.error_table and not self.options.D and not self.reuse_tables:
             # make sure we only get errors for our own instance
             queryStr = 'select count(*) from ' + self.error_table + " WHERE relname = '%s'"
% self.extTableName


Mime
View raw message