[SUPPORT] Hudi write to COW table hangs on Preparing compaction metadata job
- Dominant language
- Java
- Stars
- 6.2k
- Forks
- 2.5k
- Avg merge
- 2d 8h
- Merged PRs (30d)
- 111
Description
**Describe the problem you faced**
My Hudi job runs fine for first 9-10 executions and each job takes about 9-10mins. The job run after 10th/11th execution hangs and neither succeeds or fails. I am running this on Glue 4.0, Hudi 0.14. I have gone through the Spark UI and looks like the job is hanging on `Preparing compaction metadata: gft_fact_consol_hudi_metadata` step.
**To Reproduce**
Steps to reproduce the behavior:
Below are the hudi options used
```
{
'hoodie.table.cdc.enabled':'true',
'hoodie.table.cdc.supplemental.logging.mode': 'data_before_after',
'hoodie.datasource.write.recordkey.field': 'bazaar_uuid',
'hoodie.datasource.write.keygenerator.class': 'org.apache.hudi.keygen.ComplexKeyGenerator',
'hoodie.table.name': "gft_fact_consol_hudi",
'hoodie.datasource.write.table.name': "gft_fact_consol_hudi",
'hoodie.datasource.hive_sync.table': "gft_fact_consol_hudi",
'hoodie.datasource.hive_sync.database': "default",
'hoodie.datasource.write.partitionpath.field': 'a,b,c',
'hoodie.datasource.hive_sync.partition_fields': 'a,b,c',
'hoodie.datasource.write.hive_style_partitioning': 'true',
'hoodie.datasource.hive_sync.enable': 'true',
'hoodie.datasource.hive_sync.partition_extractor_class': 'org.apache.hudi.hive.MultiPartKeysValueExtractor',
'hoodie.metadata.enable': 'true',
'hoodie.metadata.record.index.enable':'true',
'hoodie.cleaner.policy': 'KEEP_LATEST_FILE_VERSIONS',
# 'hoodie.parquet.small.file.limit':104857600,
# 'hoodie.parquet.max.file.size':125829120,
'hoodie.clustering.inline':'true',
'hoodie.clustering.inline.max.commits': '4',
'hoodie.datasource.write.storage.type': 'COPY_ON_WRITE',
'hoodie.datasource.write.operation': 'upsert',
'hoodie.datasource.write.precombine.field': 'record_uuid',
'hoodie.datasource.hive_sync.use_jdbc': 'false',
'hoodie.datasource.hive_sync.mode': 'hms',
'hoodie.datasource.hive_sync.support_timestamp': 'true',
# 'hoodie.write.concurrency.mode': 'OPTIMISTIC_CONCURRENCY_CONTROL',
# 'hoodie.write.lock.provider': 'org.apache.hudi.aws.transaction.lock.DynamoDBBasedLockProvider',
# 'hoodie.cleaner.policy.failed.writes': 'LAZY',
# 'hoodie.write.lock.dynamodb.table': 'fri_hudi_locks_table',
# 'hoodie.embed.timeline.server': 'false',
# 'hoodie.write.lock.client.wait_time_ms_between_retry': 50000,
# 'hoodie.write.lock.wait_time_ms_between_retry': 20000,
# 'hoodie.write.lock.wait_time_ms': 60000,
# 'hoodie.write.lock.client.num_retries': 15,
# 'hoodie.keep.max.commits':'7',
# 'hoodie.keep.min.commits':'6',
# 'hoodie.write.lock.dynamodb.region': 'us-west-2',
# 'hoodie.write.lock.dynamodb.endpoint_url': 'dynamodb.us-west-2.amazonaws.com'
}
```
**Expected behavior**
As per https://hudi.apache.org/docs/compaction#background, compaction should only occur for MOR tables. Any idea why it is happening for a COW table?
**Environment Description**
* Hudi version : 0.14
* Spark version : 3.3.0
* Hive version :
* Hadoop version :
* Storage (HDFS/S3/GCS..) : s3
* Running on Docker? (yes/no) :
Contributor guide
No contributing guide indexed for this repository
Research direction
No source file or test is named. Start by reproducing the supplied Hudi 0.14 configuration on Glue 4.0 and inspect the Spark UI when the run reaches “Preparing compaction metadata”; done means explaining why this occurs for a COW table or identifying a verified fix.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- aws, java
- Domain
- data-engineering, distributed-systems
- Issue type
- Bug
- Difficulty
- 5/5
- Estimated time
- Over a week
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 25/100