Flink refine jdbc table name (OpenLineage#2512)

Signed-off-by: Zhenqiu Huang <huangzhenqiu0825@gmail.com> Signed-off-by: Ruihua Wang <ruihuawang@microsoft.com>
Ruihua98 · Mar 15, 2024 · 721d9a3 · 721d9a3
1 parent ece44ec
commit 721d9a3
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...on/flink/shared/src/main/java/io/openlineage/flink/visitor/wrapper/JdbcSourceWrapper.java b/...on/flink/shared/src/main/java/io/openlineage/flink/visitor/wrapper/JdbcSourceWrapper.java
@@ -56,7 +56,9 @@ public Optional<String> getTableName() {
 
     return queryOpt
         .flatMap(query -> OpenLineageSql.parse(List.of(query)))
-        .map(sqlMeta -> sqlMeta.inTables().isEmpty() ? "" : sqlMeta.inTables().get(0).name());
+        .map(
+            sqlMeta ->
+                sqlMeta.inTables().isEmpty() ? "" : sqlMeta.inTables().get(0).qualifiedName());
   }
 
   private Optional<JdbcConnectionOptions> getConnectionOptions() {