linkis-public-enhancements/linkis-datasource/linkis-datasource-manager/server/src/main/java/org/apache/linkis/datasourcemanager/core/service/impl/DataSourceInfoServiceImpl.java (7 lines): - line 255: // TODO throws Exception - line 338: // TODO throws ERROR Exception - line 350: // TODO LOG and throws LinkisRuntimeException - line 467: // TODO NullPoint latestVersion - line 623: // TODO wrapped Exception - line 649: // TODO defined Exception - line 670: // TODO throws RPC Exception linkis-engineconn-plugins/hbase/hbase-shims-2.5.3/src/main/resources/hbase-ruby/hbase/admin.rb (5 lines): - line 151: # TODO: remove older hlog_roll version - line 472: # TODO: add table options support - line 814: # TODO: We should not require user to config the coprocessor with our inner format. - line 1171: # FIXME: fail gracefully if can't find the region - line 1495: # TODO: Keeping backward compatability for NORMALIZER_TARGET_REGION_SIZE with HBASE-25651 change. Can be removed in later version linkis-engineconn-plugins/hbase/hbase-shims-2.5.3/src/main/resources/hbase-ruby/hirb.rb (5 lines): - line 29: # TODO: Interrupt a table creation or a connection to a bad master. Currently - line 33: # TODO: Add support for listing and manipulating catalog tables, etc. - line 34: # TODO: Encoding; need to know how to go from ruby String to UTF-8 bytes - line 57: # FIXME: Switch args processing to getopt - line 154: # TODO avoid polluting main namespace by using a binding linkis-engineconn-plugins/hbase/hbase-shims-1.4.3/src/main/resources/hbase-ruby/hirb.rb (5 lines): - line 29: # TODO: Interrupt a table creation or a connection to a bad master. Currently - line 33: # TODO: Add support for listing and manipulating catalog tables, etc. - line 34: # TODO: Encoding; need to know how to go from ruby String to UTF-8 bytes - line 58: # FIXME: Switch args processing to getopt - line 166: # TODO avoid polluting main namespace by using a binding linkis-engineconn-plugins/hbase/hbase-shims-1.2.0/src/main/resources/hbase-ruby/hirb.rb (5 lines): - line 29: # TODO: Interrupt a table creation or a connection to a bad master. Currently - line 33: # TODO: Add support for listing and manipulating catalog tables, etc. - line 34: # TODO: Encoding; need to know how to go from ruby String to UTF-8 bytes - line 59: # FIXME: Switch args processing to getopt - line 158: # TODO avoid polluting main namespace by using a binding linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-core/src/main/scala/org/apache/linkis/ecm/core/launch/ProcessEngineConnLaunch.scala (5 lines): - line 83: case _ => // TODO exception - line 128: // TODO just replace it by sorted RANDOM_PORT, since only one RANDOM_PORT is used now. - line 142: ) // TODO exception - line 179: ) // TODO exception - line 257: // TODO env需要考虑顺序问题 linkis-engineconn-plugins/hbase/hbase-shims-2.2.6/src/main/resources/hbase-ruby/hirb.rb (5 lines): - line 29: # TODO: Interrupt a table creation or a connection to a bad master. Currently - line 33: # TODO: Add support for listing and manipulating catalog tables, etc. - line 34: # TODO: Encoding; need to know how to go from ruby String to UTF-8 bytes - line 57: # FIXME: Switch args processing to getopt - line 154: # TODO avoid polluting main namespace by using a binding linkis-engineconn-plugins/hbase/hbase-shims-2.2.6/src/main/resources/hbase-ruby/hbase/admin.rb (4 lines): - line 139: # TODO: remove older hlog_roll version - line 414: # TODO: add table options support - line 781: # TODO: We should not require user to config the coprocessor with our inner format. - line 1082: # FIXME: fail gracefully if can't find the region linkis-computation-governance/linkis-entrance/src/main/scala/org/apache/linkis/entrance/EntranceWebSocketService.scala (3 lines): - line 99: ) // TODO Time interval(时间间隔做成参数) - line 157: ) // TODO Time interval(时间间隔做成参数) - line 178: // TODO Convert to a suitable Map(转换成合适的Map) linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/loader/loaders/resource/BmlEngineConnPluginResourceLoader.java (3 lines): - line 142: // TODO maybe has the same name directory? - line 213: // TODO has a problem, we don't know the source file name or suffix name of tmp file - line 232: // TODO get resourceId from database by engineTypeLabel? linkis-engineconn-plugins/hbase/hbase-shims-1.4.3/src/main/resources/hbase-ruby/hbase/admin.rb (3 lines): - line 96: # TODO remove older hlog_roll version - line 326: # TODO: add table options support - line 890: # FIXME: fail gracefully if can't find the region linkis-orchestrator/linkis-orchestrator-core/src/main/scala/org/apache/linkis/orchestrator/execution/impl/BaseTaskScheduler.scala (3 lines): - line 61: // TODO Should support to add task to ready queue, since a complex scheduler is needed, - line 63: // TODO Here, we should also remove the futures which is completed normally in taskFutureCache and taskIdTaskCache. - line 72: // TODO We should use this method to remove the futures in taskFutureCache, linkis-engineconn-plugins/hbase/hbase-shims-1.2.0/src/main/resources/hbase-ruby/hbase/admin.rb (3 lines): - line 89: # TODO remove older hlog_roll version - line 266: # TODO: add table options support - line 860: # FIXME: fail gracefully if can't find the region linkis-commons/linkis-common/src/main/scala/org/apache/linkis/common/utils/ZipUtils.scala (2 lines): - line 270: // TODO never goto here - line 284: // TODO never goto here linkis-public-enhancements/linkis-cs-server/src/main/java/org/apache/linkis/cs/persistence/util/PersistenceUtils.java (2 lines): - line 128: // 非基本类型的话,使用jackson进行反序列化 // TODO: 2020/3/5 这里属性的序列化and反序列化最好修改为utils的序列化器 - line 157: // TODO: 2020/5/15 去掉重复的 linkis-engineconn-plugins/spark/src/main/scala/org/apache/linkis/engineplugin/spark/executor/SparkScalaExecutor.scala (2 lines): - line 127: // TODO When an exception is thrown, is there a shutdown here? I need to think about it again.(当抛出异常时,此处是否需要shutdown,需要再思考一下) - line 344: // TODO: have problem with scala2.13 or higher linkis-engineconn-plugins/hbase/hbase-shims-1.4.3/src/main/resources/hbase-ruby/hbase/security.rb (2 lines): - line 40: # TODO: need to validate user name - line 91: # TODO: need to validate user name linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/service/impl/DefaultECMHealthService.scala (2 lines): - line 124: // TODO: 历史查询 - line 154: // TODO: 持久化 剩余的reports linkis-orchestrator/linkis-orchestrator-core/src/main/scala/org/apache/linkis/orchestrator/core/impl/GlobalStateImpl.scala (2 lines): - line 27: override val globalResultSetPath: FsPath = null // TODO read from configuration - line 28: override val globalLogPath: FsPath = null // TODO read from configuration linkis-engineconn-plugins/flink/flink-core/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/parser/SqlCommandParserImpl.java (2 lines): - line 178: // TODO support describe extended - line 185: // TODO support explain details linkis-public-enhancements/linkis-pes-client/src/main/scala/org/apache/linkis/bml/client/impl/HttpBmlClient.scala (2 lines): - line 136: // TODO: 不能放非空的参数 - line 577: // TODO: 不能放非空的参数 linkis-public-enhancements/linkis-cs-server/src/main/java/org/apache/linkis/cs/persistence/persistence/impl/ContextMapPersistenceImpl.java (2 lines): - line 75: // TODO: 2020/2/17 keywords 如何合并 - line 132: // TODO: 2020/2/14 null return linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/label/service/impl/DefaultNodeLabelService.scala (2 lines): - line 85: * Attach labels to node instance TODO 该方法需要优化,应该batch插入 - line 118: // TODO: add method: getLabelsByServiceInstanceAndKey(instance, labelKey) linkis-orchestrator/linkis-orchestrator-core/src/main/scala/org/apache/linkis/orchestrator/execution/impl/DefaultTaskManager.scala (2 lines): - line 296: * TODO executionTaskAndRootExecTask Will clean up, the data is not the most complete, you need to - line 313: * condition 2) TODO Whether needs to do strict maximum task concurrency control, exit linkis-engineconn-plugins/hbase/hbase-shims-2.2.6/src/main/resources/hbase-ruby/hbase/security.rb (2 lines): - line 40: # TODO: need to validate user name - line 95: # TODO: need to validate user name linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-authentication/src/main/scala/org/apache/linkis/gateway/authentication/service/CachedTokenService.scala (2 lines): - line 69: TODO begin - line 104: TODO end linkis-engineconn-plugins/hbase/hbase-shims-1.2.0/src/main/resources/hbase-ruby/hbase/security.rb (2 lines): - line 41: # TODO: need to validate user name - line 92: # TODO: need to validate user name linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/label/service/impl/DefaultUserLabelService.scala (2 lines): - line 61: // TODO: persistence 这里最好提供个一次查询的方法 - line 101: // TODO: persistence 需要提供 key,valueString 找到相关label的方法 linkis-public-enhancements/linkis-datasource/linkis-datasource-manager/server/src/main/java/org/apache/linkis/datasourcemanager/core/service/impl/MetadataOperateServiceImpl.java (2 lines): - line 79: // TODO redefined a exception extends warnException - line 125: // TODO add strategy to fix the failure of deleting linkis-engineconn-plugins/hbase/hbase-shims-2.5.3/src/main/resources/hbase-ruby/hbase/security.rb (2 lines): - line 38: # TODO: need to validate user name - line 93: # TODO: need to validate user name linkis-public-enhancements/linkis-configuration/src/main/java/org/apache/linkis/configuration/restful/api/ConfigurationRestfulApi.java (2 lines): - line 113: // TODO: 2019/12/30 configKey参数校验 - line 333: // TODO: Add a refresh cache interface later linkis-public-enhancements/linkis-cs-server/src/main/java/org/apache/linkis/cs/contextcache/parser/DefaultContextKeyValueParser.java (2 lines): - line 64: // TODO Delete later - line 71: // TODO The contextKey default are keyword linkis-public-enhancements/linkis-datasource/linkis-datasource-manager/server/src/main/java/org/apache/linkis/metadata/query/server/service/impl/MetadataQueryServiceImpl.java (2 lines): - line 699: // TODO ERROR CODE - line 715: // TODO ERROR CODE linkis-computation-governance/linkis-jdbc-driver/src/main/java/org/apache/linkis/ujes/jdbc/LinkisBaseResultSet.java (2 lines): - line 440: // TODO method required by JDK 1.7 - line 446: // TODO method required by JDK 1.7 linkis-orchestrator/linkis-orchestrator-core/src/main/scala/org/apache/linkis/orchestrator/core/CacheStrategy.scala (2 lines): - line 24: val scope: Int = 0 // TODO: enum: ONLY_SESSION, ALL_SESSIONS - line 26: val cacheLevel: Int = 0 // TODO: enum: CS_CACHE, CS_AND_ENGINE_TYPES_CACHE linkis-computation-governance/linkis-client/linkis-cli/src/main/java/org/apache/linkis/cli/application/interactor/var/VarAccessImpl.java (1 line): - line 249: // TODO: throw or return null if not string map linkis-dist/helm/charts/linkis/templates/linkis-mg-gateway.yaml (1 line): - line 136: # TODO: replace with httpGet when spring-boot readiness probe is implemented. linkis-engineconn-plugins/flink/flink-core/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/impl/CreateViewOperation.java (1 line): - line 56: // TODO check the logic linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-httpclient-support/src/main/scala/org/apache/linkis/httpclient/dws/DWSHttpClient.scala (1 line): - line 145: // TODO Consistent with workspace, plus expiration time(与workspace保持一致,加上过期时间) linkis-web-next/src/pages/ECMManagement/index.vue (1 line): - line 182: // TODO: The ECM Engine Page linkis-public-enhancements/linkis-configuration/src/main/scala/org/apache/linkis/configuration/validate/ValidatorManagerImpl.scala (1 line): - line 45: // TODO: If it is custom, create a validator class with reflection(如果是自定义的,就用反射创建一个validator类) linkis-engineconn-plugins/hbase/hbase-shims-1.4.3/src/main/resources/hbase-ruby/shell/formatter.rb (1 line): - line 72: # TODO: Look at the type. Is it RowResult? linkis-computation-governance/linkis-engineconn/linkis-engineconn-executor/accessible-executor/src/main/scala/org/apache/linkis/engineconn/acessible/executor/info/NodeOverLoadInfoManager.scala (1 line): - line 26: // TODO linkis/windows/docker overload linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/ResultSetFactory.scala (1 line): - line 57: * TODO 修改为注册形式,并修改ResultSet的getResultType逻辑 Result set corresponding type record(结果集对应类型记录) linkis-public-enhancements/linkis-datasource/linkis-datasource-manager/service/hive/src/main/java/org/apache/linkis/metadata/query/service/HiveConnection.java (1 line): - line 80: // TODO choose an authentication strategy for hive, and then use createProxyUser linkis-public-enhancements/linkis-pes-client/src/main/scala/org/apache/linkis/cs/client/http/ContextAction.scala (1 line): - line 99: // TODO: 类太多了,放一个default linkis-public-enhancements/linkis-cs-server/src/main/java/org/apache/linkis/cs/server/scheduler/impl/CsSchedulerJob.java (1 line): - line 56: // TODO: 2020/2/18 linkis-public-enhancements/linkis-instance-label-server/src/main/java/org/apache/linkis/instance/label/service/impl/DefaultInsLabelServiceAdapter.java (1 line): - line 225: // TODO throw exception linkis-engineconn-plugins/hbase/hbase-shims-2.5.3/src/main/resources/hbase-ruby/shell/formatter.rb (1 line): - line 77: # TODO: Look at the type. Is it RowResult? linkis-orchestrator/linkis-orchestrator-core/src/main/scala/org/apache/linkis/orchestrator/domain/req/DataViewReq.scala (1 line): - line 56: null // TODO update linkis-engineconn-plugins/sqoop/src/main/scala/org/apache/linkis/engineconnplugin/sqoop/executor/SqoopOnceCodeExecutor.scala (1 line): - line 73: // TODO filter job content linkis-public-enhancements/linkis-pes-publicservice/src/main/scala/org/apache/linkis/filesystem/utils/UserGroupInfo.scala (1 line): - line 34: * TODO If other modules need to be used later, the tool class should be moved to the linkis-storage linkis-public-enhancements/linkis-cs-server/src/main/java/org/apache/linkis/cs/persistence/persistence/impl/TransactionManagerImpl.java (1 line): - line 52: // TODO: 2020/2/17 linkis-public-enhancements/linkis-cs-server/src/main/java/org/apache/linkis/cs/persistence/persistence/impl/ContextIDListenerPersistenceImpl.java (1 line): - line 53: // TODO: 2020/2/17 linkis-dist/helm/charts/linkis/templates/linkis-cg-engineconnmanager.yaml (1 line): - line 179: # TODO: replace with httpGet when spring-boot readiness probe is implemented. linkis-dist/helm/charts/linkis/templates/linkis-cg-linkismanager.yaml (1 line): - line 136: # TODO: replace with httpGet when spring-boot readiness probe is implemented. linkis-computation-governance/linkis-entrance/src/main/java/org/apache/linkis/entrance/restful/EntranceRestfulApi.java (1 line): - line 866: // TODO If failover during force kill, the job status may change from Cancelled to Running linkis-commons/linkis-module/src/main/scala/org/apache/linkis/server/utils/LinkisMainHelper.scala (1 line): - line 41: // TODO wait for linkis re-written linkis-engineconn-plugins/hbase/hbase-shims-2.5.3/src/main/resources/hbase-ruby/shell/commands/wal_roll.rb (1 line): - line 37: # TODO: remove old HLog version linkis-engineconn-plugins/hbase/hbase-shims-2.2.6/src/main/resources/hbase-ruby/shell/commands/wal_roll.rb (1 line): - line 37: # TODO: remove old HLog version linkis-public-enhancements/linkis-udf-service/src/main/java/org/apache/linkis/udf/service/impl/UDFTreeServiceImpl.java (1 line): - line 208: // TODO Determine if the user can list(判断用户是否可以list) linkis-public-enhancements/linkis-datasource/linkis-datasource-manager/server/src/main/java/org/apache/linkis/datasourcemanager/core/service/impl/BmlAppServiceImpl.java (1 line): - line 40: /** Wrap the communication between Bml service // TODO RPCException defined */ linkis-orchestrator/linkis-orchestrator-core/src/main/scala/org/apache/linkis/orchestrator/core/impl/TableOrchestration.scala (1 line): - line 43: // TODO val linkisDataViewCatalogPlugin: LinkisDataViewCatalogPlugin linkis-engineconn-plugins/flink/flink-core/src/main/java/org/apache/linkis/engineconnplugin/flink/client/result/ResultUtil.java (1 line): - line 90: // TODO cache this linkis-public-enhancements/linkis-datasource/linkis-datasource-manager/server/src/main/java/org/apache/linkis/metadata/query/server/loader/MetaClassLoaderManager.java (1 line): - line 53: /** Class Loader for metaClass // TODO used interface class */ linkis-engineconn-plugins/hbase/hbase-shims-1.2.0/src/main/resources/hbase-ruby/shell/commands/wal_roll.rb (1 line): - line 38: #TODO remove old HLog version linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/fs/impl/LocalFileSystem.java (1 line): - line 287: *

