Hey everyone, im using FileSink to write a csv file to s3. Sample Code snippet:
FileSink<RowData> sink = FileSink._forRowFormat_(new Path(s3FilePath), new SerializationSchemaAdapter(serSchemaBuilder))
.withOutputFileConfig(new OutputFileConfig("test", ".csv"))
.build();
rowData.sinkTo(sink);
Data is successfully written to s3 file. But my requirement is to return the name of the file written in s3.
I have configured the Prefix and suffix as "test" and ".csv" respectively. But Flink adds its own UUID to the filename such as "test-2ea1c0a5-86c4-4af3-b61a-3c2ea4c1bce8-0.csv".
Can anyone pls let me know how to obtain this filename from the sink response?
OR is this filename configurable ?