siddiqueirshad opened a new pull request, #13053: URL: https://github.com/apache/seatunnel/pull/13053
<!-- Thank you for contributing to Apache SeaTunnel! Please read the contribution guidelines: https://seatunnel.apache.org/docs/contribution/setup --> ### Purpose of this pull request In `DruidWriter.write(SeaTunnelRow element)`, row fields were encoded into inline CSV format by only appending non-null fields to the `StringJoiner`. If a field was `null`, it was omitted completely instead of emitting an empty string. This caused rows with null values to be short by column count, shifting all following fields to the left (including the timestamp column), leading to parsing failures or data corruption during Druid ingestion. Fixes #13045. ### Proposed changes 1. In `DruidWriter.java`: When `element.getField(i)` is null, append an empty string `""` to `joiner` so column positions are preserved in the inline CSV line. 2. Added `DruidWriterTest` unit test verifying that null field values produce empty CSV columns (`2,,20,...`) without shifting positions. ### Checklist - [x] Commits are signed off (`git commit -s`) - [x] Added unit tests verifying the fix -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
