Skip to content

Update sql for q5 to q22 #9

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.

Sign up for GitHub

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

Jump to bottom
Open
wants to merge 23 commits into
base: main
Choose a base branch
from
Open

Update sql for q5 to q22 #9

wants to merge 23 commits into from

Conversation

@kuiliu88
Copy link
Contributor

@kuiliu88 kuiliu88 commented Jun 26, 2025

No description provided.

@kuiliu88 kuiliu88 requested a review from gangtao June 26, 2025 06:09
@kuiliu88 kuiliu88 changed the title Update q10.sql Update sql for q5 to q22 Jun 26, 2025
@kuiliu88
Copy link
Contributor Author

kuiliu88 commented Jun 26, 2025

result with updated version SQL,

q5         flink        124.41s     4498479 PASSED
q5         timeplus      14.23s          67 PASSED
q5         ksqldb         0.00s           0 FAILED
q7         flink         98.79s          32 PASSED
q7         timeplus      36.73s          87 PASSED
q7         ksqldb         0.00s           0 FAILED
q8         flink         29.56s       81858 PASSED
q8         timeplus      12.11s       75638 PASSED
q8         ksqldb         0.00s           0 FAILED
q9         flink        163.13s      214588 PASSED
q9         timeplus      15.27s         614 PASSED
q9         ksqldb         0.00s           0 FAILED
q10        flink         82.99s     9200000 PASSED
q10        timeplus      69.33s     9200000 PASSED
q10        ksqldb      1026.91s     9193473 PASSED
q11        flink         74.17s      196413 PASSED
q11        timeplus      30.10s      205464 PASSED
q11        ksqldb       674.06s     1049574 PASSED
q12        flink         50.42s      202959 PASSED
q12        timeplus      24.93s      183140 PASSED
q12        ksqldb       120.03s      278682 PASSED
q15        flink        118.81s     9200000 PASSED
q15        timeplus      38.27s          14 PASSED
q15        ksqldb         0.00s           0 FAILED
q16        flink        154.48s     9200000 PASSED
q16        timeplus      36.50s       70028 PASSED
q16        ksqldb         0.00s           0 FAILED
q17        flink        101.97s     9200000 PASSED
q17        timeplus      70.69s     6225913 PASSED
q17        ksqldb         0.00s           0 FAILED
q18        flink        352.68s     4410991 PASSED
q18        timeplus      31.22s     1206226 PASSED
q18        ksqldb         0.00s           0 FAILED
q19        flink        280.16s     4478790 PASSED
q19        timeplus      10.27s           0 PASSED
q19        ksqldb         0.00s           0 FAILED
q20        flink        161.06s      604984 PASSED
q20        timeplus      31.13s      166081 PASSED
q20        ksqldb       506.54s     1711774 PASSED
q21        flink         78.41s     8773492 PASSED
q21        timeplus      67.62s     9200000 PASSED
q21        ksqldb       140.98s     4595827 PASSED
q22        flink         79.10s     9200000 PASSED
q22        timeplus      67.72s     9200000 PASSED
q22        ksqldb       162.23s     9191836 PASSED

gangtao
gangtao reviewed Jun 26, 2025
View reviewed changes
Copy link
Contributor

@gangtao gangtao left a comment

Choose a reason for hiding this comment

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

@kuiliu88 do we need update 21/22 as well or not?

python/scripts/timeplus/q13.sql
one_message_per_row=true;

-- side input to be added
INSERT INTO target
Copy link
Contributor

@gangtao gangtao Jun 26, 2025

Choose a reason for hiding this comment

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

@kuiliu88 q13 is not supported, please double check here

Copy link
Contributor Author

@kuiliu88 kuiliu88 Jun 30, 2025

Choose a reason for hiding this comment

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

Here updated the q13.sql and added side-input.csv, and update function in nexmark.py to copy the csv into user_files if the case to run is q13

@kuiliu88
Copy link
Contributor Author

kuiliu88 commented Jun 27, 2025

The q21/22 are already updated version, as I pasted the latest version in branch and identical with main.

@kuiliu88
Copy link
Contributor Author

kuiliu88 commented Jun 27, 2025 •
edited
Loading

q19 was updated with fix result set size, now the result as

============================================================
TEST RESULTS SUMMARY
============================================================
Case       Platform        Time Output_Size Status
--------------------------------------------------
q19        flink        313.88s     4429719 PASSED
q19        timeplus      45.14s     2320824 PASSED
q19        ksqldb         0.00s           0 FAILED

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Reviewers

@gangtao gangtao gangtao left review comments

Assignees

No one assigned

Labels

None yet

Projects

None yet

Milestone

No milestone

Development

Successfully merging this pull request may close these issues.

3 participants

@kuiliu88 @gangtao