Etienne Chauchot created BEAM-8860:
--------------------------------------

             Summary: Implement combine with context in new spark runner
                 Key: BEAM-8860
                 URL: https://issues.apache.org/jira/browse/BEAM-8860
             Project: Beam
          Issue Type: Bug
          Components: runner-spark
            Reporter: Etienne Chauchot
            Assignee: Etienne Chauchot


Validates runner tests below fail in spark structured streaming runner because 
combine with context (for side inputs) is not implemented:
 
'org.apache.beam.sdk.transforms.CombineFnsTest.testComposedCombineWithContext''org.apache.beam.sdk.transforms.CombineTest$CombineWithContextTests.testSimpleCombineWithContext''org.apache.beam.sdk.transforms.CombineTest$CombineWithContextTests.testSimpleCombineWithContextEmpty''org.apache.beam.sdk.transforms.CombineTest$WindowingTests.testFixedWindowsCombineWithContext''org.apache.beam.sdk.transforms.CombineTest$WindowingTests.testSessionsCombineWithContext''org.apache.beam.sdk.transforms.CombineTest$WindowingTests.testSlidingWindowsCombineWithContext'



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to