Fix log spam when using a JdbcIO DataSource not support Lineage report (

#33514)
apache · Jan 13, 2025 · 005a353 · 005a353
1 parent b82bde8
commit 005a353
Showing 1 changed file with 2 additions and 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
@@ -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;