[jira] [Commented] (BEAM-5519) Spark Streaming Duplicated Encoding/Decoding Effort

2018-09-27 Thread Kyle Winkelman (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16631017#comment-16631017 ] Kyle Winkelman commented on BEAM-5519: -- Proposed: //

[jira] [Commented] (BEAM-5519) Spark Streaming Duplicated Encoding/Decoding Effort

2018-09-27 Thread Kyle Winkelman (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16631012#comment-16631012 ] Kyle Winkelman commented on BEAM-5519: -- Current: // GroupCombineFunctions.groupByKeyOnly JavaRDD>>

[jira] [Created] (BEAM-5519) Spark Streaming Duplicated Encoding/Decoding Effort

2018-09-27 Thread Kyle Winkelman (JIRA)
Kyle Winkelman created BEAM-5519: Summary: Spark Streaming Duplicated Encoding/Decoding Effort Key: BEAM-5519 URL: https://issues.apache.org/jira/browse/BEAM-5519 Project: Beam Issue Type:

[jira] [Commented] (BEAM-4783) Spark SourceRDD Not Designed With Dynamic Allocation In Mind

2018-07-26 Thread Kyle Winkelman (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558437#comment-16558437 ] Kyle Winkelman commented on BEAM-4783: -- After looking into the issue further I don't believe the

[jira] [Updated] (BEAM-4783) Spark SourceRDD Not Designed With Dynamic Allocation In Mind

2018-07-13 Thread Kyle Winkelman (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Winkelman updated BEAM-4783: - Description: When the spark-runner is used along with the configuration

[jira] [Created] (BEAM-4783) Spark SourceRDD Not Designed With Dynamic Allocation In Mind

2018-07-13 Thread Kyle Winkelman (JIRA)
Kyle Winkelman created BEAM-4783: Summary: Spark SourceRDD Not Designed With Dynamic Allocation In Mind Key: BEAM-4783 URL: https://issues.apache.org/jira/browse/BEAM-4783 Project: Beam

[jira] [Commented] (BEAM-3095) .withCompression() hinted at in docs, but not usable

2018-07-10 Thread Kyle Winkelman (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538605#comment-16538605 ] Kyle Winkelman commented on BEAM-3095: -- Can the easyfix, newbie, and starter lables be added to this?

[jira] [Commented] (BEAM-3095) .withCompression() hinted at in docs, but not usable

2018-07-10 Thread Kyle Winkelman (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538589#comment-16538589 ] Kyle Winkelman commented on BEAM-3095: --