Skip to content
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.

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

Reapply "SolaceIO.Read: handle occasional cases when finalizeCheckpoint is not executed (#32962)" (#33259) #33269

Merged
merged 1 commit into from
Dec 11, 2024

Reapply "SolaceIO.Read: handle occasional cases when finalizeCheckpoi…

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

Reapply "SolaceIO.Read: handle occasional cases when finalizeCheckpoint is not executed (#32962)" (#33259) #33269

Reapply "SolaceIO.Read: handle occasional cases when finalizeCheckpoi…
ec48a58
Select commit
Loading
Failed to load commit list.
GitHub Actions / Test Results succeeded Dec 3, 2024 in 0s

All 44 tests pass in 1m 5s

44 tests   44 ✅  1m 5s ⏱️
 8 suites   0 💤
 8 files     0 ❌

Results for commit ec48a58.

Annotations

Check notice on line 0 in .github

See this annotation in the file changed.

@github-actions github-actions / Test Results

44 tests found

There are 44 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
org.apache.beam.sdk.io.solace.it.SolaceIOMultipleSempIT ‑ test01writeAndReadWithMultipleSempClientFactory