You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Small Wong (Jira)" <ji...@apache.org> on 2022/05/25 12:57:00 UTC

[jira] [Created] (FLINK-27777) Can not get the parquet.compression when using native parquet&orc writer to sink hive

Small Wong created FLINK-27777:
----------------------------------

             Summary: Can not get the parquet.compression when using native parquet&orc writer to sink hive
                 Key: FLINK-27777
                 URL: https://issues.apache.org/jira/browse/FLINK-27777
             Project: Flink
          Issue Type: Bug
            Reporter: Small Wong
         Attachments: image-2022-05-25-20-53-20-412.png

after set table.exec.hive.fallback-mapred-writer=false, then sink hive by native parquet&orc writer, but can not get the `parquet.compression`  of `formatConf` in class `HiveTableSink`. There is no field `parquet.compression` in `jobConf` or `sd.getSerdeInfo().getParameters()`. And `parquet.compression` just  exists in `hive table properties`. 

 

!image-2022-05-25-20-53-20-412.png!



--
This message was sent by Atlassian Jira
(v8.20.7#820007)