Skip to content

Commit f74b86d

Browse files
authored
fix: Test failures due to RESOURCE_EXHAUSTED (#1197)
* fix: Test failures due to RESOURCE_EXHAUSTED * fix failing test
1 parent c3942ea commit f74b86d

File tree

1 file changed

+18
-0
lines changed
  • google-cloud-logging/src/test/java/com/google/cloud/logging/it

1 file changed

+18
-0
lines changed

google-cloud-logging/src/test/java/com/google/cloud/logging/it/ITSinkTest.java

+18
Original file line numberDiff line numberDiff line change
@@ -31,11 +31,29 @@
3131
import com.google.cloud.logging.Sink;
3232
import com.google.cloud.logging.SinkInfo;
3333
import com.google.common.collect.Sets;
34+
import java.util.Iterator;
3435
import java.util.Set;
36+
import org.junit.BeforeClass;
3537
import org.junit.Test;
3638

3739
public class ITSinkTest extends BaseSystemTest {
3840

41+
@BeforeClass
42+
public static void setUp() {
43+
// Cleanup all stucked sinks if any
44+
Logging.ListOption[] options = {Logging.ListOption.pageSize(50)};
45+
Page<Sink> sinkPage = logging.listSinks(options);
46+
Iterator<Sink> iterator = sinkPage.iterateAll().iterator();
47+
while (iterator.hasNext()) {
48+
Sink sink = iterator.next();
49+
try {
50+
sink.delete();
51+
} catch (Exception ex) {
52+
System.err.println("ERROR: Failed to delete a " + sink.getName() + " sink, error: " + ex);
53+
}
54+
}
55+
}
56+
3957
@Test
4058
public void testCreateGetUpdateAndDeleteSink() {
4159
String name = formatForTest("test-create-get-update-sink");

0 commit comments

Comments
 (0)