Azure 流分析 - LAG 函数在测试中运行良好，但在查询中运行不正常

如何解决Azure 流分析 - LAG 函数在测试中运行良好，但在查询中运行不正常

我有以下查询：

WITH currentVector AS (
SELECT 
    UnitId,[Read],ReadTime,--If it is the first read in the last 6 days
    CASE
        WHEN LAG(UnitId) OVER (PARTITION BY UnitId LIMIT DURATION(day,6)) IS NULL 
        THEN 1 ELSE 0 END [IsFirstRead],FROM IoTServerEventHub
TIMESTAMP BY ReadTime
) 

SELECT 
    UnitId,CASE 
        WHEN [IsFirstRead] = 0 
        THEN 1
        ELSE 0
    END IsValid
INTO DestinationEventHub
FROM currentVector

当我在 Azure 门户中测试此查询时 - 它工作正常。如果我有 2 次读取，并且它们之间的 ReadTime 时间超过 6 天（甚至一次读取和下一次读取之间的时间超过 1 年） - 两次读取都被标记为“6 天内的第一次”。但是，当我在生产中运行此查询时 - 第一次读取被标记为第一次，但第二次读取被标记为不是第一次，尽管它们之间相隔超过 6 天，并且时间戳是由 ReadTime 而不是由系统。

有什么理由吗？

谢谢！