Go语言 2 数据库中查询对应Spark实例信息 sparkInstance err = fdbstorageGetSparkInstanceByIdDbinstanceId if err != nil klogErrorf定时刷新数据库中查询Spark实例失败 + errError return 3 Spark实例状态为冻结则不进行后续操作 if sparkInstanceStatu
这段代码是使用Go语言编写的,用于从数据库中查询对应的Spark实例信息。
首先,通过调用GetSparkInstanceByIdDb方法从数据库中查询指定instanceId的Spark实例信息,并将结果赋值给sparkInstance变量。如果查询过程中出现错误,会将错误信息记录到日志中并返回。
接下来,通过判断sparkInstance的状态是否为冻结(constant.Freeze),如果是,则不进行后续操作,直接返回。
然后,通过调用cluster.Client方法获取与sparkInstance对应的客户端。如果获取客户端过程中出现错误,会将错误信息记录到日志中并返回。
这段代码主要用于查询Spark实例信息并获取相应的客户端,以便后续进行操作。
原文地址: http://www.cveoy.top/t/topic/iZQk 著作权归作者所有。请勿转载和采集!