Merge pull request #334 from Mytherin/issue319

Mytherin · web-flow · commit a9b4caf7f765 · 2025-06-12T11:42:14.000+02:00
Limit tids to POSTGRES_TID_MAX
diff --git a/src/postgres_scanner.cpp b/src/postgres_scanner.cpp
@@ -341,7 +341,7 @@ static bool PostgresParallelStateNext(ClientContext &context, const FunctionData
 	lstate.batch_idx = gstate.batch_idx++;
 	if (gstate.page_idx < bind_data->pages_approx) {
 		auto page_max = gstate.page_idx + bind_data->pages_per_task;
-		if (page_max >= bind_data->pages_approx) {
+		if (page_max >= bind_data->pages_approx || page_max > POSTGRES_TID_MAX) {
 			// the relpages entry is not the real max, so make the last task bigger
 			page_max = POSTGRES_TID_MAX;
 		}

Original file line number	Diff line number	Diff line change
`@@ -341,7 +341,7 @@ static bool PostgresParallelStateNext(ClientContext &context, const FunctionData`
`341`	`341`	`lstate.batch_idx = gstate.batch_idx++;`
`342`	`342`	`if (gstate.page_idx < bind_data->pages_approx) {`
`343`	`343`	`auto page_max = gstate.page_idx + bind_data->pages_per_task;`
`344`		`- if (page_max >= bind_data->pages_approx) {`
	`344`	`+ if (page_max >= bind_data->pages_approx \|\| page_max > POSTGRES_TID_MAX) {`
`345`	`345`	`// the relpages entry is not the real max, so make the last task bigger`
`346`	`346`	`page_max = POSTGRES_TID_MAX;`
`347`	`347`	`}`