Skip to content
This repository was archived by the owner on Nov 11, 2022. It is now read-only.

BoundedReadFromUnboundedSourceTest: fixes#452

Merged
lukecwik merged 1 commit intoGoogleCloudPlatform:masterfrom
dhalperi:timeBoundedTest
Sep 29, 2016
Merged

BoundedReadFromUnboundedSourceTest: fixes#452
lukecwik merged 1 commit intoGoogleCloudPlatform:masterfrom
dhalperi:timeBoundedTest

Conversation

@dhalperi
Copy link
Copy Markdown
Contributor

  1. Tests actually require non-splitting source (assert that the Key is 0).
    Use withoutSplitting.

  2. Indentation and unused code (expectedOutput).

  3. For these time-based tests, runners cannot guarantee we'll produce
    at least 3 elements, but we can expect there to be at least 1.

These appear in Beam but were not backported:

apache/beam@fecd036
apache/beam@ee7272f

1) Tests actually require non-splitting source (assert that the Key is 0).
   Use withoutSplitting.

2) Indentation and unused code (expectedOutput).

3) For these time-based tests, runners cannot guarantee we'll produce
   at least 3 elements, but we can expect there to be at least 1.

These appear in Beam but were not backported:

apache/beam@fecd036
apache/beam@ee7272f
@lukecwik
Copy link
Copy Markdown
Contributor

LGTM
Did the diffs, only substantial difference remaining is that in Apache Beam when refactoring the Direct runner out, we removed the finalize tracker support.

@lukecwik
Copy link
Copy Markdown
Contributor

Merging

@lukecwik lukecwik merged commit f0108a2 into GoogleCloudPlatform:master Sep 29, 2016
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants