Repository: incubator-hawq
Updated Branches:
  refs/heads/master 4820193c9 -> 6d5792c40


HAWQ-1366. Throw unsupported error out for dictionary page in Parquet storage


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

Branch: refs/heads/master
Commit: 6d5792c408461d7d58fa7633d939dd8900138681
Parents: 4820193
Author: Lili Ma <[email protected]>
Authored: Tue Feb 28 17:57:21 2017 +0800
Committer: Lili Ma <[email protected]>
Committed: Tue Feb 28 18:02:16 2017 +0800

----------------------------------------------------------------------
 src/backend/cdb/cdbparquetcolumn.c | 5 +++++
 1 file changed, 5 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-hawq/blob/6d5792c4/src/backend/cdb/cdbparquetcolumn.c
----------------------------------------------------------------------
diff --git a/src/backend/cdb/cdbparquetcolumn.c 
b/src/backend/cdb/cdbparquetcolumn.c
index 89ce684..083f669 100644
--- a/src/backend/cdb/cdbparquetcolumn.c
+++ b/src/backend/cdb/cdbparquetcolumn.c
@@ -146,6 +146,11 @@ ParquetExecutorReadColumn(ParquetColumnReader 
*columnReader, File file)
 
                /*just process data page now*/
                if(pageHeader->page_type != DATA_PAGE){
+                       if(pageHeader->page_type == DICTIONARY_PAGE) {
+                               ereport(ERROR, 
(errcode(ERRCODE_GP_INTERNAL_ERROR),
+                                                               errmsg("HAWQ 
does not support dictionary page type resolver for Parquet format in column 
\'%s\' ",
+                                                                               
columnChunkMetadata->colName)));
+                       }
                        buffer += pageHeader->compressed_page_size;
                        continue;
                }

Reply via email to