Github user uncleGen commented on a diff in the pull request: https://github.com/apache/spark/pull/16052#discussion_r90191009 --- Diff: streaming/src/test/scala/org/apache/spark/streaming/StreamingContextSuite.scala --- @@ -869,6 +891,31 @@ object TestReceiver { val counter = new AtomicInteger(1) } +class FakeByteArrayReceiver extends Receiver[Array[Byte]](StorageLevel.MEMORY_ONLY) with Logging { --- End diff -- @zsxwing yes, failure occurs when receiver store `Array[Byte]` data and the automatic serializer selection would pick JavaSerializer as the type of data is erased to be Object . However, after get from remote executor, the input-stream data will be deserialized with KryoSerializer as Task could get data type properly, leading to the **com.esotericsoftware.kryo.KryoException: Encountered unregistered class ID: 13994**
--- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. --- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org