[jira] [Commented] (BEAM-221) ProtoIO

[ https://issues.apache.org/jira/browse/BEAM-221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15347755#comment-15347755 ] Lucas Amorim commented on BEAM-221: --- Can you elaborate a little bit more? I'd love to work on it. thanks!

[GitHub] incubator-beam pull request #528: [BEAM-155] Remove TriggerBuilder backwards...

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/528 [BEAM-155] Remove TriggerBuilder backwards-compatibility adapter Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make

[GitHub] incubator-beam pull request #527: [BEAM-155] Use only WindowFn in TriggerTes...

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/527 [BEAM-155] Use only WindowFn in TriggerTester Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR title

[jira] [Commented] (BEAM-302) Add Scio Scala DSL to Beam

[ https://issues.apache.org/jira/browse/BEAM-302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15347672#comment-15347672 ] Jean-Baptiste Onofré commented on BEAM-302: --- Awesome ! Thanks. As discussed by e-mail, I started

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #608

See

[jira] [Updated] (BEAM-370) Remove the .named() methods from PTransforms and sub-classes

[ https://issues.apache.org/jira/browse/BEAM-370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-370: -- Assignee: Ben Chambers (was: Davor Bonaci) > Remove the .named() methods from PTransforms and

[2/2] incubator-beam git commit: Closes #339

Closes #339 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7745b921 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7745b921 Diff:

[jira] [Updated] (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:all-tabpanel ] Davor Bonaci updated BEAM-142: -- Assignee: Lucas Amorim > BigQueryIO: don't unnecessarily initialize an ExecutorService to validate >

[GitHub] incubator-beam pull request #526: [BEAM-142] - BigQueryIO: don't unnecessari...

GitHub user lucasallan opened a pull request: https://github.com/apache/incubator-beam/pull/526 [BEAM-142] - BigQueryIO: don't unnecessarily initialize an ExecutorService to validate parameters Fixes https://issues.apache.org/jira/browse/BEAM-142 You can merge this pull request

Jenkins build became unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #607

See

[jira] [Commented] (BEAM-51) Implement a CSV file reader

[ https://issues.apache.org/jira/browse/BEAM-51?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15347457#comment-15347457 ] Caio Iglesias commented on BEAM-51: --- related: https://issues.apache.org/jira/browse/BEAM-123 > Implement a

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

[GitHub] incubator-beam pull request #525: [BEAM-362] Move some more easy stuff from ...

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/525 [BEAM-362] Move some more easy stuff from SDK to appropriate modules Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x]

[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=15347383#comment-15347383 ] Lucas Amorim commented on BEAM-142: --- Can I work on this? > BigQueryIO: don't unnecessarily initialize an

[jira] [Updated] (BEAM-372) CoderProperties: Test that the coder doesn't consume more bytes than it produces

[ https://issues.apache.org/jira/browse/BEAM-372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-372: --- Description: Add a test to CoderProperties that does the following: 1. Encode a value using the Coder in the

[GitHub] incubator-beam pull request #524: Add KafkaIO tests to Flink runner Runnable...

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/524 Add KafkaIO tests to Flink runner RunnableOnService tests Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure

[jira] [Commented] (BEAM-302) Add Scio Scala DSL to Beam

[ https://issues.apache.org/jira/browse/BEAM-302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15347267#comment-15347267 ] Neville Li commented on BEAM-302: - I ported 2 modules over so far: - {{scio-core}} into {{sdks/scala/core}},

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

[ https://issues.apache.org/jira/browse/BEAM-37?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-37: Assignee: Ben Chambers (was: Kenneth Knowles) > Run DoFnWithContext without conversion to vanilla

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

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

[GitHub] incubator-beam pull request #523: [BEAM-191] Make WindowedValue extendable a...

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/523 [BEAM-191] Make WindowedValue extendable and deprecated valueInEmptyWindows Be sure to do all of the following to help us incorporate your contribution quickly and easily:

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

[ https://issues.apache.org/jira/browse/BEAM-371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neville Li reassigned BEAM-371: --- Assignee: Neville Li (was: James Malone) > Backport HDFS IO enhancements from Scio >

[jira] [Created] (BEAM-372) CoderProperties: Test that the coder doesn't consume more bytes than it produces

Ben Chambers created BEAM-372: - Summary: CoderProperties: Test that the coder doesn't consume more bytes than it produces Key: BEAM-372 URL: https://issues.apache.org/jira/browse/BEAM-372 Project: Beam

[jira] [Resolved] (BEAM-146) WindowFn.AssingContext leaks implementation details about compressed WindowedValue representation

[ https://issues.apache.org/jira/browse/BEAM-146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-146. -- Resolution: Fixed > WindowFn.AssingContext leaks implementation details about compressed >

[jira] [Updated] (BEAM-302) Add Scio Scala DSL to Beam

[ https://issues.apache.org/jira/browse/BEAM-302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-302: - Summary: Add Scio Scala DSL to Beam (was: Add Beam Scala DSL) > Add Scio Scala DSL to Beam >

[jira] [Assigned] (BEAM-302) Add Beam Scala DSL

[ https://issues.apache.org/jira/browse/BEAM-302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-302: Assignee: Neville Li (was: James Malone) Here you go! I will go ahead and make the name a

[2/5] incubator-beam git commit: Add basic WindowMatchersTest

Add basic WindowMatchersTest Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/edf11fa7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/edf11fa7 Diff:

[4/5] incubator-beam git commit: Remove references to multi-window representation from model

Remove references to multi-window representation from model Some areas of the Beam model in the SDK allude to the use of a compressed representation of an element along with the set of windows it is assigned to. However, the model itself views elements in different windows as fully independent,

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

[ https://issues.apache.org/jira/browse/BEAM-371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neville Li updated BEAM-371: Description: Right now there is a {{beam-sdks-java-io-hdfs}} module but only {{HDFSFileSource}} is

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

Neville Li created BEAM-371: --- Summary: Backport HDFS IO enhancements from Scio Key: BEAM-371 URL: https://issues.apache.org/jira/browse/BEAM-371 Project: Beam Issue Type: Improvement

[jira] [Commented] (BEAM-146) WindowFn.AssingContext leaks implementation details about compressed WindowedValue representation

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

[GitHub] incubator-beam pull request #308: [BEAM-146] Remove references to multi-wind...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/308 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[1/5] incubator-beam git commit: Explode windows in DirectRunner's Window.into evaluator

Repository: incubator-beam Updated Branches: refs/heads/master f2d2ce5f4 -> 82ae661c5 Explode windows in DirectRunner's Window.into evaluator Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a3aa4c7f

[3/5] incubator-beam git commit: Simple PaneInfo.toString() for interned constants

Simple PaneInfo.toString() for interned constants Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d9bca25a Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d9bca25a Diff:

[5/5] incubator-beam git commit: This closes #308

This closes #308 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/82ae661c Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/82ae661c Diff:

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

[ https://issues.apache.org/jira/browse/BEAM-314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-314: -- Fix Version/s: 0.2.0-incubating > Support zip compression in TextIO >

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

[ https://issues.apache.org/jira/browse/BEAM-314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reopened BEAM-314: --- Just setting the fix version field to have an updated RELEASE-NOTES for the next release.

[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] [Closed] (BEAM-314) Support zip compression in TextIO

[ https://issues.apache.org/jira/browse/BEAM-314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-314. Resolution: Fixed > Support zip compression in TextIO > - > >

[GitHub] incubator-beam pull request #400: [BEAM-314] Add zip compression support in ...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/400 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[1/2] incubator-beam git commit: Closes #400

Repository: incubator-beam Updated Branches: refs/heads/master 748b0c8da -> f2d2ce5f4 Closes #400 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f2d2ce5f Tree:

[2/2] incubator-beam git commit: [BEAM-314] Add zip compression support in TextIO

[BEAM-314] Add zip compression support in TextIO Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/49b48472 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/49b48472 Diff: