[GitHub] incubator-beam pull request: Cassandra source connector - getEstim...

GitHub user TechM-Google opened a pull request: https://github.com/apache/incubator-beam/pull/185 Cassandra source connector - getEstimatedSizeBytes Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR ti

[GitHub] incubator-beam pull request: Cassandra source and sink connector c...

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

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #113

See

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow » Apache Beam :: Runners :: Google Cloud Dataflow #113

See

[GitHub] incubator-beam pull request: EncodabilityEnforcementFactoryTest: a...

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/184 EncodabilityEnforcementFactoryTest: add unit annotations Be sure to do all of the following to help us incorporate your contribution quickly and easily: You can merge this pull request

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #112

See

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow » Apache Beam :: Runners :: Google Cloud Dataflow #112

See

[jira] [Closed] (BEAM-188) Merging WindowFn + GBK + Write => InvalidWindows throws UnsupportedOperationException

[ https://issues.apache.org/jira/browse/BEAM-188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-188. Resolution: Fixed > Merging WindowFn + GBK + Write => InvalidWindows throws > UnsupportedOperationExc

[jira] [Commented] (BEAM-188) Merging WindowFn + GBK + Write => InvalidWindows throws UnsupportedOperationException

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

[GitHub] incubator-beam pull request: [BEAM-188] Write: apply GlobalWindows...

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

[2/2] incubator-beam git commit: [BEAM-188] Write: apply GlobalWindows first

[BEAM-188] Write: apply GlobalWindows first And do not supply a timestamp when outputting. Note that this is safe because the functions in the Writer cannot access the window or timestamp. When we add per-Window or similar functions to the sinks, we will likely do so at a higher level. Project

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

Repository: incubator-beam Updated Branches: refs/heads/master 5bdea1e2b -> 8dc9032ce Closes #181 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8dc9032c Tree: http://git-wip-us.apache.org/repos/asf/incu

[GitHub] incubator-beam pull request: Implement Create as An OffsetBasedSou...

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/183 Implement Create as An OffsetBasedSource Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted

[GitHub] incubator-beam pull request: Remove the DirectPipeline class

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/182 Remove the DirectPipeline class Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted like:

[jira] [Commented] (BEAM-188) Merging WindowFn + GBK + Write => InvalidWindows throws UnsupportedOperationException

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

[GitHub] incubator-beam pull request: [BEAM-188] Write: apply GlobalWindows...

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/181 [BEAM-188] Write: apply GlobalWindows first And do not supply a timestamp when outputting. Note that this is safe because the functions in the Writer cannot access the window o

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #111

See

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow » Apache Beam :: Runners :: Google Cloud Dataflow #111

See

[jira] [Created] (BEAM-197) Incremental join

Mark Shields created BEAM-197: - Summary: Incremental join Key: BEAM-197 URL: https://issues.apache.org/jira/browse/BEAM-197 Project: Beam Issue Type: Bug Components: beam-model

[jira] [Created] (BEAM-196) Pipeline options must be available Context in DoFn.startBundle

Mark Shields created BEAM-196: - Summary: Pipeline options must be available Context in DoFn.startBundle Key: BEAM-196 URL: https://issues.apache.org/jira/browse/BEAM-196 Project: Beam Issue Type

[jira] [Commented] (BEAM-155) Support asserting the contents of windows and panes in PAssert

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

[GitHub] incubator-beam pull request: [BEAM-155] Add AccumulateAllPanes PTr...

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/180 [BEAM-155] Add AccumulateAllPanes PTransform Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR title is format

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow » Apache Beam :: Runners :: Google Cloud Dataflow #110

See

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #110

See

[jira] [Commented] (BEAM-155) Support asserting the contents of windows and panes in PAssert

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

[GitHub] incubator-beam pull request: [BEAM-155] Make PassThroughWindowFn a...

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

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

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

[1/2] incubator-beam git commit: Make IdentityWindowFn and NeverTrigger available

Repository: incubator-beam Updated Branches: refs/heads/master 6511ba28e -> 5bdea1e2b Make IdentityWindowFn and NeverTrigger available This will be used as part of the new PAssert IdentityWindowFn remains package-private to restrict usage. Project: http://git-wip-us.apache.org/repos/asf/inc

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow » Apache Beam :: Runners :: Google Cloud Dataflow #109

See

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #109

See

[1/2] incubator-beam git commit: Remove Spark(Streaming)PipelineOptionsFactory

Repository: incubator-beam Updated Branches: refs/heads/master 96765f19b -> 6511ba28e Remove Spark(Streaming)PipelineOptionsFactory Pipeline authors should generally not use any runner-specific classes, but instead should select the runner and appropriate configurations through the PipelineOpt

[GitHub] incubator-beam pull request: Remove SparkPipelineOptionsFactory, S...

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

[2/2] incubator-beam git commit: [BEAM-22] This closes #167

[BEAM-22] This closes #167 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6511ba28 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6511ba28 Diff: http://git-wip-us.apache.org/repos/asf/incub

[jira] [Commented] (BEAM-189) The Spark runner uses valueInEmptyWindow which causes values to be dropped

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

[GitHub] incubator-beam pull request: [BEAM-189] The Spark runner uses valu...

GitHub user amitsela opened a pull request: https://github.com/apache/incubator-beam/pull/179 [BEAM-189] The Spark runner uses valueInEmptyWindow which causes values to be dropped Be sure to do all of the following to help us incorporate your contribution quickly and easily:

[jira] [Updated] (BEAM-193) Port existing Dataflow SDK documentation to Beam Programming Guide

[ https://issues.apache.org/jira/browse/BEAM-193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Frances Perry updated BEAM-193: --- Assignee: Devin Donnelly (was: James Malone) > Port existing Dataflow SDK documentation to Beam Program

[jira] [Updated] (BEAM-192) Create new landing page for Apache Beam Documentation

[ https://issues.apache.org/jira/browse/BEAM-192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Frances Perry updated BEAM-192: --- Assignee: Devin Donnelly (was: James Malone) > Create new landing page for Apache Beam Documentation >

[jira] [Commented] (BEAM-194) Create a walkthrough of Beam examples in mobile gaming domain

[ https://issues.apache.org/jira/browse/BEAM-194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15241833#comment-15241833 ] Frances Perry commented on BEAM-194: Here's the existing Dataflow version: https://clou

[jira] [Updated] (BEAM-194) Create a walkthrough of Beam examples in mobile gaming domain

[ https://issues.apache.org/jira/browse/BEAM-194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Frances Perry updated BEAM-194: --- Assignee: Devin Donnelly (was: James Malone) > Create a walkthrough of Beam examples in mobile gaming d

[jira] [Commented] (BEAM-195) Rename DisplayDataMatchers#includes

[ https://issues.apache.org/jira/browse/BEAM-195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15241830#comment-15241830 ] Scott Wegner commented on BEAM-195: --- Tracking this here instead of implementing right away

[jira] [Created] (BEAM-195) Rename DisplayDataMatchers#includes

Scott Wegner created BEAM-195: - Summary: Rename DisplayDataMatchers#includes Key: BEAM-195 URL: https://issues.apache.org/jira/browse/BEAM-195 Project: Beam Issue Type: Sub-task Compone

[jira] [Created] (BEAM-194) Create a walkthrough of Beam examples in mobile gaming domain

Devin Donnelly created BEAM-194: --- Summary: Create a walkthrough of Beam examples in mobile gaming domain Key: BEAM-194 URL: https://issues.apache.org/jira/browse/BEAM-194 Project: Beam Issue T

[jira] [Commented] (BEAM-192) Create new landing page for Apache Beam Documentation

[ https://issues.apache.org/jira/browse/BEAM-192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15241817#comment-15241817 ] Jean-Baptiste Onofré commented on BEAM-192: --- I would add a page with a status over

[jira] [Created] (BEAM-193) Port existing Dataflow SDK documentation to Beam Programming Guide

Devin Donnelly created BEAM-193: --- Summary: Port existing Dataflow SDK documentation to Beam Programming Guide Key: BEAM-193 URL: https://issues.apache.org/jira/browse/BEAM-193 Project: Beam Is

[jira] [Created] (BEAM-192) Create new landing page for Apache Beam Documentation

Devin Donnelly created BEAM-192: --- Summary: Create new landing page for Apache Beam Documentation Key: BEAM-192 URL: https://issues.apache.org/jira/browse/BEAM-192 Project: Beam Issue Type: Task

[jira] [Closed] (BEAM-112) Using non-IntervalWindows seems to fail

[ https://issues.apache.org/jira/browse/BEAM-112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela closed BEAM-112. -- Resolution: Duplicate Seems like it's related to BEAM-189 > Using non-IntervalWindows seems to fail > ---

[jira] [Commented] (BEAM-189) The Spark runner uses valueInEmptyWindow which causes values to be dropped

[ https://issues.apache.org/jira/browse/BEAM-189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15241719#comment-15241719 ] Amit Sela commented on BEAM-189: According to the stack trace, it looks like it's an issue w

[jira] [Commented] (BEAM-189) The Spark runner uses valueInEmptyWindow which causes values to be dropped

[ https://issues.apache.org/jira/browse/BEAM-189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15241718#comment-15241718 ] Amit Sela commented on BEAM-189: Replace "default" windowing to valueInGlobalWindow. Materia

[GitHub] incubator-beam pull request: [BEAM-22] Switch the Default Pipeline...

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/178 [BEAM-22] Switch the Default PipelineRunner Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatt

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

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow » Apache Beam :: Runners :: Google Cloud Dataflow #108

See

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #108

See

[1/2] incubator-beam-site git commit: Update to meeting page

Repository: incubator-beam-site Updated Branches: refs/heads/asf-site 0ae64c654 -> 4af810ead Update to meeting page 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/d3c2d89e Tree: http://git-wip

[2/2] incubator-beam-site git commit: Meeting time update

Meeting time update This closes #12 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/4af810ea Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/4af810ea Diff: http://git-wip-us.

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow » Apache Beam :: Runners :: Google Cloud Dataflow #107

See

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #107

See