-
Notifications
You must be signed in to change notification settings - Fork 735
[YQL-17453] Fix expanding DqReplicate with different input/output stream/flow types #818
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[YQL-17453] Fix expanding DqReplicate with different input/output stream/flow types #818
Conversation
nepal
commented
Dec 29, 2023
- fix DqReplicate expansion
|
Note This is an automated comment that will be appended during run. 🔴 linux-x86_64-release-asan: some tests FAILED for commit 1db72be.
🔴 linux-x86_64-relwithdebinfo: some tests FAILED for commit 1db72be.
|
| TVector<TExprBase> branches; | ||
| branches.reserve(dqReplicate.Args().Count() - 1); | ||
| const auto inputKind = dqReplicate.Arg(0).Ref().GetTypeAnn()->GetKind(); | ||
| YQL_ENSURE(inputKind == ETypeAnnotationKind::Stream || inputKind == ETypeAnnotationKind::Flow); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Разве может быть что-то другое по типизации?
| branches.emplace_back(ctx.DeepCopyLambda(dqReplicate.Args().Get(i).Ref())); | ||
| const auto lambdaOutputKind = dqReplicate.Arg(i).Ref().GetTypeAnn()->GetKind(); | ||
| YQL_ENSURE(lambdaOutputKind == ETypeAnnotationKind::Stream || lambdaOutputKind == ETypeAnnotationKind::Flow); | ||
| if (lambdaOutputKind != inputKind) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Как вообще могли получаться в DqReplicate лямбды с разными типами? Типизация DqReplicate не проверяет что ли это? Если нет, то нужно там править и править оптимизаторы, которые это порождают
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
не проверяет и не было очевидно что должна проверять