[ https://issues.apache.org/jira/browse/FLINK-22617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17349709#comment-17349709 ]
罗宇侠 commented on FLINK-22617: ----------------------------- [~hehuiyuan] Hi, as you have proposed the exact code changes, would you like to do this improvement and open pull request to us? we will appreciate it. > Add log when create bulk format > -------------------------------- > > Key: FLINK-22617 > URL: https://issues.apache.org/jira/browse/FLINK-22617 > Project: Flink > Issue Type: Improvement > Components: Connectors / Hive > Reporter: hehuiyuan > Priority: Major > Attachments: hivesourelog.jpg > > > Hive table sink has some log that tells us whether to use native or mapred . > > > {code:java} > 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."); > {code} > > I have some ideas we can add log to make it more obvious when read hive for > `createBulkFormatForSplit`. > > !hivesourelog.jpg|width=788,height=301! -- This message was sent by Atlassian Jira (v8.3.4#803005)