[
https://issues.apache.org/jira/browse/SPARK-27554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849594#comment-16849594
]
Jepson commented on SPARK-27554:
[~hyukjin.kwon] Thanks for concern. The code issue, i can resolve it.
[
https://issues.apache.org/jira/browse/SPARK-27554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826699#comment-16826699
]
Jepson commented on SPARK-27554:
[~hyukjin.kwon] Thanks for quick reply.
But, other spark job are
[
https://issues.apache.org/jira/browse/SPARK-27554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jepson updated SPARK-27554:
---
Description:
{code:java}
{code}
#basic env
JAVA_HOME=/usr/java/jdk1.8.0_181
Jepson created SPARK-27554:
--
Summary: org.apache.hadoop.security.AccessControlException: Client
cannot authenticate via:[TOKEN, KERBEROS]
Key: SPARK-27554
URL: https://issues.apache.org/jira/browse/SPARK-27554
[
https://issues.apache.org/jira/browse/SPARK-24579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519956#comment-16519956
]
Jepson commented on SPARK-24579:
Very nice.
> SPIP: Standardize Optimized Data Exchange between Spark
[
https://issues.apache.org/jira/browse/SPARK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16433536#comment-16433536
]
Jepson commented on SPARK-22968:
[~apachespark] Thank you very much.
> java.lang.IllegalStateException:
[
https://issues.apache.org/jira/browse/SPARK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420215#comment-16420215
]
Jepson commented on SPARK-22968:
Adjust these parameters,keep monitor.
“request.timeout.ms“ -> (21:
[
https://issues.apache.org/jira/browse/SPARK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jepson reopened SPARK-22968:
This issue is reappear.
> java.lang.IllegalStateException: No current assignment for partition kssh-2
>
[
https://issues.apache.org/jira/browse/SPARK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jepson resolved SPARK-22968.
Resolution: Fixed
> java.lang.IllegalStateException: No current assignment for partition kssh-2
>
[
https://issues.apache.org/jira/browse/SPARK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16379639#comment-16379639
]
Jepson commented on SPARK-22968:
It's been a long time.I close it first.
>
[
https://issues.apache.org/jira/browse/SPARK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jepson updated SPARK-22968:
---
Component/s: (was: Structured Streaming)
Spark Core
> java.lang.IllegalStateException:
[
https://issues.apache.org/jira/browse/SPARK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16315552#comment-16315552
]
Jepson commented on SPARK-22968:
[~srowen] Thanks for quick response.
I turn up the parameter
[
https://issues.apache.org/jira/browse/SPARK-19547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16312505#comment-16312505
]
Jepson commented on SPARK-19547:
I have encounter this problem too.
[
https://issues.apache.org/jira/browse/SPARK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jepson updated SPARK-22968:
---
Description:
*Kafka Broker:*
{code:java}
message.max.bytes : 2621440
{code}
*Spark Streaming+Kafka
[
https://issues.apache.org/jira/browse/SPARK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jepson updated SPARK-22968:
---
Description:
*Kafka Broker:*
message.max.bytes : 2621440
*Spark Streaming+Kafka Code:*
*,
[
https://issues.apache.org/jira/browse/SPARK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jepson updated SPARK-22968:
---
Description:
CDH-KAFKA:
message.max.bytes : 2621440
, "max.partition.fetch.bytes" -> (5242880:
Jepson created SPARK-22968:
--
Summary: java.lang.IllegalStateException: No current assignment
for partition kssh-2
Key: SPARK-22968
URL: https://issues.apache.org/jira/browse/SPARK-22968
Project: Spark
[
https://issues.apache.org/jira/browse/SPARK-21733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16136668#comment-16136668
]
Jepson edited comment on SPARK-21733 at 8/22/17 11:57 AM:
--
I add this parameter
[
https://issues.apache.org/jira/browse/SPARK-21733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16136668#comment-16136668
]
Jepson edited comment on SPARK-21733 at 8/22/17 11:40 AM:
--
I add this parameter
[
https://issues.apache.org/jira/browse/SPARK-21733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16136668#comment-16136668
]
Jepson commented on SPARK-21733:
I add this parameter of "spark.network.timeout=42". And I test this,
[
https://issues.apache.org/jira/browse/SPARK-21733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16136478#comment-16136478
]
Jepson edited comment on SPARK-21733 at 8/22/17 7:57 AM:
-
[~jerryshao] Sorry,
[
https://issues.apache.org/jira/browse/SPARK-21733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16136478#comment-16136478
]
Jepson commented on SPARK-21733:
[~jerryshao] Sorry, I'll pay attention next time.
I check the log
[
https://issues.apache.org/jira/browse/SPARK-21733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16136400#comment-16136400
]
Jepson edited comment on SPARK-21733 at 8/22/17 7:47 AM:
-
[~jerryshao] Thanks
[
https://issues.apache.org/jira/browse/SPARK-21733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16136400#comment-16136400
]
Jepson edited comment on SPARK-21733 at 8/22/17 7:18 AM:
-
[~jerryshao] Thanks
[
https://issues.apache.org/jira/browse/SPARK-21733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16136400#comment-16136400
]
Jepson edited comment on SPARK-21733 at 8/22/17 6:44 AM:
-
[~jerryshao] Thanks
[
https://issues.apache.org/jira/browse/SPARK-21733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16136400#comment-16136400
]
Jepson commented on SPARK-21733:
[~jerryshao] the spark streaming with kafka scala code :
[
https://issues.apache.org/jira/browse/SPARK-21733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16136260#comment-16136260
]
Jepson edited comment on SPARK-21733 at 8/22/17 4:32 AM:
-
*The nodemanager log
[
https://issues.apache.org/jira/browse/SPARK-21733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16136260#comment-16136260
]
Jepson edited comment on SPARK-21733 at 8/22/17 4:29 AM:
-
*The nodemanager log
[
https://issues.apache.org/jira/browse/SPARK-21733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16136260#comment-16136260
]
Jepson commented on SPARK-21733:
*The nodemanager log detail:*
{code:java}
2017-08-22 11:20:07,984
[
https://issues.apache.org/jira/browse/SPARK-21733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jepson updated SPARK-21733:
---
Comment: was deleted
(was: I have resolve this issue.Thanks for [~jerryshao] and [~srowen]
spark-submit \
[
https://issues.apache.org/jira/browse/SPARK-21733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jepson updated SPARK-21733:
---
Comment: was deleted
(was: [~sowen], thank you for correcting me, I will notice it at the next time.)
>
[
https://issues.apache.org/jira/browse/SPARK-21733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jepson reopened SPARK-21733:
*This error is happening again.*
> ERROR executor.CoarseGrainedExecutorBackend: RECEIVED SIGNAL TERM
>
[
https://issues.apache.org/jira/browse/SPARK-21733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16126978#comment-16126978
]
Jepson commented on SPARK-21733:
[~sowen], thank you for correcting me, I will notice it at the next
[
https://issues.apache.org/jira/browse/SPARK-21733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jepson resolved SPARK-21733.
Resolution: Fixed
Fix Version/s: 2.1.1
> ERROR executor.CoarseGrainedExecutorBackend: RECEIVED
[
https://issues.apache.org/jira/browse/SPARK-21733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16126970#comment-16126970
]
Jepson commented on SPARK-21733:
I have resolve this issue.Thanks for [~jerryshao] and [~srowen]
[
https://issues.apache.org/jira/browse/SPARK-21733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jepson updated SPARK-21733:
---
Description:
Kafka+Spark streaming ,throw these error:
{code:java}
17/08/15 09:34:14 INFO
[
https://issues.apache.org/jira/browse/SPARK-21733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jepson updated SPARK-21733:
---
Description:
Kafka+Spark streaming ,throw these error:
{code:java}
17/08/15 09:34:14 INFO
Jepson created SPARK-21733:
--
Summary: ERROR executor.CoarseGrainedExecutorBackend: RECEIVED
SIGNAL TERM
Key: SPARK-21733
URL: https://issues.apache.org/jira/browse/SPARK-21733
Project: Spark
Issue
38 matches
Mail list logo
