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

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

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

Shang Yuanchun (Jira)
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)