[ 
https://issues.apache.org/jira/browse/BEAM-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16105124#comment-16105124
 ] 

Eugene Kirpichov commented on BEAM-2671:
----------------------------------------

I'm not sure about bumping it to 2.2.0. It looks quite dangerous and I'd be 
hesitant to ignore it without checking how dangerous it actually is. Do we have 
other tests that verify that Spark runner does not incorrectly drop data in 
streaming pipelines?

> CreateStreamTest.testFirstElementLate validatesRunner test fails on Spark 
> runner
> --------------------------------------------------------------------------------
>
>                 Key: BEAM-2671
>                 URL: https://issues.apache.org/jira/browse/BEAM-2671
>             Project: Beam
>          Issue Type: Bug
>          Components: runner-spark
>            Reporter: Etienne Chauchot
>            Assignee: Jean-Baptiste Onofré
>             Fix For: 2.1.0, 2.2.0
>
>
> Error message:
> Flatten.Iterables/FlattenIterables/FlatMap/ParMultiDo(Anonymous).out0: 
> Expected: iterable over [] in any order
>      but: Not matched: "late"



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Reply via email to