Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
46 changes: 23 additions & 23 deletions .github/workflow-template/template.yml
Original file line number Diff line number Diff line change
Expand Up @@ -297,29 +297,29 @@ jobs:
~/cargo-make/makers logs
# ~/cargo-make/makers check-logs # regression test is bound to produce errors, so we don't check logs

# - name: e2e test w/ source and Hummock
# run: |
# ~/cargo-make/makers clean-data
# ~/cargo-make/makers ci-streaming
# timeout 5m sqllogictest -p ${{ env.RW_PORT }} -d dev './e2e_test/source/**/*.slt'

# - name: Kill cluster
# run: |
# ~/cargo-make/makers k
# ~/cargo-make/makers logs
# ~/cargo-make/makers check-logs

# - name: e2e test w/ source 3-node
# run: |
# ~/cargo-make/makers clean-data
# ~/cargo-make/makers ci-3node
# timeout 5m sqllogictest -p ${{ env.RW_PORT }} -d dev './e2e_test/source_distributed/**/*.slt'

# - name: Kill cluster
# run: |
# ~/cargo-make/makers k
# ~/cargo-make/makers logs
# ~/cargo-make/makers check-logs
- name: e2e test w/ source and Hummock
run: |
~/cargo-make/makers clean-data
~/cargo-make/makers ci-streaming
timeout 5m sqllogictest -p ${{ env.RW_PORT }} -d dev './e2e_test/source/**/*.slt'

- name: Kill cluster
run: |
~/cargo-make/makers k
~/cargo-make/makers logs
~/cargo-make/makers check-logs

- name: e2e test w/ source 3-node
run: |
~/cargo-make/makers clean-data
~/cargo-make/makers ci-3node
timeout 5m sqllogictest -p ${{ env.RW_PORT }} -d dev './e2e_test/source_distributed/**/*.slt'

- name: Kill cluster
run: |
~/cargo-make/makers k
~/cargo-make/makers logs
~/cargo-make/makers check-logs

- name: Dump last 100 lines of logs on failure
if: ${{ failure() }}
Expand Down
20 changes: 20 additions & 0 deletions .github/workflows/main.yml
Original file line number Diff line number Diff line change
Expand Up @@ -254,6 +254,26 @@ jobs:
~/cargo-make/makers k
~/cargo-make/makers logs
# ~/cargo-make/makers check-logs # regression test is bound to produce errors, so we don't check logs
- name: e2e test w/ source and Hummock
run: |
~/cargo-make/makers clean-data
~/cargo-make/makers ci-streaming
timeout 5m sqllogictest -p ${{ env.RW_PORT }} -d dev './e2e_test/source/**/*.slt'
- name: Kill cluster
run: |
~/cargo-make/makers k
~/cargo-make/makers logs
~/cargo-make/makers check-logs
- name: e2e test w/ source 3-node
run: |
~/cargo-make/makers clean-data
~/cargo-make/makers ci-3node
timeout 5m sqllogictest -p ${{ env.RW_PORT }} -d dev './e2e_test/source_distributed/**/*.slt'
- name: Kill cluster
run: |
~/cargo-make/makers k
~/cargo-make/makers logs
~/cargo-make/makers check-logs
- name: Dump last 100 lines of logs on failure
if: ${{ failure() }}
run: ~/cargo-make/makers logs
Expand Down
20 changes: 20 additions & 0 deletions .github/workflows/pull-request.yml
Original file line number Diff line number Diff line change
Expand Up @@ -253,6 +253,26 @@ jobs:
~/cargo-make/makers k
~/cargo-make/makers logs
# ~/cargo-make/makers check-logs # regression test is bound to produce errors, so we don't check logs
- name: e2e test w/ source and Hummock
run: |
~/cargo-make/makers clean-data
~/cargo-make/makers ci-streaming
timeout 5m sqllogictest -p ${{ env.RW_PORT }} -d dev './e2e_test/source/**/*.slt'
- name: Kill cluster
run: |
~/cargo-make/makers k
~/cargo-make/makers logs
~/cargo-make/makers check-logs
- name: e2e test w/ source 3-node
run: |
~/cargo-make/makers clean-data
~/cargo-make/makers ci-3node
timeout 5m sqllogictest -p ${{ env.RW_PORT }} -d dev './e2e_test/source_distributed/**/*.slt'
- name: Kill cluster
run: |
~/cargo-make/makers k
~/cargo-make/makers logs
~/cargo-make/makers check-logs
- name: Dump last 100 lines of logs on failure
if: ${{ failure() }}
run: ~/cargo-make/makers logs
Expand Down
10 changes: 6 additions & 4 deletions e2e_test/source/basic_test.slt
Original file line number Diff line number Diff line change
Expand Up @@ -105,10 +105,12 @@ select v1, v2 from source_mv1;
8 name9
9 name2

query II
select sum_v1, count_v2 from source_mv2;
----
78 12
# Note(eric): Disabled because this case fails randomly
# TODO: uncomment this after migrated to low-level kafka source
# query II
# select sum_v1, count_v2 from source_mv2;
# ----
# 78 12

statement ok
drop source s