Support to remove the limit apache#1573

WeDataSphere · Mar 5, 2022 · 0540753 · 0540753
1 parent 3a21bdc
commit 0540753
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/.../main/scala/org/apache/linkis/entrance/interceptor/impl/SQLLimitEntranceInterceptor.scala b/.../main/scala/org/apache/linkis/entrance/interceptor/impl/SQLLimitEntranceInterceptor.scala
@@ -17,6 +17,7 @@
 
 package org.apache.linkis.entrance.interceptor.impl
 
+import org.apache.linkis.common.log.LogUtils
 import org.apache.linkis.entrance.conf.EntranceConfiguration
 import org.apache.linkis.entrance.interceptor.EntranceInterceptor
 import org.apache.linkis.governance.common.entity.job.JobRequest
@@ -27,11 +28,11 @@ class SQLLimitEntranceInterceptor extends EntranceInterceptor {
   private val  LIMIT_CREATORS = EntranceConfiguration.SQL_LIMIT_CREATOR.getValue
 
   override def apply(task: JobRequest, logAppender: java.lang.StringBuilder): JobRequest = {
-    /*val (user, creator) = LabelUtil.getUserCreator(task.getLabels)
+    val (user, creator) = LabelUtil.getUserCreator(task.getLabels)
     if (! LIMIT_CREATORS.contains(creator)) {
       logAppender.append(LogUtils.generateWarn(s"The code you submit will not be limited by the limit \n") )
       return task
-    }*/
+    }
     val codeType = {
       val codeType = LabelUtil.getCodeType(task.getLabels)
       if (null != codeType) {