Skip to content

update mzcompose to support 2000 object search #32478

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

Draft
wants to merge 1 commit into
base: main
Choose a base branch
from

Conversation

ptravers
Copy link
Contributor

Motivation

https://materializeinc.slack.com/archives/C0854GU86HL/p1747081703632959?thread_ts=1746561807.931999&cid=C0854GU86HL

Checklist

  • This PR has adequate test coverage / QA involvement has been duly considered. (trigger-ci for additional test/nightly runs)
  • This PR has an associated up-to-date design doc, is a design doc (template), or is sufficiently small to not require a design.
  • If this PR evolves an existing $T ⇔ Proto$T mapping (possibly in a backwards-incompatible way), then it is tagged with a T-proto label.
  • If this PR will require changes to cloud orchestration or tests, there is a companion cloud PR to account for those changes that is tagged with the release-blocker label (example).
  • If this PR includes major user-facing behavior changes, I have pinged the relevant PM to schedule a changelog post.

@ptravers ptravers requested a review from antiguru May 12, 2025 21:08
Comment on lines +1290 to +1310
", ".join(
", ".join(
[
f"a{i} STRING",
f"b{i} STRING",
f"c{i} STRING",
f"d{i} STRING[]",
]
)
for i in cls.all()
)
});"""
)
print("> INSERT INTO t DEFAULT VALUES;")
print(
f"""> CREATE MATERIALIZED VIEW v2 AS SELECT {
", ".join(
f"ARRAY_AGG(a{i} ORDER BY b1) FILTER (WHERE 's{i}' = ANY(d{i})) AS r{i}"
for i in cls.all()
)
} FROM t GROUP BY a1;"""
", ".join(
f"ARRAY_AGG(a{i} ORDER BY b1) FILTER (WHERE 's{i}' = ANY(d{i})) AS r{i}"
for i in cls.all()
)
} FROM t GROUP BY a1;"""
Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

ah sorry this is my auto formatter

Comment on lines +1291 to +1298
", ".join(
[
f"a{i} STRING",
f"b{i} STRING",
f"c{i} STRING",
f"d{i} STRING[]",
]
)
Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

auto formatter from my editor.

Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

bin/pyfmt is your friend.

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

ah thanks!

Copy link
Member

@antiguru antiguru left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I don't think this is what we want by default. It should use the crdb consensus because that's what's running in production, but the diff might help you (or anyone else who needs to debug things) to quickly reproduce the scalability issues around postgres sources we've been observing.

@ptravers
Copy link
Contributor Author

ah yeah, sorry. I meant to mark this as a draft. just showing the diff that I'm using locally. I don't think it actually works since it exits at 1000 locally.

@ptravers ptravers marked this pull request as draft May 13, 2025 13:32
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants