Skip to content

Commit

Permalink
Add a new management console to modify the engine status to UnHealthy…
Browse files Browse the repository at this point in the history
… and automatically kill the engine after task execution

The users can specify fixed engine execution
Add a new management console to modify the engine status to UnHealthy and automatically kill the engine after task execution
Optimize engine reuse logic, large resources cannot reuse small resource engines
Optimize the flink log
Linkis storage change java code to scala (The core process has some compatibility issues, and some of them have been reversed.)
  • Loading branch information
aiceflower authored Nov 5, 2024
1 parent 3647c31 commit 9036be6
Show file tree
Hide file tree
Showing 1,251 changed files with 35,831 additions and 50,606 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,7 @@ object Configuration extends Logging {
"The request interface %s is abnormal. You can try to troubleshoot common problems in the knowledge base document"
)

val LINKIS_TOKEN = CommonVars("wds.linkis.token", "LINKIS-AUTH-eTaYLbQpmIulPyrXcMl")
val LINKIS_TOKEN = CommonVars("wds.linkis.token", "LINKIS-AUTH")

val GLOBAL_CONF_CHN_NAME = "全局设置"

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -152,11 +152,11 @@ object HDFSUtils extends Logging {
hdfsFileSystemContainer.updateLastAccessTime
hdfsFileSystemContainer.getFileSystem
} else {
getHDFSUserFileSystem(userName, label, getConfiguration(userName, label))
getHDFSUserFileSystem(userName, label, getConfigurationByLabel(userName, label))
}
}
} else {
getHDFSUserFileSystem(userName, label, getConfiguration(userName, label))
getHDFSUserFileSystem(userName, label, getConfigurationByLabel(userName, label))
}
}

Expand Down

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

Loading

0 comments on commit 9036be6

Please sign in to comment.