From 005a3530fb2986485518dc8196d0f59798cb6ca1 Mon Sep 17 00:00:00 2001
From: Yi Hu <yathu@google.com>
Date: Mon, 13 Jan 2025 16:52:11 -0500
Subject: [PATCH] Fix log spam when using a JdbcIO DataSource not support
 Lineage report (#33514)

---
 .../src/main/java/org/apache/beam/sdk/io/jdbc/JdbcIO.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcIO.java b/sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcIO.java
index ab2e3e07e817..39769495beb6 100644
--- a/sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcIO.java
+++ b/sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcIO.java
@@ -1649,8 +1649,8 @@ private Connection getConnection() throws SQLException {
           }
           if (fqn != null) {
             fqn.reportLineage(Lineage.getSources(), table);
-            reportedLineage = table;
           }
+          reportedLineage = table;
         }
       }
       return connection;
@@ -2717,8 +2717,8 @@ private Connection getConnection() throws SQLException {
           }
           if (fqn != null) {
             fqn.reportLineage(Lineage.getSinks(), table);
-            reportedLineage = table;
           }
+          reportedLineage = table;
         }
       }
       return connection;