[jira] [Commented] (SPARK-18804) Join doesn't work in Spark on Bigger tables

[ https://issues.apache.org/jira/browse/SPARK-18804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15741842#comment-15741842 ] Sreelal S L commented on SPARK-18804: - Can u check the Job Dag UI and check what joi

[jira] [Closed] (SPARK-17842) Thread and memory leak in WindowDstream (UnionRDD ) when parallelPartition computation gets enabled.

[ https://issues.apache.org/jira/browse/SPARK-17842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sreelal S L closed SPARK-17842. --- > Thread and memory leak in WindowDstream (UnionRDD ) when parallelPartition > computation gets enabled.

[jira] [Commented] (SPARK-17842) Thread and memory leak in WindowDstream (UnionRDD ) when parallelPartition computation gets enabled.

[ https://issues.apache.org/jira/browse/SPARK-17842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15604420#comment-15604420 ] Sreelal S L commented on SPARK-17842: - Upgraded to 2.0.1. The leak is not observed .

[jira] [Commented] (SPARK-17842) Thread and memory leak in WindowDstream (UnionRDD ) when parallelPartition computation gets enabled.

[ https://issues.apache.org/jira/browse/SPARK-17842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15561793#comment-15561793 ] Sreelal S L commented on SPARK-17842: - Hi [~lwlin] , Checked that pull request . Fix

[jira] [Commented] (SPARK-17842) Thread and memory leak in WindowDstream (UnionRDD ) when parallelPartition computation gets enabled.

[ https://issues.apache.org/jira/browse/SPARK-17842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15561778#comment-15561778 ] Sreelal S L commented on SPARK-17842: - SparkStreaming’s Window internally uses Unio

[jira] [Issue Comment Deleted] (SPARK-17842) Thread and memory leak in WindowDstream (UnionRDD ) when parallelPartition computation gets enabled.

[ https://issues.apache.org/jira/browse/SPARK-17842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sreelal S L updated SPARK-17842: Comment: was deleted (was: SparkStreaming’s Window internally uses UnionRDD to merge all the RDD

[jira] [Created] (SPARK-17842) Thread and memory leak in WindowDstream (UnionRDD ) when parallelPartition computation gets enabled.

Sreelal S L created SPARK-17842: --- Summary: Thread and memory leak in WindowDstream (UnionRDD ) when parallelPartition computation gets enabled. Key: SPARK-17842 URL: https://issues.apache.org/jira/browse/SPARK-1784

[jira] [Commented] (SPARK-17621) Accumulator value is doubled when using DataFrame.orderBy()

[ https://issues.apache.org/jira/browse/SPARK-17621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15509301#comment-15509301 ] Sreelal S L commented on SPARK-17621: - Hi. Our actual code is bit different from wh

[jira] [Commented] (SPARK-17621) Accumulator value is doubled when using DataFrame.orderBy()

[ https://issues.apache.org/jira/browse/SPARK-17621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15509213#comment-15509213 ] Sreelal S L commented on SPARK-17621: - Hi Sean, Thanks for your quick reply. I didn

[jira] [Created] (SPARK-17621) Accumulator value is doubled when using DataFrame.orderBy()

Sreelal S L created SPARK-17621: --- Summary: Accumulator value is doubled when using DataFrame.orderBy() Key: SPARK-17621 URL: https://issues.apache.org/jira/browse/SPARK-17621 Project: Spark Is

[jira] [Closed] (SPARK-14701) checkpointWriter is stopped before eventLoop. Hence rejectedExecution exception is coming in StreamingContext.stop

[ https://issues.apache.org/jira/browse/SPARK-14701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sreelal S L closed SPARK-14701. --- Change looks good. Thanks for the quick response. Closing the issue. > checkpointWriter is stopped befo

[jira] [Created] (SPARK-14701) checkpointWriter is stopped before eventLoop. Hence rejectedExecution exception is coming in StreamingContext.stop

Sreelal S L created SPARK-14701: --- Summary: checkpointWriter is stopped before eventLoop. Hence rejectedExecution exception is coming in StreamingContext.stop Key: SPARK-14701 URL: https://issues.apache.org/jira/brow