Skip to content

Commit a31a8ce

Browse files
committed
Fix bug that only included the first file
1 parent 34efa4a commit a31a8ce

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/file_list.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -366,7 +366,7 @@ GetUnprocessedFileList(char *pipelineName, char *listFunction, char *filePattern
366366

367367
for (int rowIndex = 0; rowIndex < SPI_processed; rowIndex++)
368368
{
369-
HeapTuple row = SPI_tuptable->vals[0];
369+
HeapTuple row = SPI_tuptable->vals[rowIndex];
370370

371371
bool isNull = false;
372372
Datum pathDatum = SPI_getbinval(row, rowDesc, 1, &isNull);

0 commit comments

Comments
 (0)