sql - 如何在 Apache Beam 管道中处理 SQL Transformer 中的损坏记录

Question

我有一个带有 SQL 转换（方解石）的 Beam 管道，我希望能够知道哪些记录会根据记录中的值引发异常。我已经在 try/catch 中包围了我的转换，但它并没有真正做太多，我无法看到哪些确切的记录正在引发错误。这是转换的片段

try {
    sqlTransformed.apply("SQL transform", SqlTransform.query(sqlFile) );
}catch (Exception e){
    LOGGER.error("TRANSFORM ERROR: Failed sql transform");
    LOGGER.error(e.getMessage());
}

任何想法如何做到这一点？