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

[GitHub] incubator-beam pull request #968: [BEAM-597] Added public where method to sp...

GitHub user jeremiele opened a pull request: https://github.com/apache/incubator-beam/pull/968 [BEAM-597] Added public where method to specify parameter types. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1159

See

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

Closes #920 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4b7fe2dc Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4b7fe2dc Diff:

[1/2] incubator-beam git commit: Adds a text source to Python SDK.

Repository: incubator-beam Updated Branches: refs/heads/python-sdk ebae225ed -> 4b7fe2dc5 Adds a text source to Python SDK. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/2d1e7ff6 Tree:

[3/3] incubator-beam git commit: Closes #964

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

[GitHub] incubator-beam pull request #964: Allow pickling of UnwindowedValues instanc...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/964 --- 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/3] incubator-beam git commit: Allow pickling of UnwindowedValues instances

Repository: incubator-beam Updated Branches: refs/heads/python-sdk a60b58a94 -> ebae225ed Allow pickling of UnwindowedValues instances These are trivial wrappers produced when "windowing" by the global window, but may need to be materialized in some cases. Project:

[2/3] incubator-beam git commit: Add unit test for unwindowed iterator picking.

Add unit test for unwindowed iterator picking. Also lifted this out to a top-level class rather than defining it on every element now that it's not longer a simple generator statement. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[jira] [Commented] (BEAM-414) IntraBundleParallelization needs to be removed

[ https://issues.apache.org/jira/browse/BEAM-414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15497620#comment-15497620 ] Kenneth Knowles commented on BEAM-414: -- Awesome. One less OldDoFn situation sitting around. >

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1158

See

[jira] [Commented] (BEAM-283) CheckpointMark.finalize() is not called in Flink Source Wrapper

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

[GitHub] incubator-beam pull request #967: [BEAM-283] finalize CheckpointMarks upon c...

GitHub user mxm opened a pull request: https://github.com/apache/incubator-beam/pull/967 [BEAM-283] finalize CheckpointMarks upon completed checkpoint See the first commit for an addition to the `UnboundedSourceWrapper` to call `finalizeCheckpoint()` on `CheckpointMark`s upon

[jira] [Commented] (BEAM-636) Add Char, Byte to TypeDescriptors

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

[GitHub] incubator-beam pull request #966: [BEAM-636] Add Char, Byte to TypeDescripto...

GitHub user eljefe6a opened a pull request: https://github.com/apache/incubator-beam/pull/966 [BEAM-636] Add Char, Byte to TypeDescriptors The TypeDescriptors class is missing the Char and Byte TypeDescriptor methods. You can merge this pull request into a Git repository by

[jira] [Updated] (BEAM-636) Add Char, Byte to TypeDescriptors

[ https://issues.apache.org/jira/browse/BEAM-636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jesse Anderson updated BEAM-636: Fix Version/s: (was: 0.2.0-incubating) Description: The TypeDescriptors class is missing the

[jira] [Created] (BEAM-636) Add Char, Byte to TypeDescriptors

Jesse Anderson created BEAM-636: --- Summary: Add Char, Byte to TypeDescriptors Key: BEAM-636 URL: https://issues.apache.org/jira/browse/BEAM-636 Project: Beam Issue Type: Bug

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

[ https://issues.apache.org/jira/browse/BEAM-235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-235: Fix Version/s: (was: 0.3.0-incubating) 0.2.0-incubating > Remove

[jira] [Updated] (BEAM-635) Release 0.2.0-incubating - Support Flink Release Version 1.1.2

[ https://issues.apache.org/jira/browse/BEAM-635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-635: Component/s: (was: beam-model) runner-flink > Release 0.2.0-incubating -

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1156

See