We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4f108ba commit f6e89b1Copy full SHA for f6e89b1
ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h
@@ -1674,6 +1674,9 @@ class TDqComputeActorBase : public NActors::TActorBootstrapped<TDerived>
1674
auto inputIndex = protoSource.GetInputIndex();
1675
if (auto* sourceInfoPtr = SourcesMap.FindPtr(inputIndex)) {
1676
auto& sourceInfo = *sourceInfoPtr;
1677
+ if (!sourceInfo.AsyncInput)
1678
+ continue;
1679
+
1680
protoSource.SetIngressName(sourceInfo.Type);
1681
const auto& ingressStats = sourceInfo.AsyncInput->GetIngressStats();
1682
FillAsyncStats(*protoSource.MutableIngress(), ingressStats);
0 commit comments