You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@paimon.apache.org by "www2388258980 (via GitHub)" <gi...@apache.org> on 2023/04/13 06:20:25 UTC
[GitHub] [incubator-paimon] www2388258980 commented on issue #891: [Bug] for streaming queries, 'merge-engine' = 'aggregation' dot't produce the correctness of the query result
www2388258980 commented on issue #891:
URL: https://github.com/apache/incubator-paimon/issues/891#issuecomment-1506410794
create table cdc_ticket_fees(
id int,
ticket_id int,
`type` string,
`data` string,
total decimal(11,2),
primary key(id) not enforced
)
with (
'connector' = 'postgres-cdc',
'hostname' = '',
'port' = '5432',
'username' = '',
'password' = '',
'database-name' = 'ibupro_cloud',
'schema-name' = 'public',
'table-name' = 'ticket_fees',
'slot.name' = 'ticket_fees',
'decoding.plugin.name' = 'wal2json_streaming',
'changelog-mode' = 'upsert'
);
insert into ods_ticket_fees
select *
from cdc_ticket_fees;
--
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: issues-unsubscribe@paimon.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org