1818package org .apache .linkis .engineconnplugin .flink .util
1919
2020import org .apache .linkis .common .exception .ErrorException
21- import org .apache .linkis .common .utils .Logging
21+ import org .apache .linkis .common .utils .{ ByteTimeUtils , Logging }
2222import org .apache .linkis .engineconn .core .executor .ExecutorManager
2323import org .apache .linkis .engineconn .executor .entity .YarnExecutor
2424import org .apache .linkis .engineconnplugin .flink .client .config .FlinkVersionThreadLocal
@@ -28,26 +28,19 @@ import org.apache.linkis.engineconnplugin.flink.config.FlinkEnvConfiguration
2828import org .apache .linkis .governance .common .conf .GovernanceCommonConf
2929import org .apache .linkis .governance .common .constant .ec .ECConstants
3030import org .apache .linkis .manager .common .entity .enumeration .NodeStatus
31-
3231import org .apache .commons .lang3 .StringUtils
3332import org .apache .flink
3433import org .apache .flink .client .program .rest .RestClusterClient
3534import org .apache .flink .configuration .{HighAvailabilityOptions , JobManagerOptions , RestOptions }
3635import org .apache .flink .runtime .client .JobStatusMessage
3736import org .apache .flink .yarn .configuration .YarnConfigOptions
3837import org .apache .hadoop .conf .Configuration
39- import org .apache .hadoop .yarn .api .records .{
40- ApplicationId ,
41- ApplicationReport ,
42- FinalApplicationStatus ,
43- YarnApplicationState
44- }
38+ import org .apache .hadoop .yarn .api .records .{ApplicationId , ApplicationReport , FinalApplicationStatus , YarnApplicationState }
4539import org .apache .hadoop .yarn .client .api .YarnClient
4640import org .apache .hadoop .yarn .conf .YarnConfiguration
4741import org .apache .hadoop .yarn .util .ConverterUtils
4842
4943import java .util
50-
5144import scala .collection .JavaConverters .collectionAsScalaIterableConverter
5245import scala .collection .mutable .ArrayBuffer
5346
0 commit comments