cluster_app_logs.py 文件源码

def execute(args: typing.NamedTuple):
    spark_client = load_spark_client()

    if args.tail:
        utils.stream_logs(client=spark_client, cluster_id=args.cluster_id, application_name=args.app_name)
    else:
        app_logs = spark_client.get_application_log(cluster_id=args.cluster_id, application_name=args.app_name)
        print(app_logs.log)