架构使用spark streaming 消费kafka的数据，并通过impala来插入到kudu中，但是通过对比发现落地到kudu表中的数据比kafka消息数要少，通过后台日志发现，偶发性的出现java.sql.SQLException: [Simba][ImpalaJDBCDriver](500051) ERROR processing query/statement. Error Code: 0, SQL state: TStatus(statusCode:ERROR_STATUS, sqlState:HY000, errorMessage:AnalysisException: Syntax error in line 1