kbendick commented on issue #3091: URL: https://github.com/apache/iceberg/issues/3091#issuecomment-918565958
The CountdownLatch used here to keep the source open seems to be one possible solution: https://github.com/apache/flink/blob/313e20e8e03953a5e1cec9daa467f561ccfbd599/flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/StreamingExecutionFileSinkITCase.java#L55-L73 I notice that we have some handling for this case, so I think it's just the addition of this two separate DAGs test that is causing this problem. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
