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

apache · Jan 7, 2025 · 83b6303 · 83b6303
1 parent e0b04bf
commit 83b6303
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;