[Bug]: FlinkRunner does not emit watermark with empty source #1801
GitHub Actions / Test Results
succeeded
May 26, 2024 in 0s
All 47 tests pass in 3m 55s
47 tests 47 ✅ 3m 55s ⏱️
2 suites 0 💤
2 files 0 ❌
Results for commit 836e77e.
Annotations
Check notice on line 0 in .github
github-actions / Test Results
47 tests found
There are 47 tests, see "Raw output" for the full list of tests.
Raw output
org.apache.beam.sdk.io.jms.JmsIOIT ‑ testPublishingThenReadingAll[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testAuthenticationRequired[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testAuthenticationRequired[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testAuthenticationWithBadPassword[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testAuthenticationWithBadPassword[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testCheckpointMarkAndFinalizeSeparately[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testCheckpointMarkAndFinalizeSeparately[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testCheckpointMarkDefaultCoder[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testCheckpointMarkDefaultCoder[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testCheckpointMarkSafety[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testCheckpointMarkSafety[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testCheckpointMark[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testCheckpointMark[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testCloseWithTimeout[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testCloseWithTimeout[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testCustomAutoscaler[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testCustomAutoscaler[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testDefaultAutoscaler[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testDefaultAutoscaler[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testDiscardCheckpointMark[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testDiscardCheckpointMark[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testPublisherWithRetryConfiguration[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testPublisherWithRetryConfiguration[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testReadBytesMessages[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testReadBytesMessages[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testReadMessages[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testReadMessages[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testRequiresDedup[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testRequiresDedup[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testSplitForQueue[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testSplitForQueue[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testSplitForTopic[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testSplitForTopic[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testWriteDynamicMessage[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testWriteDynamicMessage[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testWriteMessageToStaticTopicWithoutRetryPolicy[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testWriteMessageToStaticTopicWithoutRetryPolicy[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testWriteMessageWithError[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testWriteMessageWithError[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testWriteMessageWithRetryPolicyReachesLimit[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testWriteMessageWithRetryPolicyReachesLimit[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testWriteMessageWithRetryPolicy[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testWriteMessageWithRetryPolicy[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testWriteMessage[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testWriteMessage[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testWriteMessagesWithErrors[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testWriteMessagesWithErrors[with client class class org.apache.qpid.jms.JmsConnectionFactory]
Loading