[GitHub] spark pull request: [SPARK-5569] [STREAMING] fix ObjectInputStream...

2015-10-23 Thread maxwellzdm
Github user maxwellzdm commented on the pull request: https://github.com/apache/spark/pull/8955#issuecomment-150605939 @tdas I have added unit test which wouldn't pass without this patch. Please review it when you have time. --- If your project is set up for it, you can reply

[GitHub] spark pull request: [SPARK-5569] [STREAMING] fix ObjectInputStream...

2015-10-16 Thread maxwellzdm
Github user maxwellzdm commented on the pull request: https://github.com/apache/spark/pull/8955#issuecomment-148744435 OK, Please give me some time and I'll try to add unit tests. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[GitHub] spark pull request: [SPARK-5569] [STREAMING] fix ObjectInputStream...

2015-10-01 Thread maxwellzdm
GitHub user maxwellzdm opened a pull request: https://github.com/apache/spark/pull/8955 [SPARK-5569] [STREAMING] fix ObjectInputStreamWithLoader for supporting load array classes. When use Kafka DirectStream API to create checkpoint and restore saved checkpoint when restart