You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@linkis.apache.org by ca...@apache.org on 2022/09/01 15:44:06 UTC
[incubator-linkis] branch dev-1.3.1 updated: [linkis-engineplugin-sqoop] Modification of scala file floating red (#3192)
This is an automated email from the ASF dual-hosted git repository.
casion pushed a commit to branch dev-1.3.1
in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git
The following commit(s) were added to refs/heads/dev-1.3.1 by this push:
new c0315275a [linkis-engineplugin-sqoop] Modification of scala file floating red (#3192)
c0315275a is described below
commit c0315275ac4491265d2bd043f30e62e2b815c9d3
Author: 成彬彬 <10...@users.noreply.github.com>
AuthorDate: Thu Sep 1 23:44:02 2022 +0800
[linkis-engineplugin-sqoop] Modification of scala file floating red (#3192)
---
.../engineconnplugin/sqoop/executor/SqoopOnceCodeExecutor.scala | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/linkis-engineconn-plugins/sqoop/src/main/scala/org/apache/linkis/engineconnplugin/sqoop/executor/SqoopOnceCodeExecutor.scala b/linkis-engineconn-plugins/sqoop/src/main/scala/org/apache/linkis/engineconnplugin/sqoop/executor/SqoopOnceCodeExecutor.scala
index 7567d8aa1..9dd796540 100644
--- a/linkis-engineconn-plugins/sqoop/src/main/scala/org/apache/linkis/engineconnplugin/sqoop/executor/SqoopOnceCodeExecutor.scala
+++ b/linkis-engineconn-plugins/sqoop/src/main/scala/org/apache/linkis/engineconnplugin/sqoop/executor/SqoopOnceCodeExecutor.scala
@@ -42,6 +42,7 @@ import org.apache.linkis.protocol.engine.JobProgressInfo
import org.apache.linkis.scheduler.executer.ErrorExecuteResponse
import java.util
+import java.util.Locale
import java.util.concurrent.{Future, TimeUnit}
class SqoopOnceCodeExecutor(
@@ -100,7 +101,7 @@ class SqoopOnceCodeExecutor(
}
override protected def waitToRunning(): Unit = {
- if (!isCompleted)
+ if (!isCompleted) {
daemonThread = Utils.defaultScheduler.scheduleAtFixedRate(
new Runnable {
override def run(): Unit = {
@@ -113,13 +114,14 @@ class SqoopOnceCodeExecutor(
SqoopEnvConfiguration.SQOOP_STATUS_FETCH_INTERVAL.getValue.toLong,
TimeUnit.MILLISECONDS
)
+ }
}
override def getCurrentNodeResource(): NodeResource = {
val memorySuffix = "g"
val properties = EngineConnObject.getEngineCreationContext.getOptions
Option(properties.get(EngineConnPluginConf.JAVA_ENGINE_REQUEST_MEMORY.key)).foreach(memory => {
- if (!memory.toLowerCase.endsWith(memorySuffix)) {
+ if (!memory.toLowerCase(Locale.getDefault()).endsWith(memorySuffix)) {
properties.put(EngineConnPluginConf.JAVA_ENGINE_REQUEST_MEMORY.key, memory + memorySuffix)
}
})
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@linkis.apache.org
For additional commands, e-mail: commits-help@linkis.apache.org