Guanpx opened a new issue #4658: URL: https://github.com/apache/hudi/issues/4658
**Describe the problem you faced** Data lose with Flink write COW insert table, Flink web UI show Records Received was different with HIVE count(1) **To Reproduce** Steps to reproduce the behavior: 1. Flink write and sync to hive 2. and face that Flink web UI show Records Received was different with HIVE（impala） count(1) **Expected behavior**  ![Uploading image.png…]() **Environment Description** * Hudi version : 0.10.0 * Flink version : 1.13.2 * Hive version : 2.1.1-cdh6 * Hadoop version : 3.0.0-cdh6 * Storage (HDFS/S3/GCS..) : HDFS * Running on Docker? (yes/no) : no **Additional context** Flink writre config ``` 'connector' = 'hudi', 'path' = 'hdfs://nameservice-ha/hudi/rds/event_log_origin', 'table.type' = 'COPY_ON_WRITE', 'hoodie.datasource.write.recordkey.field' = 'distinct_id', 'hive_sync.enable'='true', 'hive_sync.table'='hudi_event_log_origin', 'hive_sync.db'='default', 'hive_sync.mode' = 'hms', 'hive_sync.metastore.uris' = '', 'hive_sync.skip_ro_suffix' = 'true', 'hoodie.datasource.write.operation' = 'insert', -- append模式 'write.tasks' = '2', 'write.bucket_assign.tasks' = '2', 'write.insert.cluster' = 'true', 'write.ignore.failed' = 'false', 'clean.async.enabled' = 'true', 'clean.retain_commits' = '4', 'archive.min_commits' = '6', 'archive.max_commits' = '12', 'hoodie.cleaner.commits.retained' = '4', 'hoodie.keep.min.commits' = '5', 'hoodie.keep.max.commits' = '10' ``` **Stacktrace** ```Add the stacktrace of the error.``` -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
