ad1happy2go commented on issue #7244:
URL: https://github.com/apache/hudi/issues/7244#issuecomment-1649877906
@faizhasan @rshanmugam1 Apologies for the delay here. I tried to reproduce
and found out that it is working fine. I tried with 0.12.1 version.
Model I used, exactly like we have in ticket
```
{{ config(
materialized = 'incremental',
incremental_strategy = 'merge',
file_format = 'hudi',
options={
'type': 'cow',
'primaryKey': 'id',
'preCombineKey': 'ts',
},
unique_key = 'id',
location_root='file:///tmp/dbt/issue_7244_1/'
) }}
{% if not is_incremental() %}
select cast(1 as bigint) as id, 'yo' as msg, current_timestamp() as ts
union all
select cast(2 as bigint) as id, 'anyway' as msg, current_timestamp() as ts
union all
select cast(3 as bigint) as id, 'bye' as msg, current_timestamp() as ts
{% else %}
select cast(1 as bigint) as id, 'yo_updated' as msg, current_timestamp() as
ts
union all
select cast(2 as bigint) as id, 'anyway_updated' as msg, current_timestamp()
as ts
union all
select cast(3 as bigint) as id, 'bye_updated' as msg, current_timestamp()
as ts
{% endif %}
```
here are the results after first and second run --
--
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]
