Martijn Visser created FLINK-41185:
--------------------------------------
Summary: Migrate YarnTestJob to a self-contained Source V2 source
Key: FLINK-41185
URL: https://issues.apache.org/jira/browse/FLINK-41185
Project: Flink
Issue Type: Sub-task
Components: Test Infrastructure
Reporter: Martijn Visser
The job jar is shipped to YARN, where flink-test-utils-connector is not on the
classpath
(DataGeneratorSource is, through flink-dist), and the source has to stop when a
marker file is
deleted, which no existing source does. Needs a small nested Source V2.
Consumer:
YARNHighAvailabilityITCase.
--
This message was sent by Atlassian Jira
(v10.3.26#10030026)
