(kylin) 18/30: KYLIN-5867 Return job id for table sampling

[liyang]

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

liyang pushed a commit to branch kylin5
in repository https://gitbox.apache.org/repos/asf/kylin.git

commit dfbc63fc1d0b02f98c83cc8f01312bf9b8cbd93f
Author: fanfanAlice <41991994+fanfanal...@users.noreply.github.com>
AuthorDate: Mon Nov 6 14:31:11 2023 +0800

    KYLIN-5867 Return job id for table sampling
---
 .../java/org/apache/kylin/rest/controller/SampleController.java    | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git 
a/src/metadata-server/src/main/java/org/apache/kylin/rest/controller/SampleController.java
 
b/src/metadata-server/src/main/java/org/apache/kylin/rest/controller/SampleController.java
index a2709b0155..f2bf329c9b 100644
--- 
a/src/metadata-server/src/main/java/org/apache/kylin/rest/controller/SampleController.java
+++ 
b/src/metadata-server/src/main/java/org/apache/kylin/rest/controller/SampleController.java
@@ -123,9 +123,10 @@ public class SampleController extends NBasicController {
         checkSamplingTable(request.getQualifiedTableName());
         validatePriority(request.getPriority());
 
-        
tableSampleService.sampling(Sets.newHashSet(request.getQualifiedTableName()), 
request.getProject(),
-                request.getRows(), request.getPriority(), 
request.getYarnQueue(), request.getTag());
-        return new EnvelopeResponse<>(KylinException.CODE_SUCCESS, "", "");
+        List<String> sampleJobs = 
tableSampleService.sampling(Sets.newHashSet(request.getQualifiedTableName()),
+                request.getProject(), request.getRows(), 
request.getPriority(), request.getYarnQueue(),
+                request.getTag());
+        return new EnvelopeResponse<>(KylinException.CODE_SUCCESS, 
sampleJobs.stream().findFirst().orElse(null), "");
     }
 
     @ApiOperation(value = "hasSamplingJob", tags = { "AI" }, notes = "Update 
Param: qualified_table_name")