[
https://issues.apache.org/jira/browse/SPARK-30952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
bruce_zhao updated SPARK-30952:
---
Description:
We are trying to apply three-sigma rule in grouped data to detect anomaly data.
We fou
bruce_zhao created SPARK-30952:
--
Summary: Grouped pandas_udf crashed when a group returned an empty
DataFrame
Key: SPARK-30952
URL: https://issues.apache.org/jira/browse/SPARK-30952
Project: Spark
[
https://issues.apache.org/jira/browse/SPARK-24970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
bruce_zhao updated SPARK-24970:
---
Description:
We're using Spark streaming to consume Kinesis data, and found that it reads
more d
[
https://issues.apache.org/jira/browse/SPARK-24970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
bruce_zhao updated SPARK-24970:
---
Description:
We're using Spark streaming to consume Kinesis data, and found that it reads
more d
[
https://issues.apache.org/jira/browse/SPARK-24970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
bruce_zhao updated SPARK-24970:
---
Description:
We're using Spark streaming to consume Kinesis data, and found that it reads
more d
bruce_zhao created SPARK-24970:
--
Summary: Spark Kinesis streaming application fails to recover from
streaming checkpoint due to ProvisionedThroughputExceededException
Key: SPARK-24970
URL: https://issues.apache.org/j
[
https://issues.apache.org/jira/browse/SPARK-18620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16470069#comment-16470069
]
bruce_zhao commented on SPARK-18620:
This PR makes the input rate flat, but the limit
