Skip to content

Antalya 26.4: Fix file identifier in rescheduleTasksFromReplica#1881

Open
zvonand wants to merge 2 commits into
antalya-26.4from
feature/antalya-26.4/pr-1748
Open

Antalya 26.4: Fix file identifier in rescheduleTasksFromReplica#1881
zvonand wants to merge 2 commits into
antalya-26.4from
feature/antalya-26.4/pr-1748

Conversation

@zvonand

@zvonand zvonand commented Jun 7, 2026

Copy link
Copy Markdown
Member

Changelog category (leave one):

  • Bug Fix (user-visible misbehavior in an official stable release)

Changelog entry (a user-readable short description of the changes that goes to CHANGELOG.md):

Solved #1486

File identifier for distributed tasks was changed between 25.8 and 26.1
In frontport #1414 it was missed and rescheduleTasksFromReplica continued to use old variant.

Fix unsyncronized access to replica_to_files_to_be_processed class member (#1493 by @ianton-ru) (#1748 by @zvonand).

CI/CD Options

Exclude tests:

  • Fast test
  • Integration Tests
  • Stateless tests
  • Stateful tests
  • Performance tests
  • All with ASAN
  • All with TSAN
  • All with MSAN
  • All with UBSAN
  • All with Coverage
  • All with Aarch64
  • All Regression
  • Disable CI Cache

Regression jobs to run:

  • Fast suites (mostly <1h)
  • Aggregate Functions (2h)
  • Alter (1.5h)
  • Benchmark (30m)
  • ClickHouse Keeper (1h)
  • Iceberg (2h)
  • LDAP (1h)
  • Parquet (1.5h)
  • RBAC (1.5h)
  • SSL Server (1h)
  • S3 (2h)
  • S3 Export (2h)
  • Swarms (30m)
  • Tiered Storage (2h)

Cherry-picked from #1748.


Documentation entry for user-facing changes

...

zvonand added 2 commits June 7, 2026 19:44
…next commit)

---
Original cherry-pick message follows:

Merge pull request #1748 from Altinity/feature/antalya-26.3/pr-1493

Antalya 26.3: Fix file identifier in rescheduleTasksFromReplica
# Conflicts:
#	src/Storages/ObjectStorage/StorageObjectStorageStableTaskDistributor.cpp
#	src/Storages/ObjectStorage/StorageObjectStorageStableTaskDistributor.h
Ported `getFileIdentifier` helper and its usage in `getPreQueuedFile`,
`getMatchingFileFromIterator`, and `getAnyUnprocessedFile`.
Applied mutex locking around `getReplicaForFile` in
`getMatchingFileFromIterator` as introduced by the source PR.

`saveLastNodeActivity`, `rescheduleTasksFromReplica`, and the locking
of `replica_to_files_to_be_processed` from the source PR were not ported:
`antalya-26.4` does not have `replica_to_files_to_be_processed`,
`last_node_activity`, or `rescheduleTasksFromReplica` — those require
a separate prerequisite port of the tracking infrastructure from
`antalya-26.3`.

The `iceberg_read_optimization_enabled` block in the conflict for
`getMatchingFileFromIterator` was pre-existing `antalya-26.3` code
not present in source PR #1748's diff; it was not added.
@zvonand zvonand added releasy Created/managed by RelEasy antalya-26.4 ai-resolved Port conflict auto-resolved by Claude labels Jun 7, 2026
@github-actions

github-actions Bot commented Jun 7, 2026

Copy link
Copy Markdown

Workflow [PR], commit [9229e47]

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

ai-resolved Port conflict auto-resolved by Claude antalya-26.4 releasy Created/managed by RelEasy

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant