You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@linkis.apache.org by pe...@apache.org on 2022/05/23 12:34:45 UTC
[incubator-linkis] branch dev-1.1.3 updated: fix entrance resultset path (#2162)
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 <xu...@qq.com>
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: commits-unsubscribe@linkis.apache.org
For additional commands, e-mail: commits-help@linkis.apache.org