[GitHub] incubator-beam pull request: [BEAM-1] Removal of a few windmill-re...

GitHub user davorbonaci opened a pull request: https://github.com/apache/incubator-beam/pull/2 [BEAM-1] Removal of a few windmill-related protos that aren't Beam-specific This pull request removes `windmill.proto` and `windmill_service.proto`. You can merge this pull request into a

[jira] [Commented] (BEAM-1) Import code on git

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

[GitHub] incubator-beam pull request: [BEAM-22] Support Unbounded PCollecti...

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/3 [BEAM-22] Support Unbounded PCollections in same-process execution This completes the implementation of the InProcessPipelineRunner, which is capable of running over unbounded inputs. E

[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&focusedCommentId=15172410#comment-15172410 ] ASF GitHub Bot commented on BEAM-22: GitHub user tgroh opened a pull request: https:

[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&focusedCommentId=15172622#comment-15172622 ] Raghu Angadi commented on BEAM-52: -- [~dhalp...@google.com], please assign the jira to me. >

[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&focusedCommentId=15172735#comment-15172735 ] Jean-Baptiste Onofré commented on BEAM-52: -- It should also have options for partitio

[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&focusedCommentId=15172740#comment-15172740 ] Jean-Baptiste Onofré commented on BEAM-52: -- We can't assign to you as you are not ye

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

[ https://issues.apache.org/jira/browse/BEAM-52?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-52: - Assignee: Raghu Angadi > KafkaIO - bounded/unbounded, source/sink >

[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&focusedCommentId=15172824#comment-15172824 ] Davor Bonaci commented on BEAM-52: -- Assigned. > KafkaIO - bounded/unbounded, source/sink >

[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&focusedCommentId=15172847#comment-15172847 ] Raghu Angadi commented on BEAM-52: -- Thanks [~jbonofre] & [~davor]. I have comment about pa

[jira] [Created] (BEAM-80) Support combiner lifting for (Keyed)CombineWithContext

Pei He created BEAM-80: -- Summary: Support combiner lifting for (Keyed)CombineWithContext Key: BEAM-80 URL: https://issues.apache.org/jira/browse/BEAM-80 Project: Beam Issue Type: New Feature C

[GitHub] incubator-beam pull request: [BEAM-80] Fix the Unexpected StateTag...

GitHub user peihe opened a pull request: https://github.com/apache/incubator-beam/pull/4 [BEAM-80] Fix the Unexpected StateTag error in convertToBagTagInternal It adds asBagTag() in KeyedCombiningValueWithContextStateTag, and allows convertToBagTagInternal accept it. You can mer

[jira] [Updated] (BEAM-80) Support combiner lifting for (Keyed)CombineWithContext

[ https://issues.apache.org/jira/browse/BEAM-80?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-80: - Assignee: Pei He (was: Davor Bonaci) > Support combiner lifting for (Keyed)CombineWithContext >

[jira] [Commented] (BEAM-80) Support combiner lifting for (Keyed)CombineWithContext

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

[jira] [Created] (BEAM-81) --update PipelineOption is in the wrong interface

Scott Wegner created BEAM-81: Summary: --update PipelineOption is in the wrong interface Key: BEAM-81 URL: https://issues.apache.org/jira/browse/BEAM-81 Project: Beam Issue Type: Bug Co

[jira] [Updated] (BEAM-81) --update PipelineOption is in the wrong interface

[ https://issues.apache.org/jira/browse/BEAM-81?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-81: - Assignee: Scott Wegner (was: Davor Bonaci) > --update PipelineOption is in the wrong interface > ---

[GitHub] incubator-beam pull request: [BEAM-81] --update PipelineOption is ...

GitHub user swegner opened a pull request: https://github.com/apache/incubator-beam/pull/5 [BEAM-81] --update PipelineOption is in the wrong interface You can merge this pull request into a Git repository by running: $ git pull https://github.com/swegner/incubator-beam b231227

[jira] [Commented] (BEAM-81) --update PipelineOption is in the wrong interface

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

[jira] [Created] (BEAM-82) Transitive dependencies in Beam pom.xml have conflicts that could result in old versions if reordered

Kenneth Knowles created BEAM-82: --- Summary: Transitive dependencies in Beam pom.xml have conflicts that could result in old versions if reordered Key: BEAM-82 URL: https://issues.apache.org/jira/browse/BEAM-82

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

[ https://issues.apache.org/jira/browse/BEAM-79?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Frances Perry updated BEAM-79: -- Assignee: James Malone > Gearpump runner > --- > > Key: BEAM-79 >

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

[ https://issues.apache.org/jira/browse/BEAM-79?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Frances Perry updated BEAM-79: -- Assignee: Manu Zhang (was: James Malone) > Gearpump runner > --- > > Key: BEAM

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

[ https://issues.apache.org/jira/browse/BEAM-79?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15173229#comment-15173229 ] Frances Perry commented on BEAM-79: --- Happy to assign it to you, as you will clearly be the

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

[ https://issues.apache.org/jira/browse/BEAM-79?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15173266#comment-15173266 ] Manu Zhang commented on BEAM-79: Thanks. I'm glad to take this task, and the Gearpump team is

[jira] [Created] (BEAM-83) Beam SDK has some difficulties upon import to Eclipse as maven project

Kenneth Knowles created BEAM-83: --- Summary: Beam SDK has some difficulties upon import to Eclipse as maven project Key: BEAM-83 URL: https://issues.apache.org/jira/browse/BEAM-83 Project: Beam

[jira] [Commented] (BEAM-83) Beam SDK has some difficulties upon import to Eclipse as maven project

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

[GitHub] incubator-beam pull request: [BEAM-83] Move Java 8 tests to their ...

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/6 [BEAM-83] Move Java 8 tests to their own module This allows easy setting of the compiler source and target version to 1.8 without any fragile plugin configuration. It also allows the impor

[GitHub] incubator-beam pull request: [BEAM-82] Exclude old version of Goog...

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/7 [BEAM-82] Exclude old version of Google API client libraries Our com.google.apis:google-api-services-datastore-protobuf dependency has a transitive dependency on a very old Google API c

[jira] [Commented] (BEAM-82) Transitive dependencies in Beam pom.xml have conflicts that could result in old versions if reordered

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