Skip to content

Commit 75f2ec9

Browse files
authored
fix: ignore existing blobs in datalake migration (#9664)
Signed-off-by: Alexander Onnikov <[email protected]>
1 parent cb99b82 commit 75f2ec9

File tree

1 file changed

+14
-2
lines changed
  • services/datalake/pod-datalake/src/datalake

1 file changed

+14
-2
lines changed

services/datalake/pod-datalake/src/datalake/db.ts

Lines changed: 14 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -619,12 +619,24 @@ function migrationV2 (): [string, string] {
619619
UPDATE blob.blob
620620
SET workspace = w.uuid
621621
FROM global_account.workspace w
622-
WHERE workspace = w.data_id;
622+
WHERE workspace = w.data_id
623+
AND NOT EXISTS (
624+
SELECT 1
625+
FROM blob.blob existing
626+
WHERE existing.workspace = w.uuid::string
627+
AND existing.name = blob.blob.name
628+
);
623629
624630
UPDATE blob.meta
625631
SET workspace = w.uuid
626632
FROM global_account.workspace w
627-
WHERE workspace = w.data_id;
633+
WHERE workspace = w.data_id
634+
AND NOT EXISTS (
635+
SELECT 1
636+
FROM blob.meta existing
637+
WHERE existing.workspace = w.uuid::string
638+
AND existing.name = blob.meta.name
639+
);
628640
629641
ALTER TABLE blob.meta ADD CONSTRAINT fk_blob_meta FOREIGN KEY (workspace, name) REFERENCES blob.blob (workspace, name);
630642
`

0 commit comments

Comments
 (0)