Skip to content

Add kafka read override to Dataflow java runner. #36849

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

Merged
scwhittle merged 7 commits into from
Nov 21, 2025

Use boolean asserts over assertThat, assert each read is visited only…

67e3ca8
Select commit
Loading
Failed to load commit list.
Sign in for the full log view
Merged

Add kafka read override to Dataflow java runner. #36849

Use boolean asserts over assertThat, assert each read is visited only…
67e3ca8
Select commit
Loading
Failed to load commit list.
GitHub Actions / Test Results succeeded Nov 20, 2025 in 0s

All 7 tests pass in 1h 7m 2s

 7 files   -  1 248   7 suites   - 1 248   1h 7m 2s ⏱️ - 2h 19m 14s
 7 tests  - 10 169   7 ✅  - 10 114  0 💤  - 48  0 ❌  - 7 
15 runs   - 10 179  15 ✅  - 10 124  0 💤  - 48  0 ❌  - 7 

Results for commit 67e3ca8. ± Comparison against earlier commit 1a52da3.

Annotations

Check notice on line 0 in .github

See this annotation in the file changed.

@github-actions github-actions / Test Results

7 tests found 

There are 7 tests, see "Raw output" for the full list of tests.
Raw output 
org.apache.beam.examples.WindowedWordCountIT ‑ testWindowedWordCountInBatchDynamicSharding
org.apache.beam.examples.WindowedWordCountIT ‑ testWindowedWordCountInBatchStaticSharding
org.apache.beam.examples.WindowedWordCountIT ‑ testWindowedWordCountInStreamingStaticSharding
org.apache.beam.examples.WordCountIT ‑ testE2EWordCount
org.apache.beam.sdk.testutils.jvmverification.JvmVerification ‑ verifyCodeIsCompiledWithJava8
org.apache.beam.sdk.testutils.jvmverification.JvmVerification ‑ verifyRunningJVMVersionIs21
org.apache.beam.sdk.testutils.jvmverification.JvmVerification ‑ verifyTestCodeIsCompiledWithJava21
View more details on GitHub Actions