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

[1/2] incubator-beam git commit: Use CommittedResult in InMemoryWatermarkManager

Repository: incubator-beam Updated Branches: refs/heads/master 69ec223e5 -> 34e05954d Use CommittedResult in InMemoryWatermarkManager This enable unprocessed elements to be handled in the Watermark manager after they are added to the CommittedResult structure. Project:

Jenkins build is back to normal : beam_PostCommit_MavenVerify #324

See

Jenkins build is back to normal : beam_PostCommit_MavenVerify » Apache Beam :: Runners :: Flink #324

See

Jenkins build is back to normal : beam_PostCommit_MavenVerify » Apache Beam :: SDKs :: Java :: IO :: Google Cloud Platform #324

See

Jenkins build is back to normal : beam_PostCommit_MavenVerify » Apache Beam :: SDKs :: Java :: Build Tools #324

See

Jenkins build is back to normal : beam_PostCommit_MavenVerify » Apache Beam :: SDKs :: Java :: Maven Archetypes #324

See

Jenkins build is back to normal : beam_PostCommit_MavenVerify » Apache Beam :: SDKs :: Java :: Extensions #324

See

Jenkins build is back to normal : beam_PostCommit_MavenVerify » Apache Beam :: Runners #324

See

Jenkins build is back to normal : beam_PostCommit_MavenVerify » Apache Beam :: SDKs :: Java :: IO #324

See

Jenkins build is back to normal : beam_PostCommit_MavenVerify » Apache Beam :: SDKs :: Java :: Maven Archetypes :: Starter #324

See

Jenkins build is back to normal : beam_PostCommit_MavenVerify » Apache Beam :: Runners :: Flink :: Core #324

See

Jenkins build is back to normal : beam_PostCommit_MavenVerify » Apache Beam :: Runners :: Spark #324

See

Jenkins build is back to normal : beam_PostCommit_MavenVerify » Apache Beam :: SDKs :: Java :: Core #324

See

Jenkins build is back to normal : beam_PostCommit_MavenVerify » Apache Beam :: Parent #324

See

[jira] [Updated] (BEAM-248) Register DisplayData from anonymous implementation PTransforms

