jhkkhtd opened a new pull request, #22054:
URL: https://github.com/apache/flink/pull/22054
[FLINK-31282][Componets: Client]
## What is the purpose of the change
Fix the Problem to **create and close zookeepr connections frequently**
when executing sql **Select** , In the next() function of
CollectResultFetcher. there are two functions called :
isJobTerminated() will call **jobClient.getJobStatus()**
sendRequest() willl call **gateway.sendCoordinationRequest()** .
Everytime , Both of them will **create and close a zookeeper connection**
In ClusterClientJobClientAdapter.bridgeClientRequet()
## Brief change log
I set a flag "isQuery" ,when it is true ,i will change to use the same
clusterclient. the Connection will be create and close just for once.
## Verifying this change
I got the right connection in my product cluster.
--
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
