(beam) branch master updated: Fix log spam when using a JdbcIO DataSource not support Lineage report (#33514)

[yhu]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 005a3530fb2 Fix log spam when using a JdbcIO DataSource not support 
Lineage report (#33514)
005a3530fb2 is described below

commit 005a3530fb2986485518dc8196d0f59798cb6ca1
Author: Yi Hu <ya...@google.com>
AuthorDate: Mon Jan 13 16:52:11 2025 -0500

    Fix log spam when using a JdbcIO DataSource not support Lineage report 
(#33514)
---
 .../io/jdbc/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 ab2e3e07e81..39769495beb 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 @@ public class JdbcIO {
           }
           if (fqn != null) {
             fqn.reportLineage(Lineage.getSources(), table);
-            reportedLineage = table;
           }
+          reportedLineage = table;
         }
       }
       return connection;
@@ -2717,8 +2717,8 @@ public class JdbcIO {
           }
           if (fqn != null) {
             fqn.reportLineage(Lineage.getSinks(), table);
-            reportedLineage = table;
           }
+          reportedLineage = table;
         }
       }
       return connection;