You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "jhkkhtd (via GitHub)" <gi...@apache.org> on 2023/03/01 12:40:52 UTC

[GitHub] [flink] jhkkhtd opened a new pull request, #22054: Fix the SQL Problem to create and close zookeepr connections frequently

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-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


[GitHub] [flink] flinkbot commented on pull request #22054: [FLINK-31282][Client]Fix the SQL Problem to create and close zookeepr connections frequently

Posted by "flinkbot (via GitHub)" <gi...@apache.org>.
flinkbot commented on PR #22054:
URL: https://github.com/apache/flink/pull/22054#issuecomment-1450095545

   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "36ae45b448760acb79f4ac6195fd1238d08092ef",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "36ae45b448760acb79f4ac6195fd1238d08092ef",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 36ae45b448760acb79f4ac6195fd1238d08092ef UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org