[jira] [Created] (BAHIR-324) BAHIR-322 JobManager created a kuduReader that was not closed, resulting in an increase in server handles

[ShiminHuang (Jira)]

ShiminHuang created BAHIR-324:
---------------------------------

             Summary: BAHIR-322 JobManager created a kuduReader that was not 
closed, resulting in an increase in server handles 
                 Key: BAHIR-324
                 URL: https://issues.apache.org/jira/browse/BAHIR-324
             Project: Bahir
          Issue Type: Bug
          Components: Flink Streaming Connectors
    Affects Versions: Flink-1.1.0
            Reporter: ShiminHuang
             Fix For: Flink-1.1.0
         Attachments: image-2023-05-30-15-03-38-388.png, 
image-2023-05-30-15-04-47-387.png, image-2023-05-30-15-05-33-472.png, 
image-2023-05-30-15-06-16-063.png

h1. Problem
{quote}When JobManager starts, the ExecutionJobVertex constructor calls the 
AbstractKuduInputFormat#createInputSplits method, Causes the KuduReader object 
to create the KuduClient and KuduSession objects, but ExecutionJobVertex does 
not call the Kudureader #close() method with the display, causing the 
Kudu-related handle to remain open after the Flink task is closed. As a result, 
the number of server handles increases with the number of Flink tasks. As a 
result, the entire server becomes unavailable{quote}
h1. Code

*ExecutionJobVertex#constructor*

!image-2023-05-30-15-03-38-388.png!

{*}AbstractKuduInputFormat#createInputSplits{*}{*}{*}

*!image-2023-05-30-15-04-47-387.png!*

{*}AbstractKuduInputFormat{*}{*}#startKuduReader{*}

{*}!image-2023-05-30-15-06-16-063.png!{*}{*}{*}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)