Acquired Transaction batch TxnId/WriteIds=[849/1...948/100] on endPoint = {metaStoreUri='thrift://221.221.221.5:9083', database='ods', table='test_dyh', partitionVals=[] }; TxnStatus[OOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOO] LastUsed txnid:0 08 六月 2023 10:18:49,099 WARN [SinkRunner-PollingRunner-DefaultSinkProcessor] (org.apache.flume.sink.hive.HiveSink.drainOneBatch:325) - k1 : Failed writing to : {metaStoreUri='thrift://221.221.221.5:9083', database='ods', table='test_dyh', partitionVals=[] }. TxnID : 849
时间: 2024-04-20 14:27:34 浏览: 73
获取进程ID
这段日志信息是关于Flume中的Hive Sink组件的。其中,Acquired Transaction batch TxnId/WriteIds=[849/1...948/100]表示获取了一个事务批次,TxnId为849,包含了1到100个写入操作。endPoint指定了写入数据的Hive表的元数据信息,包括所属的数据库(ods)、表(test_dyh)和分区信息。TxnStatus[OOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOO]表示该事务批次的状态,这里全为'0'表示所有操作都还未提交。LastUsed txnid:0表示上一次使用的事务ID为0。最后的WARN日志表示写入数据到Hive表时出错,TxnID为849的事务写入失败。
阅读全文