[jira] [Commented] (BEAM-156) Implement Quiescence Signalling in the InProcessPipelineRunner

[ https://issues.apache.org/jira/browse/BEAM-156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15399854#comment-15399854 ] ASF GitHub Bot commented on BEAM-156: - 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=15414276#comment-15414276 ] ASF GitHub Bot commented on BEAM-498: - GitHub user kennknowles opened a pull request:

[jira] [Commented] (BEAM-534) README.md contains dead link

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

[jira] [Commented] (BEAM-540) Dataflow streaming jobs running on windmill do not need data disks

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

[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=15414321#comment-15414321 ] ASF GitHub Bot commented on BEAM-498: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-396) Coder.NonDeterministicException doesn't inherit from Exception

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

[jira] [Commented] (BEAM-176) Enable FindBugs static analysis during maven build

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

[jira] [Commented] (BEAM-395) KafkaIO tests should be marked 'NeedsRunner'

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

[jira] [Commented] (BEAM-142) BigQueryIO: don't unnecessarily initialize an ExecutorService to validate parameters

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

[jira] [Commented] (BEAM-355) Update to Bigtable version 0.3.0

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

[jira] [Commented] (BEAM-403) Support staging SDK packages from PyPI for remote execution

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

[jira] [Commented] (BEAM-390) Update spark runner to use spark version 1.6.2

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

[jira] [Commented] (BEAM-411) Avoid calling BigQuery directly during validation.

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

[jira] [Commented] (BEAM-191) Remove WindowedValue.valueInEmptyWindows

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

[jira] [Commented] (BEAM-395) KafkaIO tests should be marked 'NeedsRunner'

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

[jira] [Commented] (BEAM-392) Update flink runner to use flink version 1.0.3

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

[jira] [Commented] (BEAM-390) Update spark dependency to the most recent stable version

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

[jira] [Commented] (BEAM-387) Remove internal file and fix gcsio code path

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

[jira] [Commented] (BEAM-393) Add code snippets for custom sources, custom sinks, and side inputs

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

[jira] [Commented] (BEAM-389) DelegateCoder needs equals and hashCode

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

[jira] [Commented] (BEAM-368) Add getSplitPointsConsumed() to ByteKeyRangeTracker

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

[jira] [Commented] (BEAM-386) Dataflow runner to support Read.Bounded in streaming mode.

[ https://issues.apache.org/jira/browse/BEAM-386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15356561#comment-15356561 ] ASF GitHub Bot commented on BEAM-386: - 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=15359697#comment-15359697 ] ASF GitHub Bot commented on BEAM-362: - GitHub user kennknowles opened a pull request:

[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=15359705#comment-15359705 ] ASF GitHub Bot commented on BEAM-362: - GitHub user kennknowles opened a pull request:

[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=15359706#comment-15359706 ] ASF GitHub Bot commented on BEAM-362: - Github user kennknowles 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=15359746#comment-15359746 ] ASF GitHub Bot commented on BEAM-362: - Github user kennknowles closed the pull request at:

[jira] [Commented] (BEAM-422) AvroSource hits various IOException when using Snappy codec

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

[jira] [Commented] (BEAM-416) Jenkins Python Verify post commit tests are timing out

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

[jira] [Commented] (BEAM-416) Jenkins Python Verify post commit tests are timing out

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

[jira] [Commented] (BEAM-77) Reorganize Directory structure

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

[jira] [Commented] (BEAM-354) Modify DatastoreIO to use Datastore v1beta3 API

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

[jira] [Commented] (BEAM-405) BigQueryIO$StreamingWriteFn uses inefficient keySet iterator

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

[jira] [Commented] (BEAM-338) Fix licensing and usage of gutenberg files in Spark test

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

[jira] [Commented] (BEAM-368) Add getSplitPointsConsumed() to ByteKeyRangeTracker

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

[jira] [Commented] (BEAM-387) Remove internal file and fix gcsio code path

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

[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=15340445#comment-15340445 ] ASF GitHub Bot commented on BEAM-362: - GitHub user kennknowles opened a pull request:

[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=15340502#comment-15340502 ] ASF GitHub Bot commented on BEAM-362: - Github user kennknowles closed the pull request at:

[jira] [Commented] (BEAM-363) CompressedSource splits when it shouldn't

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

[jira] [Commented] (BEAM-252) Make Regex Transform

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

[jira] [Commented] (BEAM-364) Integration Tests for Bigtable Read and Write

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

[jira] [Commented] (BEAM-252) Make Regex Transform

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

[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=15359712#comment-15359712 ] ASF GitHub Bot commented on BEAM-362: - GitHub user kennknowles opened a pull request:

[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=15359713#comment-15359713 ] ASF GitHub Bot commented on BEAM-362: - Github user kennknowles closed the pull request at:

[jira] [Commented] (BEAM-371) Backport HDFS IO enhancements from Scio

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

[jira] [Commented] (BEAM-145) OutputTimeFn#assignOutputTime overrides WindowFn#getOutputTime in unfortunate ways

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

[jira] [Commented] (BEAM-145) OutputTimeFn#assignOutputTime overrides WindowFn#getOutputTime in unfortunate ways

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

[jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions

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

[jira] [Commented] (BEAM-554) Dataflow runner to support bounded writes in streaming mode.

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

[jira] [Commented] (BEAM-452) Implement DoFn per-instance setup and teardown methods

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

[jira] [Commented] (BEAM-557) Test-scoped dependencies should be excluded from shading package relocation

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

[jira] [Commented] (BEAM-557) Test-scoped dependencies should be excluded from shading package relocation

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

[jira] [Commented] (BEAM-124) Testing -- End to End WordCount Batch and Streaming Tests

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

[jira] [Commented] (BEAM-556) typo in documentation

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

[jira] [Commented] (BEAM-409) Incorrect use of Math.ceil in ApproximateQuantiles

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

[jira] [Commented] (BEAM-557) Test-scoped dependencies should be excluded from shading package relocation

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

[jira] [Commented] (BEAM-550) Datastore should support writes for Unbounded PCollections

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

[jira] [Commented] (BEAM-398) JAXBCoder uses incorrect Double-Checked Locking

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

[jira] [Commented] (BEAM-409) Incorrect use of Math.ceil in ApproximateQuantiles

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

[jira] [Commented] (BEAM-440) Create.values() returns a type-unsafe Coder

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

[jira] [Commented] (BEAM-492) Spark runner should call Pipeline.run() instead of SparkRunner.run()

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

[jira] [Commented] (BEAM-206) FileBasedSink does serial renames

[ https://issues.apache.org/jira/browse/BEAM-206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15433124#comment-15433124 ] ASF GitHub Bot commented on BEAM-206: - 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=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=15436761#comment-15436761 ] ASF GitHub Bot commented on BEAM-294: - GitHub user jbonofre opened a pull request:

[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=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=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=15459547#comment-15459547 ] ASF GitHub Bot commented on BEAM-604: - GitHub user markflyhigh 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=15464751#comment-15464751 ] ASF GitHub Bot commented on BEAM-102: - GitHub user mxm opened 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=15465632#comment-15465632 ] ASF GitHub Bot commented on BEAM-544: - GitHub user staslev opened a pull request:

[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=15465279#comment-15465279 ] ASF GitHub Bot commented on BEAM-242: - Github user asfgit 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=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=15466569#comment-15466569 ] ASF GitHub Bot commented on BEAM-553: - GitHub user chamikaramj opened a pull request:

[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=15467566#comment-15467566 ] ASF GitHub Bot commented on BEAM-333: - GitHub user mxm 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=15467538#comment-15467538 ] ASF GitHub Bot commented on BEAM-617: - GitHub user mxm opened a pull request:

[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=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=15469466#comment-15469466 ] ASF GitHub Bot commented on BEAM-242: - Github user asfgit closed the pull request at:

[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=15456510#comment-15456510 ] ASF GitHub Bot commented on BEAM-308: - 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=15456740#comment-15456740 ] ASF GitHub Bot commented on BEAM-577: - GitHub user sbilac opened a pull request:

[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=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=15456534#comment-15456534 ] ASF GitHub Bot commented on BEAM-535: - GitHub user vikkyrk 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=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=15457005#comment-15457005 ] ASF GitHub Bot commented on BEAM-535: - 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=15449947#comment-15449947 ] ASF GitHub Bot commented on BEAM-569: - 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=15470326#comment-15470326 ] ASF GitHub Bot commented on BEAM-619: - GitHub user mxm 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=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=15474155#comment-15474155 ] ASF GitHub Bot commented on BEAM-102: - Github user asfgit 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=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=15463597#comment-15463597 ] ASF GitHub Bot commented on BEAM-383: - GitHub user dhalperi opened a pull request:

[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=15446935#comment-15446935 ] ASF GitHub Bot commented on BEAM-587: - GitHub user rangadi opened a pull request:

[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=15447307#comment-15447307 ] ASF GitHub Bot commented on BEAM-548: - GitHub user swegner 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=15447033#comment-15447033 ] ASF GitHub Bot commented on BEAM-473: - GitHub user vikkyrk 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=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=15471877#comment-15471877 ] ASF GitHub Bot commented on BEAM-603: - Github user mariapython 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=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=1547#comment-1547 ] ASF GitHub Bot commented on BEAM-493: - GitHub user jasonkuster opened a pull request:

[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=15453099#comment-15453099 ] ASF GitHub Bot commented on BEAM-610: - GitHub user amitsela opened 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=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=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=15447976#comment-15447976 ] ASF GitHub Bot commented on BEAM-587: - 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=15474559#comment-15474559 ] ASF GitHub Bot commented on BEAM-544: - 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=15474468#comment-15474468 ] ASF GitHub Bot commented on BEAM-544: - Github user lukecwik closed the pull request at:

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