Manhua

Contents

1. 1. 查询

查询

• 启动类：org.apache.spark.sql.hive.thriftserver.HiveThriftServer2
• 服务：ThriftBinaryCLIService
• 执行SQL：org.apache.spark.sql.hive.thriftserver.SparkExecuteStatementOperation#runInternal/execute
  • HiveThriftServer2.eventManager.onStatementStart
    • SparkListenerThriftServerOperationStart 查询SQL
  • HiveThriftServer2.eventManager.onStatementParsed
    • SparkListenerThriftServerOperationParsed 查询计划

HiveSessionImpl: Operation log session directory is created: /tmp/hadoop/operation_logs/56873884-a22b-45cd-bfcd-0
d2a40d9ac87 都是空文件