[jira] [Commented] (BEAM-196) Pipeline options must be available Context in DoFn.startBundle

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

[jira] [Commented] (BEAM-287) Add new beam groupIds

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

[jira] [Commented] (BEAM-292) TextIO.Write.to Empty Files

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

[jira] [Commented] (BEAM-132) Release process for Beam artifacts to Maven

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

[jira] [Commented] (BEAM-288) Improve javadoc for UnboundedSource

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

[jira] [Commented] (BEAM-22) DirectPipelineRunner: support for unbounded collections

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

[jira] [Commented] (BEAM-240) Add display data link URLs for sources / sinks

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

[jira] [Commented] (BEAM-159) Support fixed number of shards in custom sinks

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

[jira] [Commented] (BEAM-330) Maven exec warning message on Dataflow WordCount Example

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

[jira] [Commented] (BEAM-317) Implement PAssert without using Side Inputs

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

[jira] [Commented] (BEAM-297) version typo at README.md of flink runner

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

[jira] [Commented] (BEAM-292) TextIO.Write.to Empty Files

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

[jira] [Commented] (BEAM-287) Add new beam groupIds

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

[jira] [Commented] (BEAM-196) Pipeline options must be available Context in DoFn.startBundle

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

[jira] [Commented] (BEAM-38) Avoid repeated DoFn deserialization

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

[jira] [Commented] (BEAM-38) Avoid repeated DoFn deserialization

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

[jira] [Commented] (BEAM-38) Avoid repeated DoFn deserialization

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

[jira] [Commented] (BEAM-318) AvroCoder may be vulnerable to AVRO-607

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

[jira] [Commented] (BEAM-326) A minor update to KafkaIO javadoc

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

[jira] [Commented] (BEAM-327) Dataflow runner should have configuration for System.out/err handling

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

[jira] [Commented] (BEAM-319) Attach src distribution artifact to be take by deploy

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

[jira] [Commented] (BEAM-334) Dataflow pipeline runner should bump major version number

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

[jira] [Commented] (BEAM-336) examples-java README is not up-to-date

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

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

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

[jira] [Commented] (BEAM-330) Maven exec warning message on Dataflow WordCount Example

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

[jira] [Commented] (BEAM-334) Dataflow pipeline runner should bump major version number

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

[jira] [Commented] (BEAM-243) Remove DirectPipelineRunner and keep only the InProcessPipelineRunner

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

[jira] [Commented] (BEAM-331) WindowedWordCount.AddTimestampFn has nondeterministic timestamp bounds

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

[jira] [Commented] (BEAM-22) DirectPipelineRunner: support for unbounded collections

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

[jira] [Commented] (BEAM-330) Maven exec warning message on Dataflow WordCount Example

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

[jira] [Commented] (BEAM-22) DirectPipelineRunner: support for unbounded collections

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

[jira] [Commented] (BEAM-159) Support fixed number of shards in custom sinks

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

[jira] [Commented] (BEAM-319) Attach src distribution artifact to be take by deploy

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

[jira] [Commented] (BEAM-22) DirectPipelineRunner: support for unbounded collections

