[flink] branch master updated: [hotfix][connector][jdbc] Corrected exception variable name (#16662)

[tison]

This is an automated email from the ASF dual-hosted git repository.

tison pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 35ac5e5  [hotfix][connector][jdbc] Corrected exception variable name 
(#16662)
35ac5e5 is described below

commit 35ac5e58cfbc57ad9ebca16dd52d36a5deba54d8
Author: mans2singh <mans2si...@users.noreply.github.com>
AuthorDate: Wed Aug 4 22:27:39 2021 -0400

    [hotfix][connector][jdbc] Corrected exception variable name (#16662)
---
 .../flink/connector/jdbc/table/JdbcRowDataLookupFunction.java       | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataLookupFunction.java
 
b/flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataLookupFunction.java
index 99f22a0..5a659f3 100644
--- 
a/flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataLookupFunction.java
+++ 
b/flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataLookupFunction.java
@@ -191,11 +191,11 @@ public class JdbcRowDataLookupFunction extends 
TableFunction<RowData> {
                         connectionProvider.closeConnection();
                         establishConnectionAndStatement();
                     }
-                } catch (SQLException | ClassNotFoundException excpetion) {
+                } catch (SQLException | ClassNotFoundException exception) {
                     LOG.error(
                             "JDBC connection is not valid, and reestablish 
connection failed",
-                            excpetion);
-                    throw new RuntimeException("Reestablish JDBC connection 
failed", excpetion);
+                            exception);
+                    throw new RuntimeException("Reestablish JDBC connection 
failed", exception);
                 }
 
                 try {