Yun Gao created FLINK-28824:
-------------------------------
Summary:
StreamingJobGraphGenerator#triggerSerializationAndReturnFuture might swallow
exception
Key: FLINK-28824
URL: https://issues.apache.org/jira/browse/FLINK-28824
Project: Flink
Issue Type: Bug
Components: API / DataStream
Affects Versions: 1.16.0
Reporter: Yun Gao
Currently the `triggerSerializationAndReturnFuture` is executed in a separate
thread. Currently when this method throws exception (for example, users may
pass an UDF that is not serializable), then the main thread would be blocked.
We'd better fail the future for any exception thrown in this thread.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
