bithw1 opened a new issue, #8356:
URL: https://github.com/apache/hudi/issues/8356
Hi,
I am running the following flink sql that writes the records to the hudi
table using flink. I have enabled the compaction option by setting
`'compaction.async.enabled'='true',`
The whole sql is:
```
val create_target_table_sql =
s"""
create table $hudi_table_name (
uuid varchar(20) PRIMARY KEY NOT ENFORCED, -- 必须指定主键
name varchar(20),
age int,
ts timestamp(3),
part varchar(20)
)
partitioned by (part)
with (
'connector' = 'hudi',
'path' = '$base_path',
'table.type' = 'MERGE_ON_READ',
'hoodie.datasource.write.recordkey.field'= 'uuid',
'hoodie.datasource.write.precombine.field' = 'ts',
'write.precombine.field' = 'ts',
'write.tasks'='2',
'write.bucket_assign.tasks' = '3',
'compaction.tasks'='1',
'compaction.async.enabled'='true',
'compaction.schedule.enabled'='true',
'compaction.trigger.strategy'='num_commits',
'compaction.delta_commits'='5',
)
```
While the sql keeps writing data to hudi, I watched the hudi table's
`.hoodie` directoy, I noticed that there are
`20230402122706.compaction.requested` and `.20230402122706.compaction.inflight`
there , but it looks there are no file created when the compaction completes,
eg: `20230402122706.compaction`, I would ask what file(file naming) will be
created when the compaction successfully completes
--
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-unsubscr...@hudi.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
