(hudi) branch branch-0.x updated: [MINOR] fix(datahub-sync): fixes database path for dataset's browse path (#13321)

[xushiyan]

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

xushiyan pushed a commit to branch branch-0.x
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/branch-0.x by this push:
     new e506d79991f [MINOR] fix(datahub-sync): fixes database path for 
dataset's browse path (#13321)
e506d79991f is described below

commit e506d79991f21f10d84e350f276ff3cca053de5a
Author: Sergio Gómez Villamor <sgomezvilla...@gmail.com>
AuthorDate: Wed May 21 02:04:45 2025 +0200

    [MINOR] fix(datahub-sync): fixes database path for dataset's browse path 
(#13321)
    
    
    Backport PR https://github.com/apache/hudi/pull/13318
---
 .../main/java/org/apache/hudi/sync/datahub/DataHubSyncClient.java   | 2 +-
 .../java/org/apache/hudi/sync/datahub/TestDataHubSyncClient.java    | 6 ++++--
 2 files changed, 5 insertions(+), 3 deletions(-)

diff --git 
a/hudi-sync/hudi-datahub-sync/src/main/java/org/apache/hudi/sync/datahub/DataHubSyncClient.java
 
b/hudi-sync/hudi-datahub-sync/src/main/java/org/apache/hudi/sync/datahub/DataHubSyncClient.java
index 4c0cd13da77..f594862e5fb 100644
--- 
a/hudi-sync/hudi-datahub-sync/src/main/java/org/apache/hudi/sync/datahub/DataHubSyncClient.java
+++ 
b/hudi-sync/hudi-datahub-sync/src/main/java/org/apache/hudi/sync/datahub/DataHubSyncClient.java
@@ -343,7 +343,7 @@ public class DataHubSyncClient extends HoodieSyncClient {
   }
 
   private Stream<MetadataChangeProposalWrapper> createDatasetEntity() {
-    BrowsePathEntry databasePath = new 
BrowsePathEntry().setUrn(databaseUrn).setId(databaseName);
+    BrowsePathEntry databasePath = new 
BrowsePathEntry().setUrn(databaseUrn).setId(databaseUrn.toString());
     List<BrowsePathEntry> paths = dataPlatformInstanceUrn.map(dpiUrn -> {
       List<BrowsePathEntry> list = new ArrayList<BrowsePathEntry>();
       list.add(new BrowsePathEntry().setUrn(dpiUrn).setId(dpiUrn.toString()));
diff --git 
a/hudi-sync/hudi-datahub-sync/src/test/java/org/apache/hudi/sync/datahub/TestDataHubSyncClient.java
 
b/hudi-sync/hudi-datahub-sync/src/test/java/org/apache/hudi/sync/datahub/TestDataHubSyncClient.java
index 30d7eb8e405..69735628977 100644
--- 
a/hudi-sync/hudi-datahub-sync/src/test/java/org/apache/hudi/sync/datahub/TestDataHubSyncClient.java
+++ 
b/hudi-sync/hudi-datahub-sync/src/test/java/org/apache/hudi/sync/datahub/TestDataHubSyncClient.java
@@ -134,7 +134,8 @@ public class TestDataHubSyncClient {
     
expectedProposalsMap.put("urn:li:dataset:(urn:li:dataPlatform:hudi,default.unknown,DEV)+status",
 "{removed=false}");
     
expectedProposalsMap.put("urn:li:dataset:(urn:li:dataPlatform:hudi,default.unknown,DEV)+subTypes",
 "{typeNames=[Table]}");
     
expectedProposalsMap.put("urn:li:dataset:(urn:li:dataPlatform:hudi,default.unknown,DEV)+dataPlatformInstance",
 "{platform=urn:li:dataPlatform:hudi}");
-    
expectedProposalsMap.put("urn:li:dataset:(urn:li:dataPlatform:hudi,default.unknown,DEV)+browsePathsV2",
 "{path=[{urn=urn:li:container:ca5c62a21c8486b650b16634aacd3996, 
id=default}]}");
+    
expectedProposalsMap.put("urn:li:dataset:(urn:li:dataPlatform:hudi,default.unknown,DEV)+browsePathsV2",
 "{path=[{urn=urn:li:container:ca5c62a21c8486b650b16634aacd3996"
+        + ", id=urn:li:container:ca5c62a21c8486b650b16634aacd3996}]}");
     
expectedProposalsMap.put("urn:li:dataset:(urn:li:dataPlatform:hudi,default.unknown,DEV)+container",
 "{container=urn:li:container:ca5c62a21c8486b650b16634aacd3996}");
     
expectedProposalsMap.put("urn:li:dataset:(urn:li:dataPlatform:hudi,default.unknown,DEV)+schemaMetadata",
 "{platformSchema={com.linkedin.schema.OtherSchema={rawSchema"
         + 
"={\"type\":\"record\",\"name\":\"triprec\",\"fields\":[{\"name\":\"ts\",\"type\":\"long\"}]}}},
 schemaName=triprec, fields=[{nullable=false, fieldPath=[version=2.0]"
@@ -183,7 +184,8 @@ public class TestDataHubSyncClient {
     
expectedProposalsMap.put("urn:li:dataset:(urn:li:dataPlatform:hudi,test_instance.default.unknown,DEV)+dataPlatformInstance",
 "{platform=urn:li:dataPlatform:hudi, instance="
         + 
"urn:li:dataPlatformInstance:(urn:li:dataPlatform:hudi,test_instance)}");
     
expectedProposalsMap.put("urn:li:dataset:(urn:li:dataPlatform:hudi,test_instance.default.unknown,DEV)+browsePathsV2",
 "{path=[{urn=urn:li:dataPlatformInstance:(urn:li:dataPlatform"
-        + ":hudi,test_instance), 
id=urn:li:dataPlatformInstance:(urn:li:dataPlatform:hudi,test_instance)}, 
{urn=urn:li:container:da9c1430eb7551811f4c0e11b911614d, id=default}]}");
+        + ":hudi,test_instance), 
id=urn:li:dataPlatformInstance:(urn:li:dataPlatform:hudi,test_instance)}, 
{urn=urn:li:container:da9c1430eb7551811f4c0e11b911614d"
+        + ", id=urn:li:container:da9c1430eb7551811f4c0e11b911614d}]}");
     
expectedProposalsMap.put("urn:li:dataset:(urn:li:dataPlatform:hudi,test_instance.default.unknown,DEV)+container",
 "{container=urn:li:container:da9c1430eb7551811f4c0e11b911614d}");
     
expectedProposalsMap.put("urn:li:dataset:(urn:li:dataPlatform:hudi,test_instance.default.unknown,DEV)+schemaMetadata",
 "{platformSchema={com.linkedin.schema.OtherSchema={rawSchema"
         + 
"={\"type\":\"record\",\"name\":\"triprec\",\"fields\":[{\"name\":\"ts\",\"type\":\"long\"}]}}},
 schemaName=triprec, fields=[{nullable=false, fieldPath=[version=2.0]"