You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by aljoscha <gi...@git.apache.org> on 2017/07/20 09:27:35 UTC
[GitHub] beam pull request #3600: [BEAM-2571] CombineTest.testSlidingWindowsCombineWi...
GitHub user aljoscha opened a pull request:
https://github.com/apache/beam/pull/3600
[BEAM-2571] CombineTest.testSlidingWindowsCombineWithContext
This is a rebased version of #3550. I didn't want to mess with the comments and history on that other PR.
R: @peihe (and the others from the older PR)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/beam jira-2571-fix-flink-watermark-issues-rebased
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/beam/pull/3600.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #3600
----
commit 2ed36cdfef5daf124d58673933ad2e685107dd8b
Author: Alex Filatov <al...@users.noreply.github.com>
Date: 2017-07-10T10:20:49Z
[BEAM-2306] Add checkstyle check to fail the build when @Deprecated is used without @deprecated javadoc (or vice versa).
The check is disabled for existing violations where reason for deprecation and/or alternative is not clear.
commit 34dd3d616ae0c4de28e12e1f09c62cf8d26a1468
Author: Aljoscha Krettek <al...@gmail.com>
Date: 2017-07-12T12:42:37Z
[BEAM-2571] Change DoFnOperator to use Long.MAX_VALUE as max watermark
This is in line with what Flink does and what BoundedSourceWrapper and
UnboundedSourceWrapper do.
commit f24ef3830c1e61379429013d712ab1e4dc65c728
Author: Pei He <pe...@apache.org>
Date: 2017-07-17T15:34:27Z
[BEAM-2630] TestPipeline: construct job/app names based on Description in junit TestRule.
commit 9833462f9dad726391ccf6e21102eb87ad9075ec
Author: Neville Li <ne...@spotify.com>
Date: 2017-07-18T13:07:21Z
[BEAM-2532] Memoizes TableSchema in BigQuerySourceBase
Instead of parsing the JSON schema for every record.
commit 9a8600d84b7a98ceecbe8b48ebce3b4f90976300
Author: Vikas Kedigehalli <vi...@google.com>
Date: 2017-07-18T17:06:46Z
Increase the gRPC message size to max value
commit 56e2c7a939ba39e4077de89e829935aea6194301
Author: Sourabh Bajaj <so...@google.com>
Date: 2017-07-19T17:08:14Z
[BEAM-2636] Make sure we only override the correct class
commit 014d80ab0cdb1672359cdb2cb76a3eabf9f2fbca
Author: Luke Cwik <lc...@google.com>
Date: 2017-07-19T18:36:35Z
[BEAM-2642] Update Google Auth to 0.7.1
Google auth libraries 0.6.1 and 0.7.1 have the same versions of dependencies.
commit 6cd72d72493ff68f747aef5ba69d3a850aab156c
Author: Aljoscha Krettek <al...@gmail.com>
Date: 2017-07-12T12:39:58Z
[BEAM-2571] Clarify pushedback variable name in DoFnOperator
commit 8068ee3805ce868b7dcc28f5421bbb4782572111
Author: Aljoscha Krettek <al...@gmail.com>
Date: 2017-07-12T13:38:06Z
[BEAM-2571] Respect watermark contract in Flink DoFnOperator
In Flink, a watermark T specifies that there will be no elements with a
timestamp <= T in the future. In Beam, a watermark T specifies that
there will not be element with a timestamp < T in the future. This leads
to problems when the watermark is exactly "on the timer timestamp", most
prominently, this happened with Triggers, where Flink would fire the
Trigger too early and the Trigger would determine (based on the
watermark) that it is not yet time to fire the window while Flink
thought it was time.
This also adds a test that specifially tests the edge case.
----
---
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 is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---
[GitHub] beam pull request #3600: [BEAM-2571] CombineTest.testSlidingWindowsCombineWi...
Posted by asfgit <gi...@git.apache.org>.
Github user asfgit closed the pull request at:
https://github.com/apache/beam/pull/3600
---
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 is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---