ggjh-159 opened a new pull request, #12320: URL: https://github.com/apache/gluten/pull/12320
fix: https://github.com/apache/gluten/issues/12306 related prs: https://github.com/bigo-sg/velox/pull/49 https://github.com/bigo-sg/velox4j/pull/39 ## What changes are proposed in this pull request? This PR consumes the companion velox PR (which now writes to `std::cout` / `std::cerr`): - Drop the file-path resolution and the `Configuration` / `CoreOptions` / `ConfigConstants` imports. - `PrintSinkFactory.extractPrintOptions` reflects into the `RowDataPrintFunction` → `PrintSinkOutputWriter` to read the user-supplied `sinkIdentifier` (print-identifier) and `target` (true = stderr) fields, and passes them through to `PrintTableHandle(tableName, inputColumns, printIdentifier, isStdErr)`. - The velox C++ side computes the Flink-style `N> ` prefix from `parallelism` / `task_index` session properties and serializes concurrent subtask writes with a process-wide mutex. ## How was this patch tested? - UTs - Manual run on a standalone Flink cluster with `parallelism.default = 2`, nexmark `events.num = 10000, tps = 2000`, query q0: every bid row reaches `taskmanager.out`, each line carries the `1> ` / `2> ` subtask prefix, no truncation across subtasks. -- 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]
