【发布时间】:2022-01-16 22:57:26
【问题描述】:
我有一个 Azure 流分析作业,它使用一些参考数据来增强传入数据。其中一些,例如。 G。物理地址不会经常变化。
一个通用脚本应该是这样的。
SELECT
a.input1
a.input2
b.input1
INTO output
from a
LEFT JOIN metadata AS b ON a.input1 = b.input1
如果我尝试运行此脚本,则会收到错误消息:
系统异常 算术运算导致溢出。 在 Microsoft.Streaming.StreamingNode.ReferenceData.DiscoveryCursor.get_NextDiscoveryDueTimeInMillisecond() 在 Microsoft.Streaming.StreamingNode.ReferenceData.ReferenceDataDiscoveryStrategyBase.Discover() 在 Microsoft.Streaming.StreamingNode.ReferenceData.ReferenceDataDiscoveryProcessor.Process(布尔 isInitialization) 在 Microsoft.Streaming.StreamingNode.ReferenceData.ReferenceDataDiscoveryProcessor.InitializeInput() 在 Microsoft.Streaming.StreamingNode.ProcessorScheduler.InitializeTopology(CancellationToken cToken) 在 Microsoft.Streaming.StreamingNode.ProcessorScheduler.ThreadProc()
我逐步简化了脚本。消除 select 语句中所有 b 的概念是不够的,我什至不得不删除 Join 语句。
困扰我的是没有算术运算,所以我不知道溢出应该从哪里来。而且我数据库中的参考数据非常简单。
【问题讨论】:
-
非常感谢您的反馈。我会调查的。根据您在下面的发现,它看起来像是计时器上的某种溢出。我会跟进的。
-
我重现了这个问题并在我们这边创建了一个错误。我会及时通知你。
标签: azure-stream-analytics stream-analytics