This is an automated email from the ASF dual-hosted git repository.
gaojun2048 pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 6a2b05a845 [bugfix][file-execl] Fix the Issue of Abnormal Data Reading
from Excel Files (#5932)
6a2b05a845 is described below
commit 6a2b05a845aec83a7e7ce48a9ed31a035f96dbad
Author: ic4y <[email protected]>
AuthorDate: Mon Jan 8 18:07:29 2024 +0800
[bugfix][file-execl] Fix the Issue of Abnormal Data Reading from Excel
Files (#5932)
---
.../connectors/seatunnel/file/source/reader/ExcelReadStrategy.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/ExcelReadStrategy.java
b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/ExcelReadStrategy.java
index 306179d780..06225f9d33 100644
---
a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/ExcelReadStrategy.java
+++
b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/ExcelReadStrategy.java
@@ -91,7 +91,6 @@ public class ExcelReadStrategy extends AbstractReadStrategy {
: workbook.getSheetAt(0);
cellCount = seaTunnelRowType.getTotalFields();
cellCount = partitionsMap.isEmpty() ? cellCount : cellCount +
partitionsMap.size();
- SeaTunnelRow seaTunnelRow = new SeaTunnelRow(cellCount);
SeaTunnelDataType<?>[] fieldTypes = seaTunnelRowType.getFieldTypes();
int rowCount = sheet.getPhysicalNumberOfRows();
if (skipHeaderNumber > Integer.MAX_VALUE
@@ -111,6 +110,7 @@ public class ExcelReadStrategy extends AbstractReadStrategy
{
? IntStream.range(0,
cellCount).toArray()
: indexes;
int z = 0;
+ SeaTunnelRow seaTunnelRow = new
SeaTunnelRow(cellCount);
for (int j : cellIndexes) {
Cell cell = rowData.getCell(j);
seaTunnelRow.setField(
