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: 成彬彬 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
