[jira] [Commented] (BEAM-757) The SparkRunner should utilize the SDK's DoFnRunner instead of writing it's own.

2016-12-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15747054#comment-15747054 ] ASF GitHub Bot commented on BEAM-757: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-757) The SparkRunner should utilize the SDK's DoFnRunner instead of writing it's own.

2016-12-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15741480#comment-15741480 ] ASF GitHub Bot commented on BEAM-757: - GitHub user amitsela opened a pull request:

[jira] [Commented] (BEAM-757) The SparkRunner should utilize the SDK's DoFnRunner instead of writing it's own.

2016-10-24 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15602812#comment-15602812 ] Kenneth Knowles commented on BEAM-757: -- For the {{DoFn}} switch, you could open a new i

[jira] [Commented] (BEAM-757) The SparkRunner should utilize the SDK's DoFnRunner instead of writing it's own.

2016-10-24 Thread Amit Sela (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15602671#comment-15602671 ] Amit Sela commented on BEAM-757: Yeah, I've noticed that using {{KeyedWorkItem}} means that

[jira] [Commented] (BEAM-757) The SparkRunner should utilize the SDK's DoFnRunner instead of writing it's own.

2016-10-24 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15602638#comment-15602638 ] Kenneth Knowles commented on BEAM-757: -- Oh, and by the way the PR that merged that also

[jira] [Commented] (BEAM-757) The SparkRunner should utilize the SDK's DoFnRunner instead of writing it's own.

2016-10-24 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15602623#comment-15602623 ] Kenneth Knowles commented on BEAM-757: -- Also related is BEAM-788 for executing {{Reduce

[jira] [Commented] (BEAM-757) The SparkRunner should utilize the SDK's DoFnRunner instead of writing it's own.

2016-10-24 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15602617#comment-15602617 ] Kenneth Knowles commented on BEAM-757: -- I'd say you can probably go ahead with it now.

[jira] [Commented] (BEAM-757) The SparkRunner should utilize the SDK's DoFnRunner instead of writing it's own.

2016-10-24 Thread Amit Sela (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15602527#comment-15602527 ] Amit Sela commented on BEAM-757: [~kenn] should I wait for the refactor to finish ? or use

[jira] [Commented] (BEAM-757) The SparkRunner should utilize the SDK's DoFnRunner instead of writing it's own.

2016-10-18 Thread Amit Sela (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15584706#comment-15584706 ] Amit Sela commented on BEAM-757: I have something (working!) using the {{SimpleDoFnRunner}}

[jira] [Commented] (BEAM-757) The SparkRunner should utilize the SDK's DoFnRunner instead of writing it's own.

2016-10-17 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15583565#comment-15583565 ] Kenneth Knowles commented on BEAM-757: -- Just a note here that I'm going to have to refa