Thomas Groh created BEAM-2735:
---------------------------------
Summary: testMergingCustomWindows tests are incorrect
Key: BEAM-2735
URL: https://issues.apache.org/jira/browse/BEAM-2735
Project: Beam
Issue Type: Bug
Components: sdk-java-core
Affects Versions: 2.2.0
Reporter: Thomas Groh
Assignee: Etienne Chauchot
If the input is rewritten to use to use {{TestStream}}, and executes in the
DirectRunner, the tests fail. My expectation is that this is due to a
disagreement in what the tests expect to be merged (if all of the merging logic
is run only once), as opposed to running the merging logic incrementally with a
perfect watermark.
This is also causing failures in the Dataflow {{ValidatesRunner}} suite.
{code:java}
PCollection<String> inputCollection =
pipeline.apply(
TestStream.create(StringUtf8Coder.of())
.advanceWatermarkTo(startInstant.plus(Duration.standardSeconds(10L)))
.addElements("big")
.advanceWatermarkTo(startInstant.plus(Duration.standardSeconds(20L)))
.addElements("small1")
.advanceWatermarkTo(startInstant.plus(Duration.standardSeconds(39L)))
.addElements("small2")
.advanceWatermarkTo(startInstant.plus(Duration.standardSeconds(250L)))
.advanceWatermarkToInfinity());
{code}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
