ggjh-159 opened a new issue, #12426: URL: https://github.com/apache/gluten/issues/12426
### Description Flink's `CommonExecSink.applyRowtimeTransformation` inserts a row-mode `StreamRecordTimestampInserter` on the sink input chain when the sink table declares a rowtime attribute. This operator reads the rowtime column from each `RowData` and stamps it onto the `StreamRecord` on a per-row basis. When the downstream sink is offloaded to Velox via Gluten-Flink, this row-mode inserter forces the columnar chain to be broken right before the sink: data is converted to `RowData`, the inserter iterates row by row to set the timestamp, and the result is then handed back to the (columnar) sink input. This adds two row↔column conversions per batch. Offload Flink's row-mode `StreamRecordTimestampInserter` to a native Velox operator, so the sink input chain stays columnar end-to-end when the sink is offloaded to Velox. ### Gluten version main branch -- 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] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
