Skip to content

Add support for dynamic write in MqttIO #13142

Add support for dynamic write in MqttIO

Add support for dynamic write in MqttIO #13142

GitHub Actions / Test Results succeeded Sep 27, 2024 in 0s

All 15 tests pass, 1 skipped in 12s

 1 files   -  7   1 suites   - 7   12s ⏱️ - 1h 21m 27s
16 tests +12  15 ✅ +11  1 💤 +1  0 ❌ ±0 
16 runs  + 2  15 ✅ + 1  1 💤 +1  0 ❌ ±0 

Results for commit 1d91ec0. ± Comparison against earlier commit b785bd7.

Annotations

Check notice on line 0 in .github

See this annotation in the file changed.

@github-actions github-actions / Test Results

1 skipped test found

There is 1 skipped test, see "Raw output" for the name of the skipped test.
Raw output
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

16 tests found

There are 16 tests, see "Raw output" for the full list of tests.
Raw output
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testDynamicWrite
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testDynamicWriteHaveNoConnectionConfiguration
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testDynamicWriteHaveNoPayloadFn
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testDynamicWriteHaveNoTopicFn
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testDynamicWriteHaveStaticTopic
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testRead
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testReadHaveNoConnectionConfiguration
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testReadHaveNoTopic
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.MqttIOTest ‑ testWriteHaveNoConnectionConfiguration
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testWriteHaveNoTopic
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testWriteWithPayloadFn
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testWriteWithTopicFn