[jira] [Commented] (BEAM-645) Running Wordcount in Spark Checks Locally and Outputs in HDFS

2016-09-22 Thread Amit Sela (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513074#comment-15513074 ] Amit Sela commented on BEAM-645: This https://github.com/apache/incubator-beam/pull/983 shou

[jira] [Commented] (BEAM-645) Running Wordcount in Spark Checks Locally and Outputs in HDFS

2016-09-21 Thread Jesse Anderson (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510280#comment-15510280 ] Jesse Anderson commented on BEAM-645: - They may well be. We can close for now. Just need

[jira] [Commented] (BEAM-645) Running Wordcount in Spark Checks Locally and Outputs in HDFS

2016-09-21 Thread Jesse Anderson (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510270#comment-15510270 ] Jesse Anderson commented on BEAM-645: - I don't have a Flink cluster to test this on. >

[jira] [Commented] (BEAM-645) Running Wordcount in Spark Checks Locally and Outputs in HDFS

2016-09-21 Thread Amit Sela (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15509955#comment-15509955 ] Amit Sela commented on BEAM-645: [~eljefe6aa] do you run this example with other runners whe

[jira] [Commented] (BEAM-645) Running Wordcount in Spark Checks Locally and Outputs in HDFS

2016-09-20 Thread Jesse Anderson (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507582#comment-15507582 ] Jesse Anderson commented on BEAM-645: - TextIO passing the knowledge to the runner is the

[jira] [Commented] (BEAM-645) Running Wordcount in Spark Checks Locally and Outputs in HDFS

2016-09-20 Thread Amit Sela (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507498#comment-15507498 ] Amit Sela commented on BEAM-645: I think it's the other way around - TextIO is the one passi

[jira] [Commented] (BEAM-645) Running Wordcount in Spark Checks Locally and Outputs in HDFS

2016-09-20 Thread Jesse Anderson (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507437#comment-15507437 ] Jesse Anderson commented on BEAM-645: - No, it doesn't happen with {{org.apache.beam.runn

[jira] [Commented] (BEAM-645) Running Wordcount in Spark Checks Locally and Outputs in HDFS

2016-09-20 Thread Amit Sela (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507410#comment-15507410 ] Amit Sela commented on BEAM-645: Does this happen with the SDKs example or the WordCount exa