[jira] [Commented] (BEAM-25) Add user-ready API for interacting with state

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

[jira] [Commented] (BEAM-27) Add user-ready API for interacting with timers

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

[jira] [Created] (BEAM-1109) Python ValidatesRunner Tests on Dataflow Service Timeout

Mark Liu created BEAM-1109: -- Summary: Python ValidatesRunner Tests on Dataflow Service Timeout Key: BEAM-1109 URL: https://issues.apache.org/jira/browse/BEAM-1109 Project: Beam Issue Type: Bug

[jira] [Updated] (BEAM-1096) flink streaming side output optimization using SplitStream

[ https://issues.apache.org/jira/browse/BEAM-1096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated BEAM-1096: --- Assignee: Alexey Diomin > flink streaming side output optimization using SplitStr

[jira] [Commented] (BEAM-1096) flink streaming side output optimization using SplitStream

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

[jira] [Updated] (BEAM-1095) Add support set config for reuse-object on flink

[ https://issues.apache.org/jira/browse/BEAM-1095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated BEAM-1095: --- Assignee: Alexey Diomin > Add support set config for reuse-object on fl

[jira] [Closed] (BEAM-1095) Add support set config for reuse-object on flink

[ https://issues.apache.org/jira/browse/BEAM-1095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed BEAM-1095. -- Resolution: Fixed Fix Version/s: 0.4.0-incubating > Add support set config for re

[jira] [Commented] (BEAM-1095) Add support set config for reuse-object on flink

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

[jira] [Commented] (BEAM-1108) Remove deprecated Dataflow Runner options and update documentation

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

[jira] [Commented] (BEAM-1107) Display user names for steps in the Flink Web UI

[ https://issues.apache.org/jira/browse/BEAM-1107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15730375#comment-15730375 ] Aljoscha Krettek commented on BEAM-1107: Yep, you're right but even in the black text the operation

[jira] [Commented] (BEAM-1108) Remove deprecated Dataflow Runner options and update documentation

[ https://issues.apache.org/jira/browse/BEAM-1108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15730373#comment-15730373 ] Neelesh Srinivas Salian commented on BEAM-1108: --- [~dhalp...@google.com] subtasks would

[jira] [Commented] (BEAM-646) Get runners out of the apply()

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

[jira] [Commented] (BEAM-1107) Display user names for steps in the Flink Web UI

[ https://issues.apache.org/jira/browse/BEAM-1107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15730313#comment-15730313 ] Daniel Halperin commented on BEAM-1107: --- Ack -- I guess I have this intuition there's opportunity

[jira] [Updated] (BEAM-1107) Display user names for steps in the Flink Web UI

[ https://issues.apache.org/jira/browse/BEAM-1107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-1107: -- Attachment: screenshot-1.png > Display user names for steps in the Flink Web

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

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

[jira] [Commented] (BEAM-1107) Display user names for steps in the Flink Web UI

[ https://issues.apache.org/jira/browse/BEAM-1107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15730212#comment-15730212 ] Daniel Halperin commented on BEAM-1107: --- Also copying [~aljoscha]'s response :) {quote} I think we

[jira] [Created] (BEAM-1107) Display user names for steps in the Flink Web UI

Daniel Halperin created BEAM-1107: - Summary: Display user names for steps in the Flink Web UI Key: BEAM-1107 URL: https://issues.apache.org/jira/browse/BEAM-1107 Project: Beam Issue Type

[jira] [Commented] (BEAM-905) Archetype pom needs to generalize dependencies

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

[jira] [Commented] (BEAM-975) Issue with MongoDBIO

[ https://issues.apache.org/jira/browse/BEAM-975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15730202#comment-15730202 ] Reza Nouri commented on BEAM-975: - Hey [~jbonofre], Here is from mongo log before failure: 2016-12-08T09

[jira] [Commented] (BEAM-25) Add user-ready API for interacting with state

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

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

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

[jira] [Commented] (BEAM-507) Fill in the documentation/runners/spark portion of the website

[ https://issues.apache.org/jira/browse/BEAM-507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15730054#comment-15730054 ] Amit Sela commented on BEAM-507: I'll have a PR by tomorrow. > Fill in the documentation/runners/sp

[jira] [Assigned] (BEAM-438) Rename one of PTransform.apply and PInput.apply

[ https://issues.apache.org/jira/browse/BEAM-438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-438: Assignee: Kenneth Knowles > Rename one of PTransform.apply and PInput.ap

[jira] [Commented] (BEAM-438) Rename one of PTransform.apply and PInput.apply

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

[jira] [Commented] (BEAM-1090) High memory usage error

[ https://issues.apache.org/jira/browse/BEAM-1090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15729950#comment-15729950 ] María GH commented on BEAM-1090: I had another occurrence: https://travis-ci.org/apache/incubator-beam

[jira] [Commented] (BEAM-597) Provide type information from Coders

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

[jira] [Commented] (BEAM-884) Add Display Data to the Python SDK's PipelineOptions, Avro io and other transforms

[ https://issues.apache.org/jira/browse/BEAM-884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15729725#comment-15729725 ] Pablo Estrada commented on BEAM-884: This is done. > Add Display Data to the Python SD

[jira] [Created] (BEAM-1106) Remove no_pipeline_type_check flag from Python SDK

Pablo Estrada created BEAM-1106: --- Summary: Remove no_pipeline_type_check flag from Python SDK Key: BEAM-1106 URL: https://issues.apache.org/jira/browse/BEAM-1106 Project: Beam Issue Type: Bug

[jira] [Commented] (BEAM-824) Misleading error message when sdk_location is missing in python

[ https://issues.apache.org/jira/browse/BEAM-824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15729724#comment-15729724 ] Pablo Estrada commented on BEAM-824: This was fixed. > Misleading error message when sdk_locat

[jira] [Commented] (BEAM-1055) Display Data keys on Python are inconsistent

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

[jira] [Commented] (BEAM-722) Add Display Data to the Python SDK

[ https://issues.apache.org/jira/browse/BEAM-722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15729723#comment-15729723 ] Pablo Estrada commented on BEAM-722: This is done. > Add Display Data to the Python

[jira] [Commented] (BEAM-1055) Display Data keys on Python are inconsistent

[ https://issues.apache.org/jira/browse/BEAM-1055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15729721#comment-15729721 ] Pablo Estrada commented on BEAM-1055: - This is done. > Display Data keys on Python are inconsist

[jira] [Commented] (BEAM-1105) Adding Beam's pico Wordcount to the existing examples.

[ https://issues.apache.org/jira/browse/BEAM-1105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15729610#comment-15729610 ] Jesse Anderson commented on BEAM-1105: -- Sounds good to me. > Adding Beam's pico Wordco

[jira] [Commented] (BEAM-1065) FileBasedSource: replace SeekableByteChannel with open(spec, startingPosition)

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

[jira] [Commented] (BEAM-664) Port Dataflow SDK WordCount walkthrough to Beam site

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

[jira] [Commented] (BEAM-1105) Adding Beam's pico Wordcount to the existing examples.

[ https://issues.apache.org/jira/browse/BEAM-1105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15729486#comment-15729486 ] Neelesh Srinivas Salian commented on BEAM-1105: --- [~jbonofre] I agree. Makes sense to bundle

[jira] [Commented] (BEAM-1105) Adding Beam's pico Wordcount to the existing examples.

[ https://issues.apache.org/jira/browse/BEAM-1105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15729476#comment-15729476 ] Jean-Baptiste Onofré commented on BEAM-1105: FYI, I also have concrete samples here: https

[jira] [Created] (BEAM-1105) Adding Beam's pico Wordcount to the existing examples.

Neelesh Srinivas Salian created BEAM-1105: - Summary: Adding Beam's pico Wordcount to the existing examples. Key: BEAM-1105 URL: https://issues.apache.org/jira/browse/BEAM-1105 Project: Beam

[jira] [Commented] (BEAM-646) Get runners out of the apply()

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

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

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

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

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

[jira] [Commented] (BEAM-1092) Shade commonly used libraries (e.g. Guava) to avoid class conflicts

[ https://issues.apache.org/jira/browse/BEAM-1092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15729017#comment-15729017 ] Maximilian Michels commented on BEAM-1092: -- 2) is for avoiding user classes to clash with all SDK

[jira] [Updated] (BEAM-1104) WordCount: Metrics error in the DirectRunner

[ https://issues.apache.org/jira/browse/BEAM-1104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-1104: -- Assignee: Thomas Groh (was: Davor Bonaci) > WordCount: Metrics error in the DirectRun

[jira] [Created] (BEAM-1104) WordCount: Metrics error in the DirectRunner

Daniel Halperin created BEAM-1104: - Summary: WordCount: Metrics error in the DirectRunner Key: BEAM-1104 URL: https://issues.apache.org/jira/browse/BEAM-1104 Project: Beam Issue Type: Bug

[jira] [Resolved] (BEAM-329) Update Spark runner README.

[ https://issues.apache.org/jira/browse/BEAM-329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré resolved BEAM-329. --- Resolution: Fixed Fix Version/s: 0.4.0-incubating > Update Spark runner REA

[jira] [Commented] (BEAM-329) Update Spark runner README.

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

[jira] [Updated] (BEAM-329) Update Spark runner README.

[ https://issues.apache.org/jira/browse/BEAM-329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela updated BEAM-329: --- Summary: Update Spark runner README. (was: Spark runner README should have a proper batch example.) > Upd

[jira] [Commented] (BEAM-329) Spark runner README should have a proper batch example.

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

[jira] [Resolved] (BEAM-1094) Spark runner should define Kafka IO dependency with test scope

[ https://issues.apache.org/jira/browse/BEAM-1094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela resolved BEAM-1094. - Resolution: Fixed Fix Version/s: 0.4.0-incubating > Spark runner should define Kafka IO depende

[jira] [Commented] (BEAM-1094) Spark runner should define Kafka IO dependency with test scope

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

[jira] [Commented] (BEAM-1094) Spark runner should define Kafka IO dependency with test scope

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

[jira] [Closed] (BEAM-1102) Flink Batch Runner does not populate aggregator values

[ https://issues.apache.org/jira/browse/BEAM-1102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed BEAM-1102. -- Resolution: Fixed Fix Version/s: 0.4.0-incubating > Flink Batch Runner does not popul

[jira] [Created] (BEAM-1103) Add Tests For Aggregators in Flink Runner

Aljoscha Krettek created BEAM-1103: -- Summary: Add Tests For Aggregators in Flink Runner Key: BEAM-1103 URL: https://issues.apache.org/jira/browse/BEAM-1103 Project: Beam Issue Type

[jira] [Commented] (BEAM-1102) Flink Batch Runner does not populate aggregator values

[ https://issues.apache.org/jira/browse/BEAM-1102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15727742#comment-15727742 ] Aljoscha Krettek commented on BEAM-1102: The problem is this part in {{FlinkProcessContextBase

[jira] [Commented] (BEAM-812) Shade guava in beam-sdks-java-io-google-cloud-platform

[ https://issues.apache.org/jira/browse/BEAM-812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15727720#comment-15727720 ] Daniel Halperin commented on BEAM-812: -- This is not likely to be fixed in the 0.4.0 release because

[jira] [Updated] (BEAM-812) Shade guava in beam-sdks-java-io-google-cloud-platform

[ https://issues.apache.org/jira/browse/BEAM-812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-812: - Fix Version/s: (was: 0.4.0-incubating) > Shade guava in beam-sdks-java-io-google-cloud-platf

[jira] [Commented] (BEAM-27) Add user-ready API for interacting with timers

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

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

[jira] [Issue Comment Deleted] (BEAM-1092) Shade commonly used libraries (e.g. Guava) to avoid class conflicts

[ https://issues.apache.org/jira/browse/BEAM-1092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated BEAM-1092: --- Comment: was deleted (was: Is 1) necessary if we do 2). I think shading is very necessary

[jira] [Commented] (BEAM-1092) Shade commonly used libraries (e.g. Guava) to avoid class conflicts

[ https://issues.apache.org/jira/browse/BEAM-1092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15727530#comment-15727530 ] Aljoscha Krettek commented on BEAM-1092: Is 1) necessary if we do 2)? I think shading is very

[jira] [Commented] (BEAM-1092) Shade commonly used libraries (e.g. Guava) to avoid class conflicts

[ https://issues.apache.org/jira/browse/BEAM-1092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15727529#comment-15727529 ] Aljoscha Krettek commented on BEAM-1092: Is 1) necessary if we do 2). I think shading is very

[jira] [Commented] (BEAM-1101) Remove inconsistencies in Python PipelineOptions

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

[jira] [Created] (BEAM-1101) Remove inconsistencies in Python PipelineOptions

Pablo Estrada created BEAM-1101: --- Summary: Remove inconsistencies in Python PipelineOptions Key: BEAM-1101 URL: https://issues.apache.org/jira/browse/BEAM-1101 Project: Beam Issue Type: Bug

[jira] [Updated] (BEAM-1085) Crunch Runner for Beam

[ https://issues.apache.org/jira/browse/BEAM-1085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian updated BEAM-1085: -- Component/s: runner-ideas > Crunch Runner for B

[jira] [Commented] (BEAM-1099) Minor typos in KafkaIO

[ https://issues.apache.org/jira/browse/BEAM-1099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15727280#comment-15727280 ] Davor Bonaci commented on BEAM-1099: Thanks [~jghoman], much appreciated. > Minor typos in Kafk

[jira] [Commented] (BEAM-1099) Minor typos in KafkaIO

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

[jira] [Resolved] (BEAM-1099) Minor typos in KafkaIO

[ https://issues.apache.org/jira/browse/BEAM-1099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci resolved BEAM-1099. Resolution: Fixed Fix Version/s: 0.4.0-incubating > Minor typos in Kafk

[jira] [Commented] (BEAM-1099) Minor typos in KafkaIO

[ https://issues.apache.org/jira/browse/BEAM-1099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15727272#comment-15727272 ] Jakob Homan commented on BEAM-1099: --- https://github.com/apache/incubator-beam/pull/1524 > Minor ty

[jira] [Commented] (BEAM-1099) Minor typos in KafkaIO

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

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

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

[jira] [Closed] (BEAM-1098) Minor typos in KafkaIO

[ https://issues.apache.org/jira/browse/BEAM-1098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci closed BEAM-1098. -- Resolution: Duplicate Fix Version/s: Not applicable > Minor typos in Kafk

[jira] [Created] (BEAM-1099) Minor typos in KafkaIO

Jakob Homan created BEAM-1099: - Summary: Minor typos in KafkaIO Key: BEAM-1099 URL: https://issues.apache.org/jira/browse/BEAM-1099 Project: Beam Issue Type: Bug Components: sdk-java

[jira] [Created] (BEAM-1098) Minor typos in KafkaIO

Jakob Homan created BEAM-1098: - Summary: Minor typos in KafkaIO Key: BEAM-1098 URL: https://issues.apache.org/jira/browse/BEAM-1098 Project: Beam Issue Type: Bug Components: sdk-java

[jira] [Commented] (BEAM-9) Storm Runner

[ https://issues.apache.org/jira/browse/BEAM-9?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15727260#comment-15727260 ] Davor Bonaci commented on BEAM-9: - Having a Storm runner would be great! Awesome! At some point

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

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

[jira] [Commented] (BEAM-1038) Support for new State API in DataflowRunner

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

[jira] [Commented] (BEAM-1038) Support for new State API in DataflowRunner

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

[jira] [Commented] (BEAM-1097) Dataflow error message for non-existing gcpTempLocation is misleading

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

[jira] [Created] (BEAM-1097) Dataflow error message for non-existing gcpTempLocation is misleading

Scott Wegner created BEAM-1097: -- Summary: Dataflow error message for non-existing gcpTempLocation is misleading Key: BEAM-1097 URL: https://issues.apache.org/jira/browse/BEAM-1097 Project: Beam

[jira] [Commented] (BEAM-986) ReduceFnRunner doesn't batch prefetching pane firings

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

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

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

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

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

[jira] [Resolved] (BEAM-641) Need to test the generated archetypes projects

[ https://issues.apache.org/jira/browse/BEAM-641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci resolved BEAM-641. --- Resolution: Invalid Fix Version/s: (was: 0.4.0-incubating) Not applicable

[jira] [Assigned] (BEAM-507) Fill in the documentation/runners/spark portion of the website

[ https://issues.apache.org/jira/browse/BEAM-507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela reassigned BEAM-507: -- Assignee: Amit Sela (was: James Malone) > Fill in the documentation/runners/spark port

[jira] [Commented] (BEAM-1096) flink streaming side output optimization using SplitStream

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

[jira] [Commented] (BEAM-986) ReduceFnRunner doesn't batch prefetching pane firings

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

[jira] [Created] (BEAM-1096) flink streaming side output optimization using SplitStream

Alexey Diomin created BEAM-1096: --- Summary: flink streaming side output optimization using SplitStream Key: BEAM-1096 URL: https://issues.apache.org/jira/browse/BEAM-1096 Project: Beam Issue

[jira] [Commented] (BEAM-646) Get runners out of the apply()

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

[jira] [Commented] (BEAM-1095) Add support set config for reuse-object on flink

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

[jira] [Commented] (BEAM-1087) Pickling error in save main session

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

[jira] [Commented] (BEAM-293) StreamingOptions should not extend GcpOptions

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

[jira] [Commented] (BEAM-1093) Confusing Javadocs in StateInternals

[ https://issues.apache.org/jira/browse/BEAM-1093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15726206#comment-15726206 ] Davor Bonaci commented on BEAM-1093: Just an outdated comment. [~mauzhang], perhaps you can quickly fix

[jira] [Commented] (BEAM-651) Consider making TypedPValue.setTypeDescriptorInternal no longer Internal

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

[jira] [Resolved] (BEAM-651) Consider making TypedPValue.setTypeDescriptorInternal no longer Internal

[ https://issues.apache.org/jira/browse/BEAM-651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-651. -- Resolution: Fixed Fix Version/s: 0.4.0-incubating > Consider mak

[jira] [Updated] (BEAM-830) Launcher for ApexRunner execution on YARN cluster

[ https://issues.apache.org/jira/browse/BEAM-830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated BEAM-830: -- Assignee: Thomas Weise > Launcher for ApexRunner execution on YARN clus

[jira] [Commented] (BEAM-830) Launcher for ApexRunner execution on YARN cluster

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

[jira] [Updated] (BEAM-1093) Confusing Javadocs in StateInternals

[ https://issues.apache.org/jira/browse/BEAM-1093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manu Zhang updated BEAM-1093: - Assignee: Ben Chambers (was: Davor Bonaci) > Confusing Javadocs in StateIntern

[jira] [Created] (BEAM-1093) Confusing Javadocs in StateInternals

Manu Zhang created BEAM-1093: Summary: Confusing Javadocs in StateInternals Key: BEAM-1093 URL: https://issues.apache.org/jira/browse/BEAM-1093 Project: Beam Issue Type: Improvement

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