diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWriteUnshardedRecords.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWriteUnshardedRecords.java index 2fe10453e256..1320f24e984c 100644 --- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWriteUnshardedRecords.java +++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWriteUnshardedRecords.java @@ -760,7 +760,10 @@ long flush( error.getRowIndexToErrorMessage().get(failedIndex), tableDestination.getTableReference()); } catch (Exception e) { - LOG.error("Failed to insert row and could not parse the result!", e); + LOG.error( + "Failed to insert row and could not parse the result! Insert error: {}.", + error.getRowIndexToErrorMessage().get(failedIndex), + e); } // output outside try {} clause to avoid suppress downstream Exception if (element != null) {