[GitHub] [flink] hehuiyuan opened a new pull request #16148: [FLINK-22617][Hive]Add log for hive source that use native or mapred reader

Mon, 14 Jun 2021 00:12:51 -0700 


hehuiyuan opened a new pull request #16148:
URL: https://github.com/apache/flink/pull/16148


   
   ## What is the purpose of the change
    Hive table sink  has some log that tells us whether to use native or mapred 
.
   
   ```
   LOG.info("Hive streaming sink: Use MapReduce RecordWriter writer.");
   LOG.info("Hive streaming sink: Use native parquet&orc writer.");
   LOG.info(
    "Hive streaming sink: Use MapReduce RecordWriter writer because BulkWriter 
Factory not available.");
   ```
    
   
   I have some ideas we can add log  to make it more  obvious when read hive 
for `createBulkFormatForSplit`.
   
   
![image](https://user-images.githubusercontent.com/18002496/121666439-d7141c00-cadb-11eb-9446-b523768ad541.png)
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to