[ https://issues.apache.org/jira/browse/BEAM-248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-248: -- Assignee: Scott Wegner (was: Davor Bonaci) > Register DisplayData from anonymous implementation

[jira] [Updated] (BEAM-250) Exclude TextSource.minBundleSize default value from display data.

[ https://issues.apache.org/jira/browse/BEAM-250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-250: -- Assignee: Scott Wegner (was: Davor Bonaci) > Exclude TextSource.minBundleSize default value from display

[jira] [Updated] (BEAM-251) Exclude PipelineOptions with @JsonIgnore from display data

[ https://issues.apache.org/jira/browse/BEAM-251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-251: -- Assignee: Scott Wegner (was: Davor Bonaci) > Exclude PipelineOptions with @JsonIgnore from display data

[jira] [Commented] (BEAM-252) Make Regex Transform

[ https://issues.apache.org/jira/browse/BEAM-252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15267743#comment-15267743 ] Davor Bonaci commented on BEAM-252: --- Interesting idea. [~kenn] can probably comment a bit on this. > Make

[jira] [Updated] (BEAM-252) Make Regex Transform

[ https://issues.apache.org/jira/browse/BEAM-252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-252: -- Assignee: Kenneth Knowles (was: Davor Bonaci) > Make Regex Transform > > >

[GitHub] incubator-beam pull request: Fix the java doc for Combine.perKey a...

GitHub user peihe opened a pull request: https://github.com/apache/incubator-beam/pull/272 Fix the java doc for Combine.perKey and ApproximateQuantiles You can merge this pull request into a Git repository by running: $ git pull https://github.com/peihe/incubator-beam

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

Repository: incubator-beam Updated Branches: refs/heads/master 1262819ac -> 3ebdf4886 Closes #270 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3ebdf488 Tree:

[jira] [Commented] (BEAM-247) CombineFn's only definable/usable inside sdk.transforms package

[ https://issues.apache.org/jira/browse/BEAM-247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15267514#comment-15267514 ] Pei He commented on BEAM-247: - Closing as work as intended. However, there are documents about Combine that are

[jira] [Commented] (BEAM-247) CombineFn's only definable/usable inside sdk.transforms package

[ https://issues.apache.org/jira/browse/BEAM-247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15267496#comment-15267496 ] Pei He commented on BEAM-247: - The bug report comes from the following code snippets, and the combine fn is not

[GitHub] incubator-beam pull request: [BEAM-todo] Kafka sink

GitHub user rangadi opened a pull request: https://github.com/apache/incubator-beam/pull/271 [BEAM-todo] Kafka sink [will update soon] You can merge this pull request into a Git repository by running: $ git pull https://github.com/rangadi/incubator-beam kafka-sink

[jira] [Commented] (BEAM-231) Remove ClassForDisplay infrastructure class.

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

[GitHub] incubator-beam pull request: [BEAM-231] Remove ClassForDisplay hel...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/259 --- 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: Remove ClassForDisplay helper type

Repository: incubator-beam Updated Branches: refs/heads/master 659cf2ee0 -> 1262819ac Remove ClassForDisplay helper type - Refactor Combine display data to not use ClassForDisplay - Refactor DoFnReflector.SimpleDoFnAdapter to not use display data namespace override - Add test case for

[jira] [Commented] (BEAM-252) Make Regex Transform

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

[jira] [Created] (BEAM-250) Exclude TextSource.minBundleSize default value from display data.

Scott Wegner created BEAM-250: - Summary: Exclude TextSource.minBundleSize default value from display data. Key: BEAM-250 URL: https://issues.apache.org/jira/browse/BEAM-250 Project: Beam Issue

[jira] [Created] (BEAM-249) Combine.GroupedValues re-wraps combineFn from Combine.PerKey and loses identity for DisplayData

Scott Wegner created BEAM-249: - Summary: Combine.GroupedValues re-wraps combineFn from Combine.PerKey and loses identity for DisplayData Key: BEAM-249 URL: https://issues.apache.org/jira/browse/BEAM-249

[2/2] incubator-beam git commit: This closes #264

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

[GitHub] incubator-beam pull request: [BEAM-22] Correct sequence of pending...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/264 --- 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

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

[1/2] incubator-beam git commit: Fix update sequence in InMemoryWatermarkManager

Repository: incubator-beam Updated Branches: refs/heads/master b9116ac42 -> 659cf2ee0 Fix update sequence in InMemoryWatermarkManager Because the WatermarkManager is not synchronized within the call to updatePending, the sequence in which pending queues are updated must be in such a manner as

[jira] [Comment Edited] (BEAM-241) Not easy for runners to get late-data dropping

[ https://issues.apache.org/jira/browse/BEAM-241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15266262#comment-15266262 ] Aljoscha Krettek edited comment on BEAM-241 at 5/2/16 5:33 PM: --- I think the

[jira] [Commented] (BEAM-246) Do not build source jar, javadoc, in default Maven profile.

[ https://issues.apache.org/jira/browse/BEAM-246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15267038#comment-15267038 ] Aljoscha Krettek commented on BEAM-246: --- +1, good idea > Do not build source jar, javadoc, in default

[jira] [Commented] (BEAM-247) CombineFn's only definable/usable inside sdk.transforms package

[ https://issues.apache.org/jira/browse/BEAM-247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15267032#comment-15267032 ] Kenneth Knowles commented on BEAM-247: -- Aside from this making me :-( we should have a test that will

[jira] [Commented] (BEAM-201) Material page

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

[2/7] incubator-beam-site git commit: Addition of material page; nav fixes

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/713f0808/images/logos/bw/nameless/beam-logo-bw-nameless.svg -- diff --git a/images/logos/bw/nameless/beam-logo-bw-nameless.svg

[7/7] incubator-beam-site git commit: Logo files and project materials

Logo files and project materials This closes #13 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/commit/3b54e40c Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/3b54e40c Diff:

[4/7] incubator-beam-site git commit: Addition of material page; nav fixes

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/713f0808/content/images/logos/full-color/nameless/beam-logo-full-color-nameless.svg -- diff --git

[1/7] incubator-beam-site git commit: Addition of material page; nav fixes

Repository: incubator-beam-site Updated Branches: refs/heads/asf-site 4af810ead -> 3b54e40ce http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/713f0808/images/logos/full-color/nameless/beam-logo-full-color-nameless.svg

[jira] [Updated] (BEAM-247) CombineFn's only definable/usable inside sdk.transforms package

[ https://issues.apache.org/jira/browse/BEAM-247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-247: - Description: {code:java} public abstract static class CombineFn extends

[jira] [Created] (BEAM-247) CombineFn's only definable/usable inside sdk.transforms package

Ben Chambers created BEAM-247: - Summary: CombineFn's only definable/usable inside sdk.transforms package Key: BEAM-247 URL: https://issues.apache.org/jira/browse/BEAM-247 Project: Beam Issue

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

[ https://issues.apache.org/jira/browse/BEAM-243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-243: -- Assignee: Thomas Groh (was: Davor Bonaci) > Remove DirectPipelineRunner and keep only the

[jira] [Created] (BEAM-246) Do not build source jar, javadoc, in default Maven profile.

Kenneth Knowles created BEAM-246: Summary: Do not build source jar, javadoc, in default Maven profile. Key: BEAM-246 URL: https://issues.apache.org/jira/browse/BEAM-246 Project: Beam Issue

[jira] [Created] (BEAM-244) Create JDBC IO

Jean-Baptiste Onofré created BEAM-244: - Summary: Create JDBC IO Key: BEAM-244 URL: https://issues.apache.org/jira/browse/BEAM-244 Project: Beam Issue Type: New Feature

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

Jean-Baptiste Onofré created BEAM-243: - Summary: Remove DirectPipelineRunner and keep only the InProcessPipelineRunner Key: BEAM-243 URL: https://issues.apache.org/jira/browse/BEAM-243 Project:

[jira] [Commented] (BEAM-241) Not easy for runners to get late-data dropping

[ https://issues.apache.org/jira/browse/BEAM-241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15266262#comment-15266262 ] Aljoscha Krettek commented on BEAM-241: --- I think the short-term (and maybe also long-term) solution is

[jira] [Assigned] (BEAM-242) Enable Checkstyle check for the Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-242: - Assignee: Jean-Baptiste Onofré > Enable Checkstyle check for the Flink Runner >

[jira] [Created] (BEAM-242) Enable Checkstyle check for the Flink Runner

Maximilian Michels created BEAM-242: --- Summary: Enable Checkstyle check for the Flink Runner Key: BEAM-242 URL: https://issues.apache.org/jira/browse/BEAM-242 Project: Beam Issue Type: