chore: check exception first on flush

vinted · Feb 6, 2024 · 1da388f · 1da388f
1 parent 7dfff93
commit 1da388f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/com/vinted/flink/bigquery/sink/defaultStream/BigQueryDefaultSinkWriter.java b/src/main/java/com/vinted/flink/bigquery/sink/defaultStream/BigQueryDefaultSinkWriter.java
@@ -97,8 +97,8 @@ public void close() {
 
     @Override
     public void flush(boolean endOfInput) {
-        inflightRequestCount.arriveAndAwaitAdvance();
         checkAsyncException();
+        inflightRequestCount.arriveAndAwaitAdvance();
     }
 
     static class AppendCallBack<A> implements ApiFutureCallback<AppendRowsResponse> {