故障排除连接操作

原因

每个输入流的组键不相同。 join 包中的函数使用组键来快速识别应比较哪些表。

解决方案

使用 group() 重新分组您的两个输入流，以便它们的组键在尝试将它们连接在一起之前匹配。

原因

您的数据流中没有匹配的组键实例。 join 包中的函数仅比较具有匹配的组键实例的表。 输入流可能具有匹配的组键，但您的流中没有匹配的组键实例。

当连接从 InfluxDB 查询的两个单独的字段时，可能会发生这种情况。 默认情况下，InfluxDB 返回的数据的组键中包含 _field。 如果每个流包含不同的字段，则不会比较两个流中的表，因为它们没有任何匹配的组键实例。

解决方案

使用 group() 从每个输入流的组键中删除任何会阻止组键实例匹配的列。

原因

您的 on 连接谓词使用不存在的列。 在 on 谓词函数中，您尝试比较输入流之一中不存在的列。

解决方案

确保您在 on 谓词函数中比较的列存在于输入流中。 如果需要，请更新谓词函数中的列名。

原因

您的 on 连接谓词使用不存在的列。 在外部连接的 on 谓词函数中，您尝试使用来自“主”输入流（join.left() 的 left 和 join.right() 的 right）中不存在的列的值。

解决方案

确保您在 on 谓词函数中比较的列实际存在于输入流中。 如果需要，请更新谓词函数中的列名。

原因

您的 on 连接谓词使用不存在的列。 在 on 谓词函数中，您尝试比较输入流之一中不存在的列。

解决方案

确保您在 on 谓词函数中比较的列实际存在于输入流中。 如果需要，请更新谓词函数中的列名。

原因

您的 as 输出模式函数使用不存在的列。 如果使用外部连接，则 as 尝试使用来自“主”输入流（join.left() 的 left 和 join.right() 的 right）中不存在的列的值。

解决方案

确保您在 as 输出函数中用于为输出赋值的列实际存在于输入流中。

原因

您的输入流之一是空的表流。 当一个或两个输入流为空时，连接包中的函数会出错。

解决方案

使用 array.from() 和 union() 在每个流中插入一个虚拟表，您可以在连接操作后将其过滤掉。 虚拟表需要包含与其联合的流的所有组键列。