[
https://issues.apache.org/jira/browse/SPARK-14105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liyin Tang updated SPARK-14105:
---
Description:
When using DISK or Memory to persistent KafkaDirectInputStream, it will
serialize the
[
https://issues.apache.org/jira/browse/SPARK-14105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liyin Tang updated SPARK-14105:
---
Description:
When using DISK or Memory to persistent KafkaDirectInputStream, it will
serialize the
[
https://issues.apache.org/jira/browse/SPARK-14105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liyin Tang updated SPARK-14105:
---
Description:
When using DISK or Memory to persistent KafkaDirectInputStream, it will
serialize the
[
https://issues.apache.org/jira/browse/SPARK-14105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liyin Tang updated SPARK-14105:
---
Description:
When using DISK or Memory to persistent KafkaDirectInputStream, it will
serialize the
[
https://issues.apache.org/jira/browse/SPARK-14105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liyin Tang updated SPARK-14105:
---
Affects Version/s: 1.6.1
> Serialization issue for KafkaRDD
>
>
>
[
https://issues.apache.org/jira/browse/SPARK-14105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liyin Tang updated SPARK-14105:
---
Attachment: Screenshot 2016-03-23 09.04.51.png
The screenshot of KafkaRDD's serialization
>
[
https://issues.apache.org/jira/browse/SPARK-14105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liyin Tang updated SPARK-14105:
---
Component/s: (was: Spark Core)
> Serialization issue for KafkaRDD
>
[
https://issues.apache.org/jira/browse/SPARK-14105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liyin Tang updated SPARK-14105:
---
Affects Version/s: 1.5.2
Component/s: Streaming
Spark Core
>