Fix GZip does not flush data

vostok · Aug 5, 2022 · 72af8a7 · 72af8a7
1 parent 1ab1fe9
commit 72af8a7
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...ules-elastic-sink/src/main/java/ru/kontur/vostok/hercules/elastic/sink/ElasticClient.java b/...ules-elastic-sink/src/main/java/ru/kontur/vostok/hercules/elastic/sink/ElasticClient.java
@@ -140,10 +140,11 @@ private HttpEntity createHttpEntity(byte[] data) throws IOException {
     }
 
     private byte[] compressData(byte[] data) throws IOException {
-        try (var compressed = new ByteArrayOutputStream(data.length); var stream = new GZIPOutputStream(compressed)) {
+        var compressed = new ByteArrayOutputStream(data.length);
+        try (var stream = new GZIPOutputStream(compressed)) {
             stream.write(data);
-            return compressed.toByteArray();
         }
+        return compressed.toByteArray();
     }
 
     private void recreateRestClient() {