hawq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lil...@apache.org
Subject [1/2] incubator-hawq git commit: HAWQ-1061. Fix update catelog inconsistency issue.
Date Tue, 20 Sep 2016 07:57:05 GMT
Repository: incubator-hawq
Updated Branches:
  refs/heads/master a683b5c31 -> 50c1aa9ea


HAWQ-1061. Fix update catelog inconsistency issue.


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

Branch: refs/heads/master
Commit: 50c1aa9eab39868f11f8946d9564aa832f5eb96c
Parents: 8954090
Author: xunzhang <xunzhangthu@gmail.com>
Authored: Tue Sep 20 12:37:56 2016 +0800
Committer: Lili Ma <ictmalili@gmail.com>
Committed: Tue Sep 20 15:56:49 2016 +0800

----------------------------------------------------------------------
 tools/bin/hawqregister | 16 ++++++++++++----
 1 file changed, 12 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-hawq/blob/50c1aa9e/tools/bin/hawqregister
----------------------------------------------------------------------
diff --git a/tools/bin/hawqregister b/tools/bin/hawqregister
index 2b9b343..bdd6947 100755
--- a/tools/bin/hawqregister
+++ b/tools/bin/hawqregister
@@ -572,8 +572,12 @@ class HawqRegister(object):
             query = "set allow_system_table_mods='dml';"
             query += "begin transaction;"
             segno_lst = [f.split('/')[-1] for f in self.files_update]
-            for i, eof in enumerate(eofs):
-                query += "update pg_aoseg.%s set eof = '%s' where segno = '%s';" % (self.seg_name,
eof, segno_lst[i])
+            if self.file_format == 'Parquet':
+                for i, eof in enumerate(eofs):
+                    query += "update pg_aoseg.%s set eof = '%s', tupcount = '%s', eofuncompressed
= '%s' where segno = '%s';" % (self.seg_name, eof, -1, -1, segno_lst[i])
+            else:
+                for i, eof in enumerate(eofs):
+                    query += "update pg_aoseg.%s set eof = '%s', tupcount = '%s', varblockcount
= '%s', eofuncompressed = '%s' where segno = '%s';" % (self.seg_name, eof, -1, -1, -1, segno_lst[i])
             query += "end transaction;"
         else: # update_and_insert
             eofs = self.sizes
@@ -590,8 +594,12 @@ class HawqRegister(object):
             query += ';'
 
             segno_lst = [f.split('/')[-1] for f in self.files_update]
-            for i, eof in enumerate(self.sizes_update):
-                query += "update pg_aoseg.%s set eof = '%s' where segno = '%s';" % (self.seg_name,
eof, segno_lst[i])
+            if self.file_format == 'Parquet':
+                for i, eof in enumerate(self.sizes_update):
+                    query += "update pg_aoseg.%s set eof = '%s', tupcount = '%s', eofuncompressed
= '%s' where segno = '%s';" % (self.seg_name, eof, -1, -1, segno_lst[i])
+            else:
+                for i, eof in enumerate(self.sizes_update):
+                    query += "update pg_aoseg.%s set eof = '%s', tupcount = '%s', varblockcount
= '%s', eofuncompressed = '%s' where segno = '%s';" % (self.seg_name, eof, -1, -1, -1, segno_lst[i])
             query += "end transaction;"
         return self.utility_accessor.update_catalog(query)
 


Mime
View raw message