Skip to content

Conversation

@jogrogan
Copy link
Collaborator

@jogrogan jogrogan commented Jan 5, 2026

When the same table is used as source and sink we are generating statements like:

CREATE TABLE IF NOT EXISTS `ADS`.`AD_CLICKS` (...) WITH ('connector'='datagen', ...);
CREATE TABLE IF NOT EXISTS `ADS`.`AD_CLICKS` (...) WITH ('connector'='blackhole');
INSERT INTO `ADS`.`AD_CLICKS` SELECT * FROM `ADS`.`AD_CLICKS`;

When Flink sees this it fails because ADS.AD_CLICKS has conflicting definitions.

This change will rewrite the query as such:

CREATE TABLE IF NOT EXISTS `ADS`.`AD_CLICKS_source` (...) WITH ('connector'='datagen', ...);
CREATE TABLE IF NOT EXISTS `ADS`.`AD_CLICKS_sink` (...) WITH ('connector'='blackhole');
INSERT INTO `ADS`.`AD_CLICKS_sink` SELECT * FROM `ADS`.`AD_CLICKS_source`;

This change also fixes a Quidem issue where tests run after !specify were failing because the connection was closed

Copy link
Collaborator

@ryannedolan ryannedolan left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

neat!

@jogrogan jogrogan merged commit 9653817 into main Jan 6, 2026
1 check passed
@jogrogan jogrogan deleted the jogrogan/nameConflicts branch January 6, 2026 20:15
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants