srowen commented on pull request #29078: URL: https://github.com/apache/spark/pull/29078#issuecomment-657693660
Weird one: ``` KafkaContinuousSinkSuite: [info] - streaming - write to kafka with topic field *** FAILED *** (31 seconds, 238 milliseconds) [info] The code passed to eventually never returned normally. Attempted 14 times over 30.741770862000003 seconds. Last failure message: [info] Decoded objects do not match expected objects: [info] expected: WrappedArray(1, 2, 3, 4, 5) [info] actual: WrappedArray() [info] assertnotnull(upcast(getcolumnbyordinal(0, IntegerType), IntegerType, - root class: "scala.Int")) [info] +- upcast(getcolumnbyordinal(0, IntegerType), IntegerType, - root class: "scala.Int") [info] +- getcolumnbyordinal(0, IntegerType) [info] [info] . (KafkaSinkSuite.scala:340) ``` It's consistent, so I believe this patch causes it, but not yet seeing any obvious reason. I'll try to reproduce and isolate locally. ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org
