Hi,
I am building a pretty straightforward processing pipeline as described
below, using *DataStream* *APIs* and *FileSystem connector, Flink version >
1.19*.
*filesystem-source (CSV) -> transforms -> filesystem-sink (CSV**)*
The documentation for the FileSystem connector shows examples for both
t;.csv")))
> .build();
> ```
>
> Best,
> Feng
>
>
>
> On Sat, Aug 17, 2024 at 4:41 AM amogh joshi wrote:
>
>> Hi Users,
>>
>> Any clues on configurable regex path for FilesSource/Filesystem connector
>> for stream APIs is appreciate
Hi Users,
Any clues on configurable regex path for FilesSource/Filesystem connector
for stream APIs is appreciated.
Regards,
Amogh.
On Thu, 15 Aug, 2024, 11:18 amogh joshi, wrote:
> Hi,
>
> I am building a pretty straightforward processing pipeline as described
> below, using
Hi,
I am building a pretty straightforward processing pipeline as described
below, using *DataStream* *APIs* and *FileSystem connector*.
*filesystem-source -> transforms -> database-sink*
Everything worked well till the filesystem (source) had just a single type
(JSON) of files. Recently the fil
