[jira] [Commented] (BEAM-261) Apache Apex Runner

[ https://issues.apache.org/jira/browse/BEAM-261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433981#comment-15433981 ] ASF GitHub Bot commented on BEAM-261: - GitHub user tweise reopened a pull request:

[jira] [Commented] (BEAM-574) KafkaIO prints superfluous information

[ https://issues.apache.org/jira/browse/BEAM-574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15434057#comment-15434057 ] ASF GitHub Bot commented on BEAM-574: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-578) Update FileBasedSource so that implementations can control whether the source gets split into ranges

[ https://issues.apache.org/jira/browse/BEAM-578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15434136#comment-15434136 ] ASF GitHub Bot commented on BEAM-578: - Github user chamikaramj closed the pull request a

[jira] [Commented] (BEAM-242) Enable Checkstyle check and Javadoc build for the Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435049#comment-15435049 ] ASF GitHub Bot commented on BEAM-242: - GitHub user jbonofre opened a pull request:

[jira] [Commented] (BEAM-383) BigQueryIO: update sink to shard into multiple write jobs

[ https://issues.apache.org/jira/browse/BEAM-383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435276#comment-15435276 ] ASF GitHub Bot commented on BEAM-383: - GitHub user dhalperi opened a pull request:

[jira] [Commented] (BEAM-582) Allow usage of the new GCP service account JSON key

[ https://issues.apache.org/jira/browse/BEAM-582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435641#comment-15435641 ] ASF GitHub Bot commented on BEAM-582: - GitHub user alexvanboxel opened a pull request:

[jira] [Commented] (BEAM-383) BigQueryIO: update sink to shard into multiple write jobs

[ https://issues.apache.org/jira/browse/BEAM-383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435869#comment-15435869 ] ASF GitHub Bot commented on BEAM-383: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-294) Change properties named dataflow.* to beam.*

[ https://issues.apache.org/jira/browse/BEAM-294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15436761#comment-15436761 ] ASF GitHub Bot commented on BEAM-294: - GitHub user jbonofre opened a pull request:

[jira] [Commented] (BEAM-545) Pipelines and their executions naming changes

[ https://issues.apache.org/jira/browse/BEAM-545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437634#comment-15437634 ] ASF GitHub Bot commented on BEAM-545: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-498) Make DoFnWithContext the new DoFn

[ https://issues.apache.org/jira/browse/BEAM-498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437769#comment-15437769 ] ASF GitHub Bot commented on BEAM-498: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-362) Move shared runner functionality out of SDK and into runners/core-java

[ https://issues.apache.org/jira/browse/BEAM-362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437790#comment-15437790 ] ASF GitHub Bot commented on BEAM-362: - GitHub user kennknowles opened a pull request:

[jira] [Commented] (BEAM-589) Making IO.Read transformations to extend PTransform>

[ https://issues.apache.org/jira/browse/BEAM-589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438174#comment-15438174 ] ASF GitHub Bot commented on BEAM-589: - GitHub user gauravgopi123 opened a pull request:

[jira] [Commented] (BEAM-79) Gearpump runner

[ https://issues.apache.org/jira/browse/BEAM-79?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438364#comment-15438364 ] ASF GitHub Bot commented on BEAM-79: Github user manuzhang closed the pull request at:

[jira] [Commented] (BEAM-294) Change properties named dataflow.* to beam.*

[ https://issues.apache.org/jira/browse/BEAM-294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438622#comment-15438622 ] ASF GitHub Bot commented on BEAM-294: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-579) Integrate NamedAggregators into Spark's sink system

[ https://issues.apache.org/jira/browse/BEAM-579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438757#comment-15438757 ] ASF GitHub Bot commented on BEAM-579: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-589) Making IO.Read transformations to extend PTransform>

[ https://issues.apache.org/jira/browse/BEAM-589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439383#comment-15439383 ] ASF GitHub Bot commented on BEAM-589: - Github user gauravgopi123 closed the pull request

[jira] [Commented] (BEAM-589) Making IO.Read transformations to extend PTransform>

[ https://issues.apache.org/jira/browse/BEAM-589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439384#comment-15439384 ] ASF GitHub Bot commented on BEAM-589: - GitHub user gauravgopi123 reopened a pull request

[jira] [Commented] (BEAM-589) Making IO.Read transformations to extend PTransform>

[ https://issues.apache.org/jira/browse/BEAM-589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439523#comment-15439523 ] ASF GitHub Bot commented on BEAM-589: - GitHub user gauravgopi123 reopened a pull request

[jira] [Commented] (BEAM-589) Making IO.Read transformations to extend PTransform>

[ https://issues.apache.org/jira/browse/BEAM-589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439522#comment-15439522 ] ASF GitHub Bot commented on BEAM-589: - Github user gauravgopi123 closed the pull request

[jira] [Commented] (BEAM-589) Making IO.Read transformations to extend PTransform>

[ https://issues.apache.org/jira/browse/BEAM-589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439546#comment-15439546 ] ASF GitHub Bot commented on BEAM-589: - Github user gauravgopi123 closed the pull request

[jira] [Commented] (BEAM-589) Making IO.Read transformations to extend PTransform>

[ https://issues.apache.org/jira/browse/BEAM-589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439817#comment-15439817 ] ASF GitHub Bot commented on BEAM-589: - GitHub user gauravgopi123 reopened a pull request

[jira] [Commented] (BEAM-572) Remove Spark references in WordCount

[ https://issues.apache.org/jira/browse/BEAM-572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439839#comment-15439839 ] ASF GitHub Bot commented on BEAM-572: - GitHub user markflyhigh opened a pull request:

[jira] [Commented] (BEAM-592) StackOverflowError Failed example/java/WordCount When Using SparkRunner

[ https://issues.apache.org/jira/browse/BEAM-592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439893#comment-15439893 ] ASF GitHub Bot commented on BEAM-592: - GitHub user markflyhigh opened a pull request:

[jira] [Commented] (BEAM-473) DatastoreIO querying latest timestamp statistics doesn't work with namespace

[ https://issues.apache.org/jira/browse/BEAM-473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15440006#comment-15440006 ] ASF GitHub Bot commented on BEAM-473: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-589) Making IO.Read transformations to extend PTransform>

[ https://issues.apache.org/jira/browse/BEAM-589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15440105#comment-15440105 ] ASF GitHub Bot commented on BEAM-589: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-461) Create custom Kinesis source

[ https://issues.apache.org/jira/browse/BEAM-461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15440150#comment-15440150 ] ASF GitHub Bot commented on BEAM-461: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-598) GearpumpRunner depends on SNAPSHOT jar that has since been released and deleted

[ https://issues.apache.org/jira/browse/BEAM-598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15440338#comment-15440338 ] ASF GitHub Bot commented on BEAM-598: - Github user dhalperi closed the pull request at:

[jira] [Commented] (BEAM-598) GearpumpRunner depends on SNAPSHOT jar that has since been released and deleted

[ https://issues.apache.org/jira/browse/BEAM-598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15440339#comment-15440339 ] ASF GitHub Bot commented on BEAM-598: - GitHub user dhalperi reopened a pull request:

[jira] [Commented] (BEAM-598) GearpumpRunner depends on SNAPSHOT jar that has since been released and deleted

[ https://issues.apache.org/jira/browse/BEAM-598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15440343#comment-15440343 ] ASF GitHub Bot commented on BEAM-598: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-65) SplittableDoFn

[ https://issues.apache.org/jira/browse/BEAM-65?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15440438#comment-15440438 ] ASF GitHub Bot commented on BEAM-65: GitHub user jkff opened a pull request: https:/

[jira] [Commented] (BEAM-584) Support Verifiers in TestSparkRunner

[ https://issues.apache.org/jira/browse/BEAM-584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15441116#comment-15441116 ] ASF GitHub Bot commented on BEAM-584: - GitHub user aviemzur opened a pull request:

[jira] [Commented] (BEAM-592) StackOverflowError Failed example/java/WordCount When Using SparkRunner

[ https://issues.apache.org/jira/browse/BEAM-592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15441143#comment-15441143 ] ASF GitHub Bot commented on BEAM-592: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-569) JMS IO should set maxNumRecords to Long.MAX_VALUE by default

[ https://issues.apache.org/jira/browse/BEAM-569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15441377#comment-15441377 ] ASF GitHub Bot commented on BEAM-569: - GitHub user jbonofre opened a pull request:

[jira] [Commented] (BEAM-599) Return KafkaIO getWatermark log in debug mode

[ https://issues.apache.org/jira/browse/BEAM-599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15443073#comment-15443073 ] ASF GitHub Bot commented on BEAM-599: - GitHub user aviemzur opened a pull request:

[jira] [Commented] (BEAM-15) Applying windowing to cached RDDs fails

[ https://issues.apache.org/jira/browse/BEAM-15?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15443503#comment-15443503 ] ASF GitHub Bot commented on BEAM-15: GitHub user staslev opened a pull request: http

[jira] [Commented] (BEAM-600) Add TestCountingSource option to specify the number of splits returned by generateInitialSplits

[ https://issues.apache.org/jira/browse/BEAM-600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15444075#comment-15444075 ] ASF GitHub Bot commented on BEAM-600: - GitHub user drieber opened a pull request: h

[jira] [Commented] (BEAM-313) Enable the use of an existing spark context with the SparkPipelineRunner

[ https://issues.apache.org/jira/browse/BEAM-313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445668#comment-15445668 ] ASF GitHub Bot commented on BEAM-313: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-587) Update KafkaIO to take advantage of Dofn Setup/Teardown

[ https://issues.apache.org/jira/browse/BEAM-587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15446935#comment-15446935 ] ASF GitHub Bot commented on BEAM-587: - GitHub user rangadi opened a pull request: h

[jira] [Commented] (BEAM-473) DatastoreIO querying latest timestamp statistics doesn't work with namespace

[ https://issues.apache.org/jira/browse/BEAM-473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15447033#comment-15447033 ] ASF GitHub Bot commented on BEAM-473: - GitHub user vikkyrk opened a pull request: h

[jira] [Commented] (BEAM-548) Combine$PerKeyWithHotKeyFanout should propagate Display Data

[ https://issues.apache.org/jira/browse/BEAM-548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15447307#comment-15447307 ] ASF GitHub Bot commented on BEAM-548: - GitHub user swegner opened a pull request: h

[jira] [Commented] (BEAM-572) Remove Spark references in WordCount

[ https://issues.apache.org/jira/browse/BEAM-572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15447529#comment-15447529 ] ASF GitHub Bot commented on BEAM-572: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-599) Return KafkaIO getWatermark log in debug mode

[ https://issues.apache.org/jira/browse/BEAM-599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15447533#comment-15447533 ] ASF GitHub Bot commented on BEAM-599: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-587) Update KafkaIO to take advantage of Dofn Setup/Teardown

[ https://issues.apache.org/jira/browse/BEAM-587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15447976#comment-15447976 ] ASF GitHub Bot commented on BEAM-587: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-569) JMS IO should set maxNumRecords to Long.MAX_VALUE by default

[ https://issues.apache.org/jira/browse/BEAM-569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449947#comment-15449947 ] ASF GitHub Bot commented on BEAM-569: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-610) Enable spark's checkpointing mechanism for driver-failure recovery in streaming

[ https://issues.apache.org/jira/browse/BEAM-610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15453099#comment-15453099 ] ASF GitHub Bot commented on BEAM-610: - GitHub user amitsela opened a pull request:

[jira] [Commented] (BEAM-308) PipelineOptions throws when using package-private PipelineOptions interfaces from multiple packages

[ https://issues.apache.org/jira/browse/BEAM-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15456510#comment-15456510 ] ASF GitHub Bot commented on BEAM-308: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-535) Cloud Datastore naming clean-up

[ https://issues.apache.org/jira/browse/BEAM-535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15456520#comment-15456520 ] ASF GitHub Bot commented on BEAM-535: - Github user vikkyrk closed the pull request at:

[jira] [Commented] (BEAM-535) Cloud Datastore naming clean-up

[ https://issues.apache.org/jira/browse/BEAM-535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15456534#comment-15456534 ] ASF GitHub Bot commented on BEAM-535: - GitHub user vikkyrk opened a pull request: h

[jira] [Commented] (BEAM-577) Update filebasedsource to support compressed files

[ https://issues.apache.org/jira/browse/BEAM-577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15456740#comment-15456740 ] ASF GitHub Bot commented on BEAM-577: - GitHub user sbilac opened a pull request: ht

[jira] [Commented] (BEAM-473) DatastoreIO querying latest timestamp statistics doesn't work with namespace

[ https://issues.apache.org/jira/browse/BEAM-473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15456981#comment-15456981 ] ASF GitHub Bot commented on BEAM-473: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-535) Cloud Datastore naming clean-up

[ https://issues.apache.org/jira/browse/BEAM-535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15457005#comment-15457005 ] ASF GitHub Bot commented on BEAM-535: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-548) Combine$PerKeyWithHotKeyFanout should propagate Display Data

[ https://issues.apache.org/jira/browse/BEAM-548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15459123#comment-15459123 ] ASF GitHub Bot commented on BEAM-548: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-362) Move shared runner functionality out of SDK and into runners/core-java

[ https://issues.apache.org/jira/browse/BEAM-362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15459157#comment-15459157 ] ASF GitHub Bot commented on BEAM-362: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-604) Use Watermark Check Streaming Job Finish in DataflowPipelineJob

[ https://issues.apache.org/jira/browse/BEAM-604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15459547#comment-15459547 ] ASF GitHub Bot commented on BEAM-604: - GitHub user markflyhigh opened a pull request:

[jira] [Commented] (BEAM-600) Add TestCountingSource option to specify the number of splits returned by generateInitialSplits

[ https://issues.apache.org/jira/browse/BEAM-600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15461465#comment-15461465 ] ASF GitHub Bot commented on BEAM-600: - Github user drieber closed the pull request at:

[jira] [Commented] (BEAM-456) Add MongoDBIO

[ https://issues.apache.org/jira/browse/BEAM-456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15463423#comment-15463423 ] ASF GitHub Bot commented on BEAM-456: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-383) BigQueryIO: update sink to shard into multiple write jobs

[ https://issues.apache.org/jira/browse/BEAM-383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15463597#comment-15463597 ] ASF GitHub Bot commented on BEAM-383: - GitHub user dhalperi opened a pull request:

[jira] [Commented] (BEAM-102) Side Inputs for Streaming

[ https://issues.apache.org/jira/browse/BEAM-102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15464751#comment-15464751 ] ASF GitHub Bot commented on BEAM-102: - GitHub user mxm opened a pull request: https

[jira] [Commented] (BEAM-242) Enable Checkstyle check and Javadoc build for the Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15465279#comment-15465279 ] ASF GitHub Bot commented on BEAM-242: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-544) Add header/footer support to TextIO.Write

[ https://issues.apache.org/jira/browse/BEAM-544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15465632#comment-15465632 ] ASF GitHub Bot commented on BEAM-544: - GitHub user staslev opened a pull request: h

[jira] [Commented] (BEAM-242) Enable Checkstyle check and Javadoc build for the Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15466509#comment-15466509 ] ASF GitHub Bot commented on BEAM-242: - GitHub user jbonofre opened a pull request:

[jira] [Commented] (BEAM-553) Add a custom text source

[ https://issues.apache.org/jira/browse/BEAM-553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15466569#comment-15466569 ] ASF GitHub Bot commented on BEAM-553: - GitHub user chamikaramj opened a pull request:

[jira] [Commented] (BEAM-617) Allow setting of StateBackend on FlinkPipelineOptions

[ https://issues.apache.org/jira/browse/BEAM-617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15467538#comment-15467538 ] ASF GitHub Bot commented on BEAM-617: - GitHub user mxm opened a pull request: https

[jira] [Commented] (BEAM-333) Support "stop" for streaming pipelines

[ https://issues.apache.org/jira/browse/BEAM-333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15467566#comment-15467566 ] ASF GitHub Bot commented on BEAM-333: - GitHub user mxm opened a pull request: https

[jira] [Commented] (BEAM-383) BigQueryIO: update sink to shard into multiple write jobs

[ https://issues.apache.org/jira/browse/BEAM-383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15468151#comment-15468151 ] ASF GitHub Bot commented on BEAM-383: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-577) Update filebasedsource to support compressed files

[ https://issues.apache.org/jira/browse/BEAM-577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15468784#comment-15468784 ] ASF GitHub Bot commented on BEAM-577: - Github user sbilac closed the pull request at:

[jira] [Commented] (BEAM-242) Enable Checkstyle check and Javadoc build for the Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15469466#comment-15469466 ] ASF GitHub Bot commented on BEAM-242: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-619) UnboundedSourceWrapper snapshotting fails with IndexOutOfBoundsException

[ https://issues.apache.org/jira/browse/BEAM-619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15470326#comment-15470326 ] ASF GitHub Bot commented on BEAM-619: - GitHub user mxm opened a pull request: https

[jira] [Commented] (BEAM-15) Applying windowing to cached RDDs fails

[ https://issues.apache.org/jira/browse/BEAM-15?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15470961#comment-15470961 ] ASF GitHub Bot commented on BEAM-15: Github user staslev closed the pull request at:

[jira] [Commented] (BEAM-603) Update python sdk README examples

[ https://issues.apache.org/jira/browse/BEAM-603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15471877#comment-15471877 ] ASF GitHub Bot commented on BEAM-603: - Github user mariapython closed the pull request a

[jira] [Commented] (BEAM-544) Add header/footer support to TextIO.Write

[ https://issues.apache.org/jira/browse/BEAM-544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15472015#comment-15472015 ] ASF GitHub Bot commented on BEAM-544: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-493) All Runners Run WordCount in Precommit

[ https://issues.apache.org/jira/browse/BEAM-493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1547#comment-1547 ] ASF GitHub Bot commented on BEAM-493: - GitHub user jasonkuster opened a pull request:

[jira] [Commented] (BEAM-620) DataflowPipelineJob IllegalArgumentException from time underflow

[ https://issues.apache.org/jira/browse/BEAM-620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15472879#comment-15472879 ] ASF GitHub Bot commented on BEAM-620: - GitHub user dhalperi opened a pull request:

[jira] [Commented] (BEAM-102) Side Inputs for Streaming

[ https://issues.apache.org/jira/browse/BEAM-102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15474155#comment-15474155 ] ASF GitHub Bot commented on BEAM-102: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-544) Add header/footer support to TextIO.Write

[ https://issues.apache.org/jira/browse/BEAM-544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15474468#comment-15474468 ] ASF GitHub Bot commented on BEAM-544: - Github user lukecwik closed the pull request at:

[jira] [Commented] (BEAM-544) Add header/footer support to TextIO.Write

[ https://issues.apache.org/jira/browse/BEAM-544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15474476#comment-15474476 ] ASF GitHub Bot commented on BEAM-544: - GitHub user lukecwik reopened a pull request:

[jira] [Commented] (BEAM-544) Add header/footer support to TextIO.Write

[ https://issues.apache.org/jira/browse/BEAM-544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15474559#comment-15474559 ] ASF GitHub Bot commented on BEAM-544: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-618) Python SDKs writes non RFC compliant JSON files for BQ Export

[ https://issues.apache.org/jira/browse/BEAM-618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15475447#comment-15475447 ] ASF GitHub Bot commented on BEAM-618: - GitHub user ajamato opened a pull request: h

[jira] [Commented] (BEAM-618) Python SDKs writes non RFC compliant JSON files for BQ Export

[ https://issues.apache.org/jira/browse/BEAM-618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15475458#comment-15475458 ] ASF GitHub Bot commented on BEAM-618: - Github user ajamato closed the pull request at:

[jira] [Commented] (BEAM-620) DataflowPipelineJob IllegalArgumentException from time underflow

[ https://issues.apache.org/jira/browse/BEAM-620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15475500#comment-15475500 ] ASF GitHub Bot commented on BEAM-620: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-617) Allow setting of StateBackend on FlinkPipelineOptions

[ https://issues.apache.org/jira/browse/BEAM-617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15477127#comment-15477127 ] ASF GitHub Bot commented on BEAM-617: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-333) Support "stop" for streaming pipelines

[ https://issues.apache.org/jira/browse/BEAM-333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15477146#comment-15477146 ] ASF GitHub Bot commented on BEAM-333: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-619) UnboundedSourceWrapper snapshotting fails with IndexOutOfBoundsException

[ https://issues.apache.org/jira/browse/BEAM-619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15477147#comment-15477147 ] ASF GitHub Bot commented on BEAM-619: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-624) NoClassDefFoundError Failed Dataflow Streaming Job

[ https://issues.apache.org/jira/browse/BEAM-624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15477705#comment-15477705 ] ASF GitHub Bot commented on BEAM-624: - GitHub user markflyhigh opened a pull request:

[jira] [Commented] (BEAM-624) NoClassDefFoundError Failed Dataflow Streaming Job

[ https://issues.apache.org/jira/browse/BEAM-624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15478121#comment-15478121 ] ASF GitHub Bot commented on BEAM-624: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-584) Support Verifiers in TestSparkRunner

[ https://issues.apache.org/jira/browse/BEAM-584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15479450#comment-15479450 ] ASF GitHub Bot commented on BEAM-584: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-626) AvroCoder not deserializing correctly in Kryo

[ https://issues.apache.org/jira/browse/BEAM-626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15481574#comment-15481574 ] ASF GitHub Bot commented on BEAM-626: - GitHub user aviemzur opened a pull request:

[jira] [Commented] (BEAM-244) Create JDBC IO

[ https://issues.apache.org/jira/browse/BEAM-244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15482234#comment-15482234 ] ASF GitHub Bot commented on BEAM-244: - GitHub user jbonofre opened a pull request:

[jira] [Commented] (BEAM-627) Set Spark master only if not set.

[ https://issues.apache.org/jira/browse/BEAM-627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15483440#comment-15483440 ] ASF GitHub Bot commented on BEAM-627: - GitHub user amitsela opened a pull request:

[jira] [Commented] (BEAM-627) Set Spark master only if not set.

[ https://issues.apache.org/jira/browse/BEAM-627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15483530#comment-15483530 ] ASF GitHub Bot commented on BEAM-627: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-628) Sink class org.apache.beam.runners.spark.aggregators.metrics.sink.GraphiteSink cannot be instantiated

[ https://issues.apache.org/jira/browse/BEAM-628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15483759#comment-15483759 ] ASF GitHub Bot commented on BEAM-628: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-625) Make Dataflow Python Materialized PCollection representation more efficient

[ https://issues.apache.org/jira/browse/BEAM-625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15484680#comment-15484680 ] ASF GitHub Bot commented on BEAM-625: - GitHub user katsiapis opened a pull request:

[jira] [Commented] (BEAM-618) Python SDKs writes non RFC compliant JSON files for BQ Export

[ https://issues.apache.org/jira/browse/BEAM-618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15484968#comment-15484968 ] ASF GitHub Bot commented on BEAM-618: - GitHub user ajamato opened a pull request: h

[jira] [Commented] (BEAM-625) Make Dataflow Python Materialized PCollection representation more efficient

[ https://issues.apache.org/jira/browse/BEAM-625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15485777#comment-15485777 ] ASF GitHub Bot commented on BEAM-625: - Github user katsiapis closed the pull request at:

[jira] [Commented] (BEAM-79) Gearpump runner

[ https://issues.apache.org/jira/browse/BEAM-79?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15487529#comment-15487529 ] ASF GitHub Bot commented on BEAM-79: Github user manuzhang closed the pull request at:

[jira] [Commented] (BEAM-625) Make Dataflow Python Materialized PCollection representation more efficient

[ https://issues.apache.org/jira/browse/BEAM-625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15487766#comment-15487766 ] ASF GitHub Bot commented on BEAM-625: - Github user katsiapis closed the pull request at:

[jira] [Commented] (BEAM-436) DirectRunner RunnableOnService tempLocation configuration insufficient

[ https://issues.apache.org/jira/browse/BEAM-436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15488207#comment-15488207 ] ASF GitHub Bot commented on BEAM-436: - Github user swegner closed the pull request at:

[jira] [Commented] (BEAM-630) DataflowRunnableOnService test suite is broken

[ https://issues.apache.org/jira/browse/BEAM-630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15488470#comment-15488470 ] ASF GitHub Bot commented on BEAM-630: - GitHub user jkff opened a pull request: http

[jira] [Commented] (BEAM-630) DataflowRunnableOnService test suite is broken

[ https://issues.apache.org/jira/browse/BEAM-630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15488494#comment-15488494 ] ASF GitHub Bot commented on BEAM-630: - GitHub user jkff opened a pull request: http

[jira] [Commented] (BEAM-630) DataflowRunnableOnService test suite is broken

[ https://issues.apache.org/jira/browse/BEAM-630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15488859#comment-15488859 ] ASF GitHub Bot commented on BEAM-630: - Github user asfgit closed the pull request at:

<    2   3   4   5   6   7   8   9   10   11   >