Skip to content

SolaceIO.Read: handle occasional cases when finalizeCheckpoint is not executed #36044

SolaceIO.Read: handle occasional cases when finalizeCheckpoint is not executed

SolaceIO.Read: handle occasional cases when finalizeCheckpoint is not executed #36044

GitHub Actions / Test Results succeeded Nov 19, 2024 in 0s

All 43 tests pass in 22s

 7 files   -   551   7 suites   - 551   22s ⏱️ - 6m 12s
43 tests  - 5 285  43 ✅  - 5 274  0 💤  - 11  0 ❌ ±0 
43 runs   - 5 288  43 ✅  - 5 277  0 💤  - 11  0 ❌ ±0 

Results for commit da95027. ± Comparison against earlier commit 740646d.

Annotations

Check notice on line 0 in .github

See this annotation in the file changed.

@github-actions github-actions / Test Results

43 tests found

There are 43 tests, see "Raw output" for the full list of tests.
Raw output
org.apache.beam.sdk.io.solace.RetryCallableManagerTest ‑ testRetryCallable_ChecksForAllDefinedExceptions
org.apache.beam.sdk.io.solace.RetryCallableManagerTest ‑ testRetryCallable_ExecutionCountIsCorrectAfterMultipleExceptions
org.apache.beam.sdk.io.solace.RetryCallableManagerTest ‑ testRetryCallable_RetriesExpectedNumberOfTimes
org.apache.beam.sdk.io.solace.RetryCallableManagerTest ‑ testRetryCallable_ReturnsExpected
org.apache.beam.sdk.io.solace.RetryCallableManagerTest ‑ testRetryCallable_ThrowsRetryHelperException
org.apache.beam.sdk.io.solace.RetryCallableManagerTest ‑ testRetryCallable_ThrowsRetryHelperExceptionOnUnspecifiedException
org.apache.beam.sdk.io.solace.SolaceIOReadTest ‑ testCheckpointMark
org.apache.beam.sdk.io.solace.SolaceIOReadTest ‑ testCheckpointMarkAndFinalizeSeparately
org.apache.beam.sdk.io.solace.SolaceIOReadTest ‑ testCheckpointMarkSafety
org.apache.beam.sdk.io.solace.SolaceIOReadTest ‑ testCreateQueueForTopic
org.apache.beam.sdk.io.solace.SolaceIOReadTest ‑ testDefaultCoder
org.apache.beam.sdk.io.solace.SolaceIOReadTest ‑ testDestinationTopicQueueCreation
org.apache.beam.sdk.io.solace.SolaceIOReadTest ‑ testNoQueueAndTopicSet
org.apache.beam.sdk.io.solace.SolaceIOReadTest ‑ testReadMessages
org.apache.beam.sdk.io.solace.SolaceIOReadTest ‑ testReadMessagesWithDeduplication
org.apache.beam.sdk.io.solace.SolaceIOReadTest ‑ testReadMessagesWithDeduplicationOnReplicationGroupMessageId
org.apache.beam.sdk.io.solace.SolaceIOReadTest ‑ testReadMessagesWithoutDeduplication
org.apache.beam.sdk.io.solace.SolaceIOReadTest ‑ testReadWithCoderAndParseFnAndTimestampFn
org.apache.beam.sdk.io.solace.SolaceIOReadTest ‑ testSplitsForExclusiveQueue
org.apache.beam.sdk.io.solace.SolaceIOReadTest ‑ testSplitsForNonExclusiveQueueWithMaxNumConnections
org.apache.beam.sdk.io.solace.SolaceIOReadTest ‑ testSplitsForNonExclusiveQueueWithMaxNumConnectionsRespectDesired
org.apache.beam.sdk.io.solace.SolaceIOReadTest ‑ testTopicEncoding
org.apache.beam.sdk.io.solace.SolaceIOWriteTest ‑ testWriteLatencyBatched
org.apache.beam.sdk.io.solace.SolaceIOWriteTest ‑ testWriteLatencyStreaming
org.apache.beam.sdk.io.solace.SolaceIOWriteTest ‑ testWriteThroughputBatched
org.apache.beam.sdk.io.solace.SolaceIOWriteTest ‑ testWriteThroughputStreaming
org.apache.beam.sdk.io.solace.SolaceIOWriteTest ‑ testWriteWithFailedRecords
org.apache.beam.sdk.io.solace.broker.BasicAuthWriterSessionTest ‑ testAuthProperties
org.apache.beam.sdk.io.solace.broker.BasicAuthWriterSessionTest ‑ testOverrideWithHigherThroughput
org.apache.beam.sdk.io.solace.broker.BasicAuthWriterSessionTest ‑ testOverrideWithLowerLatency
org.apache.beam.sdk.io.solace.broker.BasicAuthWriterSessionTest ‑ testVpnNames
org.apache.beam.sdk.io.solace.broker.OverrideWriterPropertiesTest ‑ testDontOverrideForCustom
org.apache.beam.sdk.io.solace.broker.OverrideWriterPropertiesTest ‑ testOverrideForHigherThroughput
org.apache.beam.sdk.io.solace.broker.OverrideWriterPropertiesTest ‑ testOverrideForLowerLatency
org.apache.beam.sdk.io.solace.broker.SempBasicAuthClientExecutorTest ‑ testCreateQueueResponseEncoding
org.apache.beam.sdk.io.solace.broker.SempBasicAuthClientExecutorTest ‑ testCreateSubscriptionResponseEncoding
org.apache.beam.sdk.io.solace.broker.SempBasicAuthClientExecutorTest ‑ testExecuteStatus3xx
org.apache.beam.sdk.io.solace.broker.SempBasicAuthClientExecutorTest ‑ testExecuteStatus4xx
org.apache.beam.sdk.io.solace.broker.SempBasicAuthClientExecutorTest ‑ testExecuteWithUnauthorized
org.apache.beam.sdk.io.solace.broker.SempBasicAuthClientExecutorTest ‑ testGetQueueResponseEncoding
org.apache.beam.sdk.io.solace.it.SolaceIOIT ‑ test01WriteStreaming
org.apache.beam.sdk.io.solace.it.SolaceIOIT ‑ test02Read
org.apache.beam.sdk.io.solace.it.SolaceIOIT ‑ test03WriteBatched