[jira] [Commented] (SPARK-17510) Set Streaming MaxRate Independently For Multiple Streams

2016-09-14 Thread Jeff Nadler (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15491460#comment-15491460 ] Jeff Nadler commented on SPARK-17510: - That would be incredible, thank you very much for looking into

[jira] [Commented] (SPARK-17510) Set Streaming MaxRate Independently For Multiple Streams

2016-09-14 Thread Jeff Nadler (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15491412#comment-15491412 ] Jeff Nadler commented on SPARK-17510: - Well... both streams use updateStateByKey. The session one

[jira] [Commented] (SPARK-17510) Set Streaming MaxRate Independently For Multiple Streams

2016-09-14 Thread Jeff Nadler (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15491165#comment-15491165 ] Jeff Nadler commented on SPARK-17510: - Yes you're right - it's partly about differing rates but the

[jira] [Commented] (SPARK-17510) Set Streaming MaxRate Independently For Multiple Streams

2016-09-14 Thread Jeff Nadler (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15490746#comment-15490746 ] Jeff Nadler commented on SPARK-17510: - I filed SPARK-17539 for the backpressure bug. > Set

[jira] [Created] (SPARK-17539) Streaming Backpressure Starves DirectStream When Used In Combination With Receivers

2016-09-14 Thread Jeff Nadler (JIRA)
Jeff Nadler created SPARK-17539: --- Summary: Streaming Backpressure Starves DirectStream When Used In Combination With Receivers Key: SPARK-17539 URL: https://issues.apache.org/jira/browse/SPARK-17539

[jira] [Commented] (SPARK-17510) Set Streaming MaxRate Independently For Multiple Streams

2016-09-14 Thread Jeff Nadler (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15490731#comment-15490731 ] Jeff Nadler commented on SPARK-17510: - I consider this to be a separate issue from the backpressure

[jira] [Created] (SPARK-17510) Set Streaming MaxRate Independently For Multiple Streams

2016-09-12 Thread Jeff Nadler (JIRA)
Jeff Nadler created SPARK-17510: --- Summary: Set Streaming MaxRate Independently For Multiple Streams Key: SPARK-17510 URL: https://issues.apache.org/jira/browse/SPARK-17510 Project: Spark Issue

[jira] [Comment Edited] (SPARK-6613) Starting stream from checkpoint causes Streaming tab to throw error

2015-09-15 Thread Jeff Nadler (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-6613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14745596#comment-14745596 ] Jeff Nadler edited comment on SPARK-6613 at 9/15/15 3:22 PM: - I'm seeing

[jira] [Commented] (SPARK-6613) Starting stream from checkpoint causes Streaming tab to throw error

2015-09-15 Thread Jeff Nadler (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-6613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14745596#comment-14745596 ] Jeff Nadler commented on SPARK-6613: I'm seeing almost the same problem in 1.4.1.When recovering

[jira] [Commented] (SPARK-5315) reduceByWindow returns Scala DStream not JavaDStream

2015-01-19 Thread Jeff Nadler (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14282703#comment-14282703 ] Jeff Nadler commented on SPARK-5315: Thanks Jerry! I was just about to file this and