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

peacewong pushed a commit to branch dev-1.1.3
in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git


The following commit(s) were added to refs/heads/dev-1.1.3 by this push:
     new d135ccd93 fix entrance resultset path (#2162)
d135ccd93 is described below

commit d135ccd9326c63d57b9e8885f704c73e30d5752a
Author: Alexyang <[email protected]>
AuthorDate: Mon May 23 20:34:38 2022 +0800

    fix entrance resultset path (#2162)
    
    * 1.  entrance - fix resultset path
    
    * 1.  entrance - fix resultset path
---
 .../entrance/interceptor/impl/StorePathEntranceInterceptor.scala       | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/linkis-computation-governance/linkis-entrance/src/main/scala/org/apache/linkis/entrance/interceptor/impl/StorePathEntranceInterceptor.scala
 
b/linkis-computation-governance/linkis-entrance/src/main/scala/org/apache/linkis/entrance/interceptor/impl/StorePathEntranceInterceptor.scala
index 5e14bc0cd..3eeb68032 100644
--- 
a/linkis-computation-governance/linkis-entrance/src/main/scala/org/apache/linkis/entrance/interceptor/impl/StorePathEntranceInterceptor.scala
+++ 
b/linkis-computation-governance/linkis-entrance/src/main/scala/org/apache/linkis/entrance/interceptor/impl/StorePathEntranceInterceptor.scala
@@ -52,7 +52,8 @@ class StorePathEntranceInterceptor extends 
EntranceInterceptor with Logging {
       val labelJson = 
BDPJettyServerHelper.gson.toJson(jobReq.getLabels.asScala.filter(_ != 
null).map(_.toString))
       throw new 
EntranceErrorException(EntranceErrorCode.LABEL_PARAMS_INVALID.getErrCode, 
s"UserCreator cannot be empty in labels : ${labelJson} of job with id : 
${jobReq.getId}")
     }
-    parentPath += DateFormatUtils.format(System.currentTimeMillis, 
"yyyyMMdd_HHmmss") + "/" +
+    // multi linkis cluster should not use same root folder , in which case 
result file may be overwrite
+    parentPath += DateFormatUtils.format(System.currentTimeMillis, 
"yyyy-MM-dd/HHmmss") + "/" +
       userCreator._2 + "/" + jobReq.getId
     val paramsMap = {
       val map = new util.HashMap[String, Any]()


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to