tree 0dd9899ea7d63284db48df03a281c62962099240
parent a5428e75ff92a4aad1ae9a3d4a613b8dccb6857c
author AmatyaAvadhanula <amatya.avadhanula@imply.io> 1713324991 +0530
committer GitHub <noreply@github.com> 1713324991 +0530
gpgsig -----BEGIN PGP SIGNATURE-----
 
 wsFcBAABCAAQBQJmH0O/CRC1aQ7uu5UhlAAANFUQAHkg3VAECswbYidZ9klnL8cl
 nv2RfyjS3TRc9hQ5tuvea5g0d01wBuaczWntuo1ijLlxWBPNmWuSk3Au+Xpx+E+2
 jATANR8+dW85vqRYU4SUTIbcRJBCVk2u7YSf7V1ihauHzzEPMTZlBXYfg24yH293
 /7ojr1ec1HTp2C9CEplvI7cYYruAxXEWiGxkw5j05JQm8Pm4fsXSjW/t1k8GEk76
 dSw6+zsuF445iNhCaF5AsxDODYer4gRf/ssfgpGgjbojswCnxOkP71IMCfVCjgFk
 rys4fQI/yX+rW7mm1fNKt8Pyid+vZNruHjtlg59gQd3FSHyELguHIxIf5A3vCU4N
 Hpq171Am6QL/UNiha2/0ahwyW2mXJfyr+J5mPqx7tEvUe3JIeiC9k/VNUk6H+0ff
 MBLOlWtezPG7YiBQhH7HO7LEG6sNsuKN7T7joZd910DQ4BoBR3zIJmZQb0WcVBM/
 4CZBgfrzRabM0v6Vbq9Gg3AftOPKIDiAmDDsDeLEtB/DNcP3LyRoxL0s3mA/9rHX
 +kUjX4amo7oEDRS1XYA43U/xUjkf+uboWWgjFEnAdETUzBae9lxpAzdKWF5oomeA
 SPRm1LjJh/7s8NBNdo6Hz6u/dy+fXR/3NYKjON9v5OkZGnNiToh3g3EU/wQAO5+K
 0s4Oyn8nioMVIeGA7HrT
 =phnU
 -----END PGP SIGNATURE-----
 

Associate pending segments with the tasks that requested them (#16144)

Changes:
- Add column `task_allocator_id` to `pendingSegments` metadata table.
- Add column `upgraded_from_segment_id` to `pendingSegments` metadata table.
- Add interface `PendingSegmentAllocatingTask` and implement it by all tasks which
can allocate pending segments.
- Use `taskAllocatorId` to identify the task (and its sub-tasks or replicas) to which
a pending segment has been allocated.
- Perform active cleanup of pending segments in `TaskLockbox` once there are no
active tasks for the corresponding task allocator id.
- When committing APPEND segments, also commit all upgraded pending segments
corresponding to that task allocator id.
- When committing REPLACE segments, upgrade all overlapping pending segments in
the same transaction.