[BUG] ParquetOutputCodecTest may not be testing correctly

[dlvenable]

Describe the bug

I removed some try-catch lines in the ParquetOutputCodecTest test. These tests began to fail.

Something is definitely wrong as the lines in question are part of the setup. It may be that the tests are not actually testing what they claim to test.

To Reproduce

Remove these lines:

data-prepper/data-prepper-plugins/s3-sink/src/test/java/org/opensearch/dataprepper/plugins/codec/parquet/ParquetOutputCodecTest.java

Lines 576 to 578 in c4acf28

	} catch (Exception parquetException) {
	LOG.error("Failed to parse Parquet", parquetException);
	}

data-prepper/data-prepper-plugins/s3-sink/src/test/java/org/opensearch/dataprepper/plugins/codec/parquet/ParquetOutputCodecTest.java

Lines 584 to 585 in c4acf28

	} catch (Exception parquetException) {
	LOG.error("Failed to parse Parquet", parquetException);

Run the tests.

Quite a few of them fail.

Expected behavior

I should be able to run tests without this code throwing exceptions at all.

Additional context

This was found while removing ex.printStackTrace() lines:

https://github.com/opensearch-project/data-prepper/pull/3991/files#r1459559030

[dlvenable]

Also, we found that some of the assertions are loops. However, the size of these loops is not asserted. Thus, these assertions are not even happening.

[dlvenable]

Also, @kkondaka found this:

List<Map<String, Object>> actualRecords = createParquetRecordsList(new ByteArrayInputStream(tempFile.toString().getBytes()));

The line above is not actually loading the file. It gets the path as bytes.

It should look like:

List<Map<String, Object>> actualRecords = createParquetRecordsList(new FileInputStream(tempFile));