Hi Yashoda,
I think this is not a reasonable way and it is not supported at the moment.
I suggest that you can convert the DataStream generated by windowsAll into
a Table, and then use the TableAPI.
AllWindowProcess -> ConvertDataStreamToTable -> ProcessUsingTableAPI
Best,
Feng
On Fri, Oct 1
Hi Community,
Can someone help me here?
Regards,
Kirti Dhar
From: Kirti Dhar Upadhyay K
Sent: 10 October 2023 15:52
To: user@flink.apache.org
Subject: File Source Watermark Issue
Hi Team,
I am using Flink File Source with window aggregator as process function, and
stuck with a weird issues.
F
I've now tracked this down to the fact that my application is trying to run
a query in a separate thread from the one that set up the table
environment. is StreamTableEnvironment supposed to be thread safe? Can it
be a singleton that is available to multiple threads to server queries on
or should e
