You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Yun Gao (Jira)" <ji...@apache.org> on 2022/08/05 06:37:00 UTC

[jira] [Created] (FLINK-28824) StreamingJobGraphGenerator#triggerSerializationAndReturnFuture might swallow exception

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)