diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/testing/FakeDatasetService.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/testing/FakeDatasetService.java index 3c0ea08c033b..e9b1e25a7afc 100644 --- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/testing/FakeDatasetService.java +++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/testing/FakeDatasetService.java @@ -261,9 +261,7 @@ public Table getTableImpl( Map dataset = tables.get(tableRef.getProjectId(), tableRef.getDatasetId()); if (dataset == null) { - throwNotFound( - "Tried to get a dataset %s:%s, but no such dataset was set", - tableRef.getProjectId(), tableRef.getDatasetId()); + return null; } TableContainer tableContainer = dataset.get(tableRef.getTableId());