search

teragrep / pth_06

Teragrep Datasource for Apache Spark
GNU Affero General Public License v3.0
0 stars 5 forks source link

Resource leaks in StreamDBClient.java: 346 #48

Open StrongestNumber9 opened 2 months ago

StrongestNumber9 commented 2 months ago

Describe the bug

 *** CID 1594364:  Resource leaks  (RESOURCE_LEAK)
/src/main/java/com/teragrep/pth_06/planner/StreamDBClient.java: 346 in com.teragrep.pth_06.planner.StreamDBClient$BloomFiltersTempTable.insert(org.jooq.DSLContext, org.apache.spark.util.sketch.BloomFilter, org.apache.spark.util.sketch.BloomFilter, org.apache.spark.util.sketch.BloomFilter)()
340                     mediumBaos.close();
341                     largeBaos.close();
342                 } catch(IOException e) {
343                     throw new UncheckedIOException(e);
344                 }
345     
>>>     CID 1594364:  Resource leaks  (RESOURCE_LEAK)
>>>     Failing to save or close resource created by "ctx.insertInto(com.teragrep.pth_06.planner.StreamDBClient.BloomFiltersTempTable.BLOOM_TABLE).columns(com.teragrep.pth_06.planner.StreamDBClient.BloomFiltersTempTable.fe100kfp001, com.teragrep.pth_06.planner.StreamDBClient.BloomFiltersTempTable.fe1000kfpp003, com.teragrep.pth_06.planner.StreamDBClient.BloomFiltersTempTable.fe2500kfpp005).values(org.jooq.impl.DSL.val(smallBaos.toByteArray(), `1[].class), org.jooq.impl.DSL.val(mediumBaos.toByteArray(), `1[].class), org.jooq.impl.DSL.val(largeBaos.toByteArray(), `1[].class))" leaks it.
346                 ctx.insertInto(BLOOM_TABLE).columns(
347                                 fe100kfp001,
348                                 fe1000kfpp003,
349                                 fe2500kfpp005
350                         ).values(
351                                 DSL.val(smallBaos.toByteArray(), byte[].class),

Software version

3.0.1