You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by GitBox <gi...@apache.org> on 2022/09/11 19:19:18 UTC

[GitHub] [hudi] Xiaohan-Shen opened a new issue, #6653: [SUPPORT] Hudi table COW taking up significant space for a small table

Xiaohan-Shen opened a new issue, #6653:
URL: https://github.com/apache/hudi/issues/6653

   **Describe the problem you faced**
   
   Hey guys, I tried to run DeltaStreamer on EMR to capture changes in MySQL through AWS DMS and store them COW on S3. I tried to run it for a table with 30,000 rows and 9 columns, which takes up ~6M on MySQL, but on S3 the Hudi table's folder takes up >10 GB... Did I configure something wrong?  
   ![image (12)](https://user-images.githubusercontent.com/55402701/189544915-46ca41d7-3b86-4045-8a0b-944b6abc217d.png)
   ![image (11)](https://user-images.githubusercontent.com/55402701/189544978-b96d05a1-3dbd-411e-a2f5-d9356ddbc1a9.png)
   
   **To Reproduce**
   
   Steps to reproduce the behavior:
   
   1. Follow basic setup described in this [blog](https://cwiki.apache.org/confluence/display/HUDI/2020/01/20/Change+Capture+Using+AWS+Database+Migration+Service+and+Hudi)
   2. Insert 30,000 rows into MySQL and wait until AWS DMS captures the changes 
   3. Use this command to start Hudi: 
   ```
   spark-submit 
     --jars /usr/lib/spark/external/lib/spark-avro.jar,/usr/lib/hudi/hudi-spark-bundle.jar,/usr/lib/hudi/hudi-utilities-bundle.jar 
     --class org.apache.hudi.utilities.deltastreamer.HoodieDeltaStreamer 
     --packages org.apache.hudi:hudi-spark-bundle_2.12:0.11.0,org.apache.spark:spark-avro_2.12:3.2.1 
     --master yarn --deploy-mode client /usr/lib/hudi/hudi-utilities-bundle.jar 
     --table-type COPY_ON_WRITE 
     --source-ordering-field updated_at 
     --source-class org.apache.hudi.utilities.sources.ParquetDFSSource 
     --target-base-path s3://mysql-data-replication/hudi_orders 
     --target-table hudi_orders 
     --transformer-class org.apache.hudi.utilities.transform.AWSDmsTransformer 
     --continuous 
     --hoodie-conf hoodie.datasource.write.recordkey.field=order_id 
     --hoodie-conf hoodie.datasource.write.partitionpath.field=customer_name 
     --hoodie-conf hoodie.deltastreamer.source.dfs.root=s3://mysql-data-replication/hudi_dms/orders 
     --payload-class org.apache.hudi.payload.AWSDmsAvroPayload
   ```
   
   **Expected behavior**
   
   The table takes up 6M on MySQL, so I expect the Hudi table to be <30M on S3. 
   
   **Environment Description**
   
   * Hudi version : 0.11.0
   
   * Spark version : 3.2.1
   
   * Hive version : should be irrelevant, but 3.1.3
   
   * Hadoop version : 3.2.1
   
   * Storage (HDFS/S3/GCS..) : S3
   
   * Running on Docker? (yes/no) : no
   
   


-- 
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: commits-unsubscribe@hudi.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


[GitHub] [hudi] Xiaohan-Shen commented on issue #6653: [SUPPORT] Hudi table COW taking up significant space for a small table

Posted by GitBox <gi...@apache.org>.
Xiaohan-Shen commented on issue #6653:
URL: https://github.com/apache/hudi/issues/6653#issuecomment-1247442099

   I just figured out the problem: I used the primary key field for partitioning, so it was creating one partition for every row. My bad. 


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


[GitHub] [hudi] xushiyan commented on issue #6653: [SUPPORT] Hudi table COW taking up significant space for a small table

Posted by GitBox <gi...@apache.org>.
xushiyan commented on issue #6653:
URL: https://github.com/apache/hudi/issues/6653#issuecomment-1247438706

   likely a lot of small files were created. @Xiaohan-Shen how many files were created in S3? and what do the file sizes look like?
   cc @zhangyue19921010 @yihua this can be a good point for diagnositc reporter to capture, as in how file sizes distribution look like, to help diagnose parquet size setting issues for example.


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


[GitHub] [hudi] Xiaohan-Shen closed issue #6653: [SUPPORT] Hudi table COW taking up significant space for a small table

Posted by GitBox <gi...@apache.org>.
Xiaohan-Shen closed issue #6653: [SUPPORT] Hudi table COW taking up significant space for a small table
URL: https://github.com/apache/hudi/issues/6653


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org