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

Posted to issues@flink.apache.org by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2019/12/06 18:18:00 UTC

[jira] [Created] (FLINK-15116) Make JobClient stateless, remove AutoCloseable

Aljoscha Krettek created FLINK-15116:
----------------------------------------

             Summary: Make JobClient stateless, remove AutoCloseable
                 Key: FLINK-15116
                 URL: https://issues.apache.org/jira/browse/FLINK-15116
             Project: Flink
          Issue Type: Sub-task
          Components: API / DataSet, API / DataStream
            Reporter: Aljoscha Krettek


Currently, {{JobClient}} is {{AutoCloseable}} and we require users to close the {{JobClient}} that they get as a result from {{executeAsync()}}. This is problematic because users can simply ignore the result of {{executeAsync()}} and then we will leak the resources that the client has.

We should change the {{JobClient}} so that it acquires the required {{ClusterClient}} for each method call and closes it again. 

This means that the users no longer have the burden of managing the JobClient lifecycle, i.e. they can freely ignore the result of executeAsync().



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