Skip to content
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

feat(risingwave): add streaming DDLs, new #8781

Conversation

KeXiangWang
Copy link
Contributor

@KeXiangWang KeXiangWang commented Mar 26, 2024

Description of changes

In #8239 (A PR from company fork), I cannot allow maintainer to edit the PR. So I create this PR from my personal fork. All the changes in #8239 are included here.

Issues closed

@KeXiangWang KeXiangWang force-pushed the wkx/risingwave-streaming-features branch from 74e2038 to e63c5cb Compare March 26, 2024 16:33
Given that Postgres and Risingwave don't support cross-catalog
operations, we can use only the `database` kwarg to specify all the
necessary bits here.

I also tweaked the implementation of `overwrite` in
`create_materialized_view` as I don't think it was doing the right thing.
@@ -175,6 +175,7 @@ def test_mutate_then_join_no_column_overlap(batting, awards_players):
@pytest.mark.notimpl(["druid"])
@pytest.mark.notyet(["dask"], reason="dask doesn't support descending order by")
@pytest.mark.notyet(["flink"], reason="Flink doesn't support semi joins")
@pytest.mark.skip("risingwave") # TODO(Kexiang): Risingwave's bug, investigating
Copy link
Member

Choose a reason for hiding this comment

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

Suggested change
@pytest.mark.skip("risingwave") # TODO(Kexiang): Risingwave's bug, investigating
@pytest.mark.broken("risingwave") # TODO(Kexiang): Risingwave's bug, investigating

whatever the reason, we want to get a signal when this test starts to pass, and with skip, that change will not be visible.

Copy link
Contributor Author

@KeXiangWang KeXiangWang Apr 2, 2024

Choose a reason for hiding this comment

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

The problem is that this case does not always fail. It actually can pass sometimes. But I haven't got time to explore under what conditions it will fail/pass. I think skip is more appropriate for now.

@lostmygithubaccount
Copy link
Member

I'm going to close this in favor of #8239 (please correct/reopen if I'm interpreting this wrong)

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.

3 participants