Jenkins build is still unstable: beam_RunnableOnService_GoogleCloudDataflow » Apache Beam :: SDKs :: Java :: Core #14

See

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

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

[GitHub] incubator-beam pull request: [BEAM-162] Check for closed windows e...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/105 --- 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: Drop elements in closed windows before mapping window

Repository: incubator-beam Updated Branches: refs/heads/master 164676bc7 -> fba1259b4 Drop elements in closed windows before mapping window Previously, the sequence was: 1. Map a window to a representative of its equivalence class according to merging. 2. Drop the element if that window

[GitHub] incubator-beam pull request: Repeatedly#onFire should clear all fi...

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

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

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

Jenkins build is still unstable: beam_RunnableOnService_GoogleCloudDataflow » Apache Beam :: SDKs :: Java :: Core #13

See

[GitHub] incubator-beam pull request: DebuggingWordCount now takes filter a...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/108 --- 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: DebuggingWordCount now takes filter as an option

Repository: incubator-beam Updated Branches: refs/heads/master 061e6b5d8 -> e5bca60de DebuggingWordCount now takes filter as an option Previously it was hard-coded as "Flourish|stomach". Now it is a PipelineOption with that as the default. This allows "breaking" the pipeline by

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

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

[GitHub] incubator-beam pull request: Minor tweaks to PULL_REQUEST_TEMPLATE...

GitHub user bjchambers opened a pull request: https://github.com/apache/incubator-beam/pull/111 Minor tweaks to PULL_REQUEST_TEMPLATE.md Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure tests pass via `mvn

Jenkins build is still unstable: beam_RunnableOnService_GoogleCloudDataflow #12

See

Jenkins build is still unstable: beam_RunnableOnService_GoogleCloudDataflow » Apache Beam :: SDKs :: Java :: Core #12

See

[GitHub] incubator-beam pull request: Replace unambiguous of `throw Throwab...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/70 --- 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/3] incubator-beam git commit: Re-interrupt thread when handling InterruptedException

Re-interrupt thread when handling InterruptedException Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8b31c530 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8b31c530 Diff:

[1/3] incubator-beam git commit: Replace unambiguous of `throw Throwables.propagate` with definition

Repository: incubator-beam Updated Branches: refs/heads/master cab0c57c0 -> 061e6b5d8 Replace unambiguous of `throw Throwables.propagate` with definition In the SDK the path taken by Throwables.propagate is always statically known, and the inlined logic is more explicit and readable: - If

[3/3] incubator-beam git commit: This closes #70

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

[jira] [Commented] (BEAM-134) Investigate use of AutoValue

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

[GitHub] incubator-beam pull request: DebuggingWordCount now takes filter a...

GitHub user bjchambers opened a pull request: https://github.com/apache/incubator-beam/pull/108 DebuggingWordCount now takes filter as an option Allow DebuggingWordCount to take the filter to be matched as an option. Be sure to do all of the following to help us incorporate

[jira] [Updated] (BEAM-134) Investigate use of AutoValue

[ https://issues.apache.org/jira/browse/BEAM-134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Scott Wegner updated BEAM-134: -- Description: The initial PR for [BEAM-118] added a dependency on

Jenkins build is still unstable: beam_RunnableOnService_GoogleCloudDataflow #11

See

Jenkins build is still unstable: beam_RunnableOnService_GoogleCloudDataflow » Apache Beam :: SDKs :: Java :: Core #11

See

[GitHub] incubator-beam pull request: [BEAM-22] Clean up InProcess Read Eva...

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/106 [BEAM-22] Clean up InProcess Read Evaluators These are a couple of minor improvements to BoundedReadEvaluator and UnboundedReadEvaluator that enables splitting a source at evaluation

[GitHub] incubator-beam pull request: Optimize the Count CombineFn

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

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

[jira] [Comment Edited] (BEAM-162) assert fail using session windows

[ https://issues.apache.org/jira/browse/BEAM-162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15220413#comment-15220413 ] Kenneth Knowles edited comment on BEAM-162 at 3/31/16 6:34 PM: --- I agree with

[jira] [Commented] (BEAM-162) assert fail using session windows

[ https://issues.apache.org/jira/browse/BEAM-162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15220413#comment-15220413 ] Kenneth Knowles commented on BEAM-162: -- I agree with your PR, but I think the cause is different than

[jira] [Commented] (BEAM-162) assert fail using session windows

[ https://issues.apache.org/jira/browse/BEAM-162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15220403#comment-15220403 ] Kenneth Knowles commented on BEAM-162: -- I meant should in the normative sense, of course. > assert

[jira] [Commented] (BEAM-162) assert fail using session windows

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

[jira] [Commented] (BEAM-162) assert fail using session windows

[ https://issues.apache.org/jira/browse/BEAM-162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15220386#comment-15220386 ] Mark Shields commented on BEAM-162: --- https://github.com/apache/incubator-beam/pull/105 > assert fail

[GitHub] incubator-beam pull request: [BEAM-162] Check for closed windows e...

GitHub user mshields822 opened a pull request: https://github.com/apache/incubator-beam/pull/105 [BEAM-162] Check for closed windows early Rather than squash speculation on the bug I'll post this early. Will do unit test and try to get more randomization into NexMark Q11 so

[jira] [Commented] (BEAM-162) assert fail using session windows

[ https://issues.apache.org/jira/browse/BEAM-162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15220369#comment-15220369 ] Kenneth Knowles commented on BEAM-162: -- Elaborating on Ben's comment, only the trigger's {{onFire()}}

[jira] [Updated] (BEAM-163) Warn the user when a PCollection (via Window.into) has smaller allowedLateness than upstream

[ https://issues.apache.org/jira/browse/BEAM-163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-163: - Description: In this situation, data may be dropped downstream even though it was allowed upstream.

[jira] [Created] (BEAM-163) Warn the user when a PCollection (via Window.into) has smaller allowedLateness than upstream

Kenneth Knowles created BEAM-163: Summary: Warn the user when a PCollection (via Window.into) has smaller allowedLateness than upstream Key: BEAM-163 URL: https://issues.apache.org/jira/browse/BEAM-163

[jira] [Created] (BEAM-162) assert fail using session windows

Mark Shields created BEAM-162: - Summary: assert fail using session windows Key: BEAM-162 URL: https://issues.apache.org/jira/browse/BEAM-162 Project: Beam Issue Type: Bug Components:

[jira] [Commented] (BEAM-68) Support for limiting parallelism of a step

[ https://issues.apache.org/jira/browse/BEAM-68?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15220089#comment-15220089 ] Eugene Kirpichov commented on BEAM-68: -- I re-duped BEAM-169 against BEAM-92. - I agree that it won't

[jira] [Reopened] (BEAM-159) Support fixed number of shards in custom sinks

[ https://issues.apache.org/jira/browse/BEAM-159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Kirpichov reopened BEAM-159: --- Reopening to dupe against BEAM-92 instead, per discussion in BEAM-68. > Support fixed number of

[GitHub] incubator-beam pull request: [BEAM-158] add support for bounded so...

GitHub user mxm opened a pull request: https://github.com/apache/incubator-beam/pull/104 [BEAM-158] add support for bounded sources in streaming Apart from a few improvements, this PR introduces bounded sources in streaming. The BoundedSource wrapper (`SourceInputFormat`) is the

[jira] [Commented] (BEAM-158) Add support for bounded sources in streaming mode

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

[3/3] incubator-beam git commit: This closes #94.

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

[1/3] incubator-beam git commit: [flink] improve lifecycle handling of GroupAlsoByWindowWrapper

Repository: incubator-beam Updated Branches: refs/heads/master 0c47cad48 -> 96e286fec [flink] improve lifecycle handling of GroupAlsoByWindowWrapper Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

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

GitHub user TechM-Google opened a pull request: https://github.com/apache/incubator-beam/pull/103 Cassandra source and sink connector classes [BEAM-] Description of pull request Be sure to do all of the following to help us incorporate your contribution quickly and