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

[ https://issues.apache.org/jira/browse/SPARK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15499334#comment-15499334 ] Cody Koeninger commented on SPARK-17510: [~jnadler] See the pull request here htt

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

[ https://issues.apache.org/jira/browse/SPARK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15499329#comment-15499329 ] Apache Spark commented on SPARK-17510: -- User 'koeninger' has created a pull request

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

[ https://issues.apache.org/jira/browse/SPARK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15491460#comment-15491460 ] Jeff Nadler commented on SPARK-17510: - That would be incredible, thank you very much

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

[ https://issues.apache.org/jira/browse/SPARK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15491455#comment-15491455 ] Cody Koeninger commented on SPARK-17510: Ok, next time I get some free hacking ti

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

[ https://issues.apache.org/jira/browse/SPARK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15491412#comment-15491412 ] Jeff Nadler commented on SPARK-17510: - Well... both streams use updateStateByKey.

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

[ https://issues.apache.org/jira/browse/SPARK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15491389#comment-15491389 ] Cody Koeninger commented on SPARK-17510: Just for clarity's sake, compute time is

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

[ https://issues.apache.org/jira/browse/SPARK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15491165#comment-15491165 ] Jeff Nadler commented on SPARK-17510: - Yes you're right - it's partly about differin

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

[ https://issues.apache.org/jira/browse/SPARK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15491087#comment-15491087 ] Cody Koeninger commented on SPARK-17510: I use direct stream for multiple topic j

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

[ https://issues.apache.org/jira/browse/SPARK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15490746#comment-15490746 ] Jeff Nadler commented on SPARK-17510: - I filed SPARK-17539 for the backpressure bug.

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

[ https://issues.apache.org/jira/browse/SPARK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15490731#comment-15490731 ] Jeff Nadler commented on SPARK-17510: - I consider this to be a separate issue from th

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

[ https://issues.apache.org/jira/browse/SPARK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15489102#comment-15489102 ] Cody Koeninger commented on SPARK-17510: This would require a constructor change