YousifS7 commented on issue #11635:
URL: https://github.com/apache/hudi/issues/11635#issuecomment-2230777486
Hi @wombatu-kun, Thank you for getting back to me.
I have modified the SQL File to the following:
```
CACHE TABLE dbz_filtered AS
SELECT ts_ms, op, before, after FROM <SRC> WHERE op IN ('d', 'u', 'c', 'r');
CACHE TABLE dbz_events AS
SELECT ts_ms, CASE WHEN op = 'd' THEN before ELSE after END AS
source_fields, CASE WHEN op = 'd' THEN true ELSE false END AS is_deleted FROM
dbz_filtered;
CACHE TABLE dbz_fields AS
SELECT ts_ms, source_fields FROM dbz_events;
SELECT source_fields.*, Concat(source_fields.col1, source_fields.col2) AS
hudi_key, YEAR(FROM_UNIXTIME(source_fields.col2 / 1000)) AS partition_path FROM
dbz_fields;
```
I'm still getting the same error:
```
HoodieKeyException: recordKey value: "null" for field: "hudi_key" cannot be
null or empty.
```
Not sure if I'm missing something else.
Thank you
--
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]
