我有多个查询运行在同一个星火结构的流会话上。查询是将拼花记录写入、Google、和检查点到Google。日志: at org.apache.spark.sql.execution.streaming.ManifestFileCommitProtocol.commitJob(ManifestFileCommitProtocol.scala:67)
at
当我尝试按id分组时,我丢失了规范值的所有其他外键,如果我按指定值删除组,则会得到大量的结果,每个结果都包含对值的自己的外键。(我将每一篇文章与各自的规格值连接起来)。我的查询(翻译和简化)如下:left join article_specification on article_specification.fk_ar
首先,这些是我的SQL表:FieldID INT (PK)FormFieldsFormID INT(FK)FieldID INT (FK)Value NVARCHAR(1000)FormID INT (PK)
FormName NVARCHAR(50每个表单都有0或更多的DataPool。每个Data