[ https://issues.apache.org/jira/browse/BEAM-2735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Thomas Groh resolved BEAM-2735. ------------------------------- Resolution: Fixed Fix Version/s: Not applicable > 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: Thomas Groh > Fix For: Not applicable > > > 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)