Skip to content

Commit e37e321

Browse files
Fokkoelectrum
authored andcommitted
Use try-with-resources in Avro tests
1 parent 41ca1f3 commit e37e321

File tree

2 files changed

+1
-5
lines changed

2 files changed

+1
-5
lines changed

presto-product-tests/src/main/java/io/prestosql/tests/kafka/KafkaAvroSmokeTest.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,6 @@ private static byte[] convertRecordToAvro(Schema schema, Map<String, Object> val
110110
try (DataFileWriter<GenericRecord> dataFileWriter = new DataFileWriter<>(new GenericDatumWriter<>(schema))) {
111111
dataFileWriter.create(schema, outputStream);
112112
dataFileWriter.append(record);
113-
dataFileWriter.close();
114113
}
115114
catch (IOException e) {
116115
throw new UncheckedIOException("Failed to convert to Avro.", e);

presto-record-decoder/src/test/java/io/prestosql/decoder/avro/TestAvroDecoder.java

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -146,12 +146,9 @@ private static GenericData.Record buildAvroRecord(Schema schema, ByteArrayOutput
146146
{
147147
GenericData.Record record = new GenericData.Record(schema);
148148
values.forEach(record::put);
149-
try {
150-
DataFileWriter<GenericRecord> dataFileWriter = new DataFileWriter<>(new GenericDatumWriter<>(schema));
151-
149+
try (DataFileWriter<GenericRecord> dataFileWriter = new DataFileWriter<>(new GenericDatumWriter<>(schema))) {
152150
dataFileWriter.create(schema, outputStream);
153151
dataFileWriter.append(record);
154-
dataFileWriter.close();
155152
}
156153
catch (IOException e) {
157154
throw new RuntimeException("Failed to convert to Avro.", e);

0 commit comments

Comments
 (0)