This is an automated email from the ASF dual-hosted git repository.
davidzollo 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 9b3deb9ed0 [Fix][Connector-V2] Remove unreachable
LocalTimestampMillisConversion in ParquetWriteStrategy
9b3deb9ed0 is described below
commit 9b3deb9ed029e1f2c9b82e29ef19ff88ae66d730
Author: water <[email protected]>
AuthorDate: Fri Aug 14 12:13:51 2026 +0800
[Fix][Connector-V2] Remove unreachable LocalTimestampMillisConversion in
ParquetWriteStrategy
---
.../seatunnel/file/sink/writer/ParquetWriteStrategy.java | 8 +++++++-
1 file changed, 7 insertions(+), 1 deletion(-)
diff --git
a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/ParquetWriteStrategy.java
b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/ParquetWriteStrategy.java
index 8537fc688b..43bd1bc8c1 100644
---
a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/ParquetWriteStrategy.java
+++
b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/ParquetWriteStrategy.java
@@ -174,7 +174,13 @@ public class ParquetWriteStrategy extends
AbstractWriteStrategy<ParquetWriter<Ge
GenericData dataModel = new GenericData();
dataModel.addLogicalTypeConversion(new
Conversions.DecimalConversion());
dataModel.addLogicalTypeConversion(new
TimeConversions.DateConversion());
- dataModel.addLogicalTypeConversion(new
TimeConversions.LocalTimestampMillisConversion());
+ // LocalTimestampMillisConversion is not needed here because
+ // seaTunnelDataType2ParquetDataType maps TIMESTAMP to
+ // INT64.as(OriginalType.TIMESTAMP_MILLIS), which AvroSchemaConverter
+ // converts to Avro's timestamp-millis (not local-timestamp-millis).
+ // resolveObject also handles TIMESTAMP values manually (converting to
+ // epoch millis), bypassing the data model entirely.
+ // See https://github.com/apache/seatunnel/issues/11743
if (writer == null) {
Path path = new Path(filePath);
// initialize the kerberos login
