Implement rescale change#142

Merged

jeffxiang merged 5 commits into

pinterest:mainfrom

ashish47108:ashish/rescale

May 27, 2026

Commits on May 11, 2026

Implement rescale change
ashish47108
committed
Implement source operator rescaling based on scan.parallelism, table.exec.resource.default-parallelism and kafka partition count values
ashish47108
committed
Removed obsolete code
ashish47108
committed

Commits on May 12, 2026

Added Unit test coverage
ashish47108
committed

Commits on May 15, 2026

removed unused code
ashish47108
committed