drorventura commented on issue #3108:
URL: https://github.com/apache/flink-cdc/issues/3108#issuecomment-2003458861
@olivier-derom were you able to make that work?
if not then this should solve your missing functions:
```
create or replace function min(uuid, uuid)
returns uuid
immutable parallel safe
language plpgsql as
$$
begin
return least($1, $2);
end
$$;
create aggregate min(uuid) (
sfunc = min,
stype = uuid,
combinefunc = min,
parallel = safe,
sortop = operator (<)
);
create or replace function max(uuid, uuid)
returns uuid
immutable parallel safe
language plpgsql as
$$
begin
return greatest($1, $2);
end
$$;
create aggregate max(uuid) (
sfunc = max,
stype = uuid,
combinefunc = max,
parallel = safe,
sortop = operator (>)
);
```
however it would still not work since uuid type is not supported or mapper
in the
`com.ververica.cdc.connectors.postgres.source.utils.PostgresTypeUtils.convertFromColumn`
and requires a mapping to DataType.STRING()
I wasn't able to proceed with the contribution yet, however I do wonder how
did you manage to get through?
--
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]
