Skip to content

Add portable Mqtt source and sink transforms #14004

Add portable Mqtt source and sink transforms

Add portable Mqtt source and sink transforms #14004

GitHub Actions / Test Results succeeded Aug 30, 2024 in 0s

All 5 tests pass, 2 skipped in 9s

7 tests   5 ✅  9s ⏱️
2 suites  2 💤
2 files    0 ❌

Results for commit 5008fc6.

Annotations

Check notice on line 0 in .github

See this annotation in the file changed.

@github-actions github-actions / Test Results

2 skipped tests found

There are 2 skipped tests, see "Raw output" for the full list of skipped tests.
Raw output
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testRead
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testReadNoClientId

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.sdk.io.mqtt.MqttIOTest ‑ testRead
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testReadNoClientId
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testReadObject
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testReceiveWithTimeoutAndNoData
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testWrite
org.apache.beam.sdk.io.mqtt.MqttSchemaTransformProviderTest ‑ testReceiveWithTimeoutAndNoData
org.apache.beam.sdk.io.mqtt.MqttSchemaTransformProviderTest ‑ testWrite