[ https://issues.apache.org/jira/browse/BEAM-22?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15315206#comment-15315206 ] ASF GitHub Bot commented on BEAM-22: GitHub user tgroh 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=15300778#comment-15300778 ] ASF GitHub Bot commented on BEAM-308: - 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=15300644#comment-15300644 ] ASF GitHub Bot commented on BEAM-308: - GitHub user swegner opened a pull request:

[jira] [Commented] (BEAM-117) Implement the API for Static Display Metadata

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

[jira] [Commented] (BEAM-122) GlobalWindow and allowedLateness can cause inconsistent timer interpretation

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

[jira] [Commented] (BEAM-22) DirectPipelineRunner: support for unbounded collections

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

[jira] [Commented] (BEAM-330) Maven exec warning message on Dataflow WordCount Example

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

[jira] [Commented] (BEAM-335) beam_PostCommit_RunnableOnService_GoogleCloudDataflow broken since #514

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

[jira] [Commented] (BEAM-331) WindowedWordCount.AddTimestampFn has nondeterministic timestamp bounds

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

[jira] [Commented] (BEAM-289) Examples Use TypeDescriptors

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

[jira] [Commented] (BEAM-327) Dataflow runner should have configuration for System.out/err handling

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

[jira] [Commented] (BEAM-243) Remove DirectPipelineRunner and keep only the InProcessPipelineRunner

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

[jira] [Commented] (BEAM-342) Change Filter#greaterThan, etc. to actually use Filter

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

[jira] [Commented] (BEAM-343) DisplayData error in AfterWatermark

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

[jira] [Commented] (BEAM-327) Dataflow runner should have configuration for System.out/err handling

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

[jira] [Commented] (BEAM-287) Add new beam groupIds

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

[jira] [Commented] (BEAM-287) Add new beam groupIds

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

[jira] [Commented] (BEAM-52) KafkaIO - bounded/unbounded, source/sink

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

[jira] [Commented] (BEAM-235) Remove streaming flag

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

[jira] [Commented] (BEAM-312) UnboundedSourceWrapper fails if CheckpointMarkCoder not available

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

[jira] [Commented] (BEAM-235) Remove streaming flag

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

[jira] [Commented] (BEAM-53) PubSubIO: reimplement in Java

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

[jira] [Commented] (BEAM-270) Support Timestamps/Windows in Flink Batch

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

[jira] [Commented] (BEAM-254) Add maven-rat-plugin execution

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

[jira] [Commented] (BEAM-155) Support asserting the contents of windows and panes in PAssert

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

[jira] [Commented] (BEAM-122) GlobalWindow and allowedLateness can cause inconsistent timer interpretation

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

[jira] [Commented] (BEAM-122) GlobalWindow and allowedLateness can cause inconsistent timer interpretation

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

[jira] [Commented] (BEAM-289) Examples Use TypeDescriptors

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

[jira] [Commented] (BEAM-103) Make UnboundedSourceWrapper parallel

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

[jira] [Commented] (BEAM-318) AvroCoder is vulnerable to AVRO-607

[ https://issues.apache.org/jira/browse/BEAM-318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15308972#comment-15308972 ] ASF GitHub Bot commented on BEAM-318: - GitHub user dhalperi 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=15309061#comment-15309061 ] ASF GitHub Bot commented on BEAM-242: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-323) The InProcessPipelineRunner uses user objects for State and Timer lookups

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

[jira] [Commented] (BEAM-321) Hash encoded keys in Flink batch mode

[ https://issues.apache.org/jira/browse/BEAM-321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15310556#comment-15310556 ] ASF GitHub Bot commented on BEAM-321: - GitHub user aljoscha 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=15309315#comment-15309315 ] ASF GitHub Bot commented on BEAM-242: - Github user jbonofre closed the pull request at:

[jira] [Commented] (BEAM-295) Flink Create Functions call Collector.close()

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

[jira] [Commented] (BEAM-314) Support zip compression in TextIO

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

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

[jira] [Commented] (BEAM-316) Support file scheme in TextIO

[ https://issues.apache.org/jira/browse/BEAM-316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15308001#comment-15308001 ] ASF GitHub Bot commented on BEAM-316: - GitHub user jbonofre 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=15344733#comment-15344733 ] ASF GitHub Bot commented on BEAM-354: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-115) Beam Runner API

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

[jira] [Commented] (BEAM-155) Support asserting the contents of windows and panes in PAssert

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

[jira] [Commented] (BEAM-367) GetFractionConsumed() inaccurate for non-uniform records

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

[jira] [Commented] (BEAM-360) Add a framework for creating Python-SDK sources for new file types

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

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

[jira] [Commented] (BEAM-367) GetFractionConsumed() inaccurate for non-uniform records

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

[jira] [Commented] (BEAM-343) DisplayData error in AfterWatermark

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

[jira] [Commented] (BEAM-341) ReduceFnRunner allows GC time overflow

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

[jira] [Commented] (BEAM-234) Remove the word Pipeline from the name of all PipelineRunner implementations

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

[jira] [Commented] (BEAM-348) Clean temp_dir usage in _stage_extra_packages

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

[jira] [Commented] (BEAM-234) Remove the word Pipeline from the name of all PipelineRunner implementations

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

[jira] [Commented] (BEAM-234) Remove the word Pipeline from the name of all PipelineRunner implementations

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

[jira] [Commented] (BEAM-359) AvroCoder should be able to handle anonymous classes as schemas

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

[jira] [Commented] (BEAM-234) Remove the word Pipeline from the name of all PipelineRunner implementations

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

[jira] [Commented] (BEAM-234) Remove the word Pipeline from the name of all PipelineRunner implementations

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

[jira] [Commented] (BEAM-234) Remove the word Pipeline from the name of all PipelineRunner implementations

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

[jira] [Commented] (BEAM-356) Custom commands not executed on pip install for user workflow package

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

[jira] [Commented] (BEAM-234) Remove the word Pipeline from the name of all PipelineRunner implementations

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

[jira] [Commented] (BEAM-321) Hash encoded keys in Flink batch mode

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

[jira] [Commented] (BEAM-357) Build doesn't pass on windows

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

[jira] [Commented] (BEAM-314) Support zip compression in TextIO

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

[jira] [Commented] (BEAM-359) AvroCoder should be able to handle anonymous classes as schemas

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

[jira] [Commented] (BEAM-37) Run DoFnWithContext without conversion to vanilla DoFn

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

[jira] [Commented] (BEAM-350) beam_PostCommit_RunnableOnService_GoogleCloudDataflow flaky

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

[jira] [Commented] (BEAM-259) Execute selected RunnableOnService tests with Spark runner

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

[jira] [Commented] (BEAM-234) Remove the word Pipeline from the name of all PipelineRunner implementations

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

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

  1   2   3   4   5   6   7   8   9   10   >