|
70 | 70 | import org.joda.time.Duration; |
71 | 71 | import org.junit.After; |
72 | 72 | import org.junit.Before; |
| 73 | +import org.junit.Ignore; |
73 | 74 | import org.junit.Rule; |
74 | 75 | import org.junit.Test; |
75 | 76 | import org.junit.rules.ExpectedException; |
@@ -115,6 +116,7 @@ public void tearDown() throws NoSuchFieldException, IllegalAccessException { |
115 | 116 | } |
116 | 117 |
|
117 | 118 | @Test |
| 119 | + @Ignore("https://github.com/apache/beam/issues/37002 Re-enable skipped tests.") |
118 | 120 | // Error code UNAVAILABLE is retried repeatedly until the RPC times out. |
119 | 121 | public void testUnavailableExceptionRetries() throws InterruptedException { |
120 | 122 | DirectOptions options = PipelineOptionsFactory.as(DirectOptions.class); |
@@ -155,6 +157,7 @@ public void testUnavailableExceptionRetries() throws InterruptedException { |
155 | 157 | } |
156 | 158 |
|
157 | 159 | @Test |
| 160 | + @Ignore("https://github.com/apache/beam/issues/37002 Re-enable skipped tests.") |
158 | 161 | // Error code ABORTED is retried repeatedly until it times out. |
159 | 162 | public void testAbortedExceptionRetries() throws InterruptedException { |
160 | 163 | mockSpannerService.setExecuteStreamingSqlExecutionTime( |
@@ -218,6 +221,7 @@ public void testUnknownExceptionDoesNotRetry() { |
218 | 221 | } |
219 | 222 |
|
220 | 223 | @Test |
| 224 | + @Ignore("https://github.com/apache/beam/issues/37002 Re-enable skipped tests.") |
221 | 225 | // Error code RESOURCE_EXHAUSTED is retried repeatedly. |
222 | 226 | public void testResourceExhaustedRetry() { |
223 | 227 | mockSpannerService.setExecuteStreamingSqlExecutionTime( |
@@ -281,6 +285,7 @@ public void testResourceExhaustedRetryWithDefaultSettings() { |
281 | 285 | } |
282 | 286 |
|
283 | 287 | @Test |
| 288 | + @Ignore("https://github.com/apache/beam/issues/37002 Re-enable skipped tests.") |
284 | 289 | public void testInvalidRecordReceived() { |
285 | 290 | final Timestamp startTimestamp = Timestamp.ofTimeSecondsAndNanos(0, 1000); |
286 | 291 | final Timestamp endTimestamp = |
|
0 commit comments