[
https://issues.apache.org/jira/browse/SPARK-20036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15973544#comment-15973544
]
Daniel Nuriyev commented on SPARK-20036:
I placed the explicit dependencies in my
[
https://issues.apache.org/jira/browse/SPARK-20036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966939#comment-15966939
]
Daniel Nuriyev commented on SPARK-20036:
Thank you, Cody. I will do as you say an
[
https://issues.apache.org/jira/browse/SPARK-20037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15943654#comment-15943654
]
Daniel Nuriyev commented on SPARK-20037:
Thank you for your feedback, This proble
[
https://issues.apache.org/jira/browse/SPARK-20037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nuriyev updated SPARK-20037:
---
Attachment: Main.java
> impossible to set kafka offsets using kafka 0.10 and spark 2.0.0
> --
[
https://issues.apache.org/jira/browse/SPARK-20037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15943642#comment-15943642
]
Daniel Nuriyev commented on SPARK-20037:
My system is absolutely simple: a topic
[
https://issues.apache.org/jira/browse/SPARK-20037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nuriyev updated SPARK-20037:
---
Attachment: offsets.png
> impossible to set kafka offsets using kafka 0.10 and spark 2.0.0
>
[
https://issues.apache.org/jira/browse/SPARK-20037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15938600#comment-15938600
]
Daniel Nuriyev commented on SPARK-20037:
This is en exception from partition 1 of
[
https://issues.apache.org/jira/browse/SPARK-20036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15938472#comment-15938472
]
Daniel Nuriyev commented on SPARK-20036:
To provide more info I am attaching the
[
https://issues.apache.org/jira/browse/SPARK-20036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nuriyev updated SPARK-20036:
---
Attachment: Main.java
pom.xml
> impossible to read a whole kafka topic using
[
https://issues.apache.org/jira/browse/SPARK-20037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nuriyev updated SPARK-20037:
---
Description:
I use kafka 0.10.1 and java code with the following dependencies:
org.apache.ka
[
https://issues.apache.org/jira/browse/SPARK-20036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nuriyev updated SPARK-20036:
---
Description:
I use kafka 0.10.1 and java code with the following dependencies:
o
[
https://issues.apache.org/jira/browse/SPARK-20036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nuriyev updated SPARK-20036:
---
Description:
I use kafka 0.10.1 and java code with the following dependencies:
o
Daniel Nuriyev created SPARK-20037:
--
Summary: impossible to set kafka offsets using kafka 0.10 and
spark 2.0.0
Key: SPARK-20037
URL: https://issues.apache.org/jira/browse/SPARK-20037
Project: Spark
[
https://issues.apache.org/jira/browse/SPARK-20036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nuriyev updated SPARK-20036:
---
Description:
I use kafka 0.10.1 and java code with the following dependencies:
o
[
https://issues.apache.org/jira/browse/SPARK-20036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nuriyev updated SPARK-20036:
---
Component/s: (was: Spark Core)
Input/Output
> impossible to read a whole
Daniel Nuriyev created SPARK-20036:
--
Summary: impossible to read a whole kafka topic using kafka 0.10
and spark 2.0.0
Key: SPARK-20036
URL: https://issues.apache.org/jira/browse/SPARK-20036
Project:
16 matches
Mail list logo