Jan Lukavský created BEAM-9273:
----------------------------------

             Summary: Explicitly fail pipeline with @RequiresTimeSortedInput 
with unsupported runner
                 Key: BEAM-9273
                 URL: https://issues.apache.org/jira/browse/BEAM-9273
             Project: Beam
          Issue Type: Improvement
          Components: sdk-java-core
            Reporter: Jan Lukavský
            Assignee: Jan Lukavský


Fail pipeline with @RequiresTimeSortedInput annotation in pipeline translation 
time when being run with unsupported runner. Currently, unsupported runners are:

 - apex

 - portable flink

 - gearpump

 - dataflow

 - jet

 - samza

 - spark structured streaming

These runners should reject the pipeline.



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

Reply via email to