TODO Caching /etc/passwd information to the local as linkis-orchestrator/linkis-computation-orchestrator/src/main/scala/org/apache/linkis/orchestrator/computation/catalyst/optimizer/CacheTaskOptimizer.scala (1 line): - line 30: // TODO We should use CacheLabel to be judgment condition. If CacheLabel is not provided, we won't transform a CodeLogicalUnitTask to a CacheTask. linkis-computation-governance/linkis-client/linkis-cli/src/main/java/org/apache/linkis/cli/application/CtxBuilder.java (1 line): - line 61: /** generate Templates load env variables TODO: load version info */ linkis-computation-governance/linkis-client/linkis-computation-client/src/main/scala/org/apache/linkis/ujes/client/request/JobSubmitAction.scala (1 line): - line 44: // TODO: remove executeUser in the future linkis-orchestrator/linkis-orchestrator-core/src/main/scala/org/apache/linkis/orchestrator/planner/AbstractPlanner.scala (1 line): - line 50: // TODO Should LogicalContext in Planner and Optimizer be merged into one? linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/excel/StorageExcelWriter.scala (1 line): - line 138: // TODO: 是否需要替换null值 linkis-engineconn-plugins/hbase/hbase-shims-2.2.6/src/main/resources/hbase-ruby/shell.rb (1 line): - line 371: # TODO: remove older hlog_roll command linkis-engineconn-plugins/sqoop/src/main/scala/org/apache/linkis/engineconnplugin/sqoop/launch/SqoopEngineConnLaunchBuilder.scala (1 line): - line 95: // TODO we should decide separator in different environment linkis-computation-governance/linkis-entrance/src/main/scala/org/apache/linkis/entrance/interceptor/impl/LabelCheckInterceptor.scala (1 line): - line 86: // TODO: need one more check to see if userCreatorLabel equals executeUser linkis-engineconn-plugins/sqoop/src/main/java/org/apache/sqoop/mapreduce/JobBase.java (1 line): - line 281: // TODO: 'splitByCol' is import-job specific; lift it out of this API. linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-core/src/main/scala/org/apache/linkis/gateway/parser/GatewayParser.scala (1 line): - line 142: // TODO add version support linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/execute/EngineExecutionContext.scala (1 line): - line 130: // TODO executor.getEngineServerContext().getEngineAsyncListenerBus().post(ResultSetCreatedEvent(jId, output, alias)) linkis-computation-governance/linkis-client/linkis-computation-client/src/main/scala/org/apache/linkis/computation/client/once/simple/SimpleOnceJobBuilder.scala (1 line): - line 79: onceExecutorContent.setExtraLabels(new util.HashMap[String, AnyRef]) // TODO Set it if needed linkis-engineconn-plugins/hbase/hbase-shims-2.2.6/src/main/resources/hbase-ruby/shell/formatter.rb (1 line): - line 77: # TODO: Look at the type. Is it RowResult? linkis-public-enhancements/linkis-cs-server/src/main/java/org/apache/linkis/cs/contextcache/DefaultContextCacheService.java (1 line): - line 228: * TODO This method has poor performance and is not implemented now linkis-computation-governance/linkis-client/linkis-computation-client/src/main/scala/org/apache/linkis/ujes/client/utils/UJESClientUtils.scala (1 line): - line 43: * TODO At first Judge engine type linkis-engineconn-plugins/hbase/hbase-shims-2.5.3/src/main/resources/hbase-ruby/hbase/quotas.rb (1 line): - line 105: # TODO: Setting specified region server quota isn't supported currently and using 'all' for all RS linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/manager/DefaultEMNodeManager.java (1 line): - line 117: * Get detailed em information from the persistence TODO add label to node ? linkis-engineconn-plugins/hbase/hbase-shims-1.4.3/src/main/resources/hbase-ruby/shell/commands/wal_roll.rb (1 line): - line 38: #TODO remove old HLog version linkis-engineconn-plugins/hbase/hbase-shims-1.4.3/src/main/resources/hbase-ruby/shell.rb (1 line): - line 357: # TODO remove older hlog_roll command linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/service/impl/DefaultLocalDirsHandleService.scala (1 line): - line 29: // TODO: 检测当前磁盘的健康状态,如果目录满了,需要上报am linkis-commons/linkis-rpc/src/main/scala/org/apache/linkis/rpc/interceptor/common/CacheableRPCInterceptor.scala (1 line): - line 47: .initialCapacity(20) // TODO Make parameters(做成参数) linkis-engineconn-plugins/hbase/hbase-shims-2.2.6/src/main/resources/hbase-ruby/hbase/quotas.rb (1 line): - line 102: # TODO: Setting specified region server quota isn't supported currently and using 'all' for all RS linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/utils/StorageUtils.scala (1 line): - line 189: // TODO IO-client mode need return false linkis-engineconn-plugins/flink/flink-core/src/main/java/org/apache/linkis/engineconnplugin/flink/client/result/BatchResult.java (1 line): - line 61: // TODO supports large result set linkis-computation-governance/linkis-client/linkis-cli/src/main/java/org/apache/linkis/cli/application/interactor/validate/ParamValidator.java (1 line): - line 26: // TODO:throw linkis-commons/linkis-rpc/src/main/java/org/apache/linkis/rpc/message/parser/DefaultServiceParser.java (1 line): - line 43: // TODO: 2020/7/15 more analysis linkis-commons/linkis-scheduler/src/main/scala/org/apache/linkis/scheduler/queue/fifoqueue/FIFOUserConsumer.scala (1 line): - line 130: Utils.tryQuietly(Thread.sleep(1000)) // TODO 还可以优化,通过实现JobListener进行优化 linkis-public-enhancements/linkis-pes-client/src/main/scala/org/apache/linkis/cs/client/http/ContextResult.scala (1 line): - line 88: // TODO: 用来匹配所有的void 不需要处理返回值的result linkis-public-enhancements/linkis-cs-server/src/main/java/org/apache/linkis/cs/server/scheduler/impl/CsExecuteRequest.java (1 line): - line 29: // TODO: 2020/3/3 变量名修改 linkis-public-enhancements/linkis-pes-client/src/main/java/org/apache/linkis/cs/client/utils/ContextServiceUtils.java (1 line): - line 44: /** TODO get instances */ linkis-commons/linkis-storage/src/main/java/org/apache/linkis/storage/factory/impl/BuildHDFSFileSystem.java (1 line): - line 46: // TODO Agent user(代理的用户) linkis-orchestrator/linkis-orchestrator-core/src/main/scala/org/apache/linkis/orchestrator/execution/impl/UserRunningNumber.scala (1 line): - line 73: * TODO Unified getKey method linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/resource/DriverAndKubernetesResource.java (1 line): - line 87: return false; // TODO This method needs to return false by default, and this method needs to be linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/domain/RMLabelContainer.java (1 line): - line 181: // TODO lock sequence linkis-public-enhancements/linkis-pes-publicservice/src/main/java/org/apache/linkis/filesystem/restful/api/FsRestfulApi.java (1 line): - line 475: // TODO: 2018/11/29 Judging the directory, the directory cannot be linkis-computation-governance/linkis-entrance/src/main/scala/org/apache/linkis/entrance/event/EntranceEvent.scala (1 line): - line 30: //TODO Subsequent optimization, temporarily use this(后续优化,暂时这么用) linkis-dist/helm/charts/linkis/templates/linkis-ps-publicservice.yaml (1 line): - line 148: # TODO: replace with httpGet when spring-boot readiness probe is implemented. linkis-computation-governance/linkis-client/linkis-cli/src/main/java/org/apache/linkis/cli/application/operator/once/OnceJobOper.java (1 line): - line 65: } // TODO: remove parsing and let server side parse engineType linkis-orchestrator/linkis-orchestrator-core/src/main/scala/org/apache/linkis/orchestrator/core/impl/OrchestratorContextImpl.scala (1 line): - line 28: // TODO read from configuration linkis-orchestrator/linkis-computation-orchestrator/src/main/scala/org/apache/linkis/orchestrator/computation/utils/TreeNodeUtil.scala (1 line): - line 35: // TODO 考虑TreeNode修改的并发操作问题 linkis-computation-governance/linkis-entrance/src/main/scala/org/apache/linkis/entrance/interceptor/OnceJobInterceptor.scala (1 line): - line 76: onceExecutorContent.setExtraLabels(new util.HashMap[String, AnyRef]) // TODO Set it if needed linkis-public-enhancements/linkis-datasource/linkis-datasource-manager/service/hdfs/src/main/java/org/apache/linkis/metadata/query/service/HdfsConnection.java (1 line): - line 46: // TODO fix the problem of connecting multiple cluster in FSFactory.getFSByLabelAndUser linkis-dist/helm/charts/linkis/templates/linkis-cg-entrance.yaml (1 line): - line 143: # TODO: replace with httpGet when spring-boot readiness probe is implemented. linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/service/impl/BmlResourceLocalizationService.scala (1 line): - line 72: // TODO: engineType判断是否下载到本地 unzip linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/manager/DefaultEngineNodeManager.java (1 line): - line 183: * TODO use Engine需要考虑流式引擎的场景,后续需要通过Label加额外的处理 linkis-dist/helm/charts/linkis/templates/linkis-web.yaml (1 line): - line 88: # TODO: replace with httpGet when spring-boot readiness probe is implemented. linkis-public-enhancements/linkis-cs-server/src/main/java/org/apache/linkis/cs/contextcache/index/DefaultContextInvertedIndex.java (1 line): - line 31: /** TODO Added ContextKey scoring feature */ linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/selector/rule/ConcurrencyNodeSelectRule.scala (1 line): - line 32: // 2. TODO 通过标签判断engine是否支持并发,如果Engine为io,状态,当支持并发engine需要进行保留 linkis-computation-governance/linkis-entrance/src/main/scala/org/apache/linkis/entrance/scheduler/EntranceSchedulerContext.scala (1 line): - line 55: : ListenerEventBus[_ <: SchedulerEventListener, _ <: ScheduleEvent] = null // TODO wait for linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/service/impl/AbstractEngineConnLaunchService.scala (1 line): - line 176: // TODO: null 抛出异常 linkis-engineconn-plugins/hbase/hbase-shims-1.2.0/src/main/resources/hbase-ruby/shell.rb (1 line): - line 337: # TODO remove older hlog_roll command linkis-computation-governance/linkis-entrance/src/main/scala/org/apache/linkis/entrance/persistence/PersistenceManager.scala (1 line): - line 33: // TODO Need to support HA(需要支持HA) linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/script/VariableParser.scala (1 line): - line 67: // TODO need delete linkis-orchestrator/linkis-computation-orchestrator/src/main/scala/org/apache/linkis/orchestrator/computation/catalyst/physical/AbstractPhysicalTransform.scala (1 line): - line 34: // TODO rebuild needed! please refer to [[TaskPlannerTransform]]. linkis-engineconn-plugins/flink/flink-core/src/main/scala/org/apache/linkis/engineconnplugin/flink/executor/FlinkSQLComputationExecutor.scala (1 line): - line 207: // TODO wait for completed. linkis-engineconn-plugins/pipeline/src/main/scala/org/apache/linkis/manager/engineplugin/pipeline/executor/ExcelExecutor.scala (1 line): - line 66: // TODO: fs 加目录判断 linkis-engineconn-plugins/flink/flink-core/src/main/java/org/apache/linkis/engineconnplugin/flink/client/sql/operation/impl/SetOperation.java (1 line): - line 80: // TODO avoid to build a new Environment for some cases linkis-public-enhancements/linkis-configuration/src/main/scala/org/apache/linkis/configuration/service/CategoryService.scala (1 line): - line 100: // TODO use getOrElse linkis-public-enhancements/linkis-cs-server/src/main/java/org/apache/linkis/cs/server/scheduler/impl/CsJobListener.java (1 line): - line 51: // TODO: 2020/2/22 正常 /异常 linkis-engineconn-plugins/flink/flink-core/src/main/scala/org/apache/linkis/engineconnplugin/flink/factory/FlinkEngineConnFactory.scala (1 line): - line 389: // TODO Check if the path is already exists linkis-engineconn-plugins/spark/src/main/scala/org/apache/linkis/engineplugin/spark/cs/CSTableParser.scala (1 line): - line 89: * TODO From cs to get csTable Exact Match linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-core/src/main/scala/org/apache/linkis/gateway/security/UserRestful.scala (1 line): - line 388: // TODO use normal register only when it's implemented(仅当实现了通用注册,才可以调注册接口) linkis-engineconn-plugins/hbase/hbase-shims-2.5.3/src/main/resources/hbase-ruby/shell.rb (1 line): - line 489: # TODO: remove older hlog_roll command linkis-web/src/apps/linkis/components/cardList/index.vue (1 line): - line 42: linkis-public-enhancements/linkis-cs-server/src/main/java/org/apache/linkis/cs/server/service/impl/ContextListenerServiceImpl.java (1 line): - line 78: // TODO: 2020/2/28 linkis-engineconn-plugins/hbase/hbase-shims-1.2.0/src/main/resources/hbase-ruby/shell/formatter.rb (1 line): - line 72: # TODO: Look at the type. Is it RowResult? linkis-public-enhancements/linkis-cs-server/src/main/java/org/apache/linkis/cs/server/service/impl/ContextIDServiceImpl.java (1 line): - line 80: // TODO: 2020/2/23 reset 方法