Github user LuciferYang commented on the issue:
https://github.com/apache/spark/pull/22149
> Is that possible to add a test case?
Thanks for your reply Xiao, I tried to add a test case to reproduce bad
case, but it only reproduce in small probabilityï¼we need to ensure that Task
still run in `iter.map(outputProjection).foreach { row => xxxx}` code part of
`ScriptTransformationWriterThread.run` method and not completed when TaskRunner
response `KillTask` cmd , timing is difficult to accuracy control.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
