Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

replacingmergetree.delete.column property doesn't work for postgres #501

Closed
DenisFilippovArammeem opened this issue Mar 13, 2024 · 2 comments · Fixed by #593
Closed

replacingmergetree.delete.column property doesn't work for postgres #501

DenisFilippovArammeem opened this issue Mar 13, 2024 · 2 comments · Fixed by #593
Labels
dev-complete Development completed kafka Issues related to Kafka version p3 qa-verified label to mark issues that were verified by QA
Milestone

Comments

@DenisFilippovArammeem
Copy link

DenisFilippovArammeem commented Mar 13, 2024

When synchronizing data between postgres and clickhouse using clickhouse-sink-connector, I'm trying to use
replacingmergetree.delete.column: "_sign"
property to auto-create ReplacingMergeTree table with _sign column as deletion indicator.
But sink-connector creates the table like the following:

CREATE TABLE my_database.test
(
    `id` Int32,
    `name` Nullable(String),
    `_sign` Int8,
    `_version` UInt64
)
ENGINE = ReplacingMergeTree(_version)

How can I specify that I need ReplacingMergeTree(_version, _sign) in the table declaration

@svb-alt svb-alt added this to the 2.2.0 milestone Apr 4, 2024
@svb-alt svb-alt removed the 2.0.2 label Apr 4, 2024
@svb-alt svb-alt modified the milestones: 2.2.0, 2.0.2 Apr 4, 2024
@svb-alt svb-alt added the kafka Issues related to Kafka version label Apr 4, 2024
@subkanthi
Copy link
Collaborator

With 2.0.2 release, in the kafka version, the is_deleted column will be created for ReplacingMergeTree, however its not customizable.

@subkanthi subkanthi modified the milestones: 2.0.2, 2.1.0 Apr 4, 2024
@DenisFilippovArammeem
Copy link
Author

thanks, @subkanthi
Is there any chance to make it customizable?

@subkanthi subkanthi modified the milestones: 2.1.0, 2.2.0 Apr 10, 2024
@subkanthi subkanthi linked a pull request May 14, 2024 that will close this issue
@subkanthi subkanthi added dev-complete Development completed p3 labels May 28, 2024
@Selfeer Selfeer added the qa-verified label to mark issues that were verified by QA label Jun 28, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
dev-complete Development completed kafka Issues related to Kafka version p3 qa-verified label to mark issues that were verified by QA
Projects
None yet
Development

Successfully merging a pull request may close this issue.

4 participants