spark on k8s daemonset collect log

[404]

hi, all


Spark runs on k8s, uses daemonset filebeat to collect logs, and writes them to 
elasticsearch. The docker logs are in json format, and each line is a json 
string. How to merge multi-line exceptions?