Hello,
I have a flink table source working using
"""
create table source (
ts TIMESTAMP(3),
log_line STRING,
WATERMARK FOR ts AS ts - INTERVAL '1' SECOND
) with (
'connector'='lokitail', 'query'='blah', 'url'='blah'
)
""")
It uses a simple custom table
6420693512ba12fb4a5c0%7C0%7C0%7C637848905883722815%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C3000&sdata=XS0PYznJn8YcBQlyf538Jcq%2BkWlXpEkj6HEN%2B%2FsvrDU%3D&reserved=0>
On Wed, Apr 6, 2022 at 10:46 PM
ivan.ros...@agilent.com<mailto:i
Hello,
I'm trying to understand tumbling windows at the level of the python table api.
For this short example:
Input csv
Print output
2022-01-01 10:00:23.0, "data line 3"
2022-01-01 10:00:24.0, "data line 4"
2022-01-01 10:00:18.0, "data line 1"
2022-01-01 10:00:25.
Hello,
Sorry to spam everyone, but am hoping there's a way to get into Ververica's
upcoming Flink developer training, starting today November 29, 2021. Got
last-minute approval at work to register, but registration on website is closed
:/
Thanks in advance,
Ivan Rosero
Agilent
2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C2000&sdata=AGkBw24GYglyZZpL346hgqm2CX9wLrEStJxNzRme29E%3D&reserved=0>
On 5. Nov 2021, at 09:23,
ivan.ros...@agilent.com<mailto:ivan.ros...@agilent.com> wrote:
Hi Fabian,
Indeed, yes! Thank you.
Ok, now an actual question. I'm using
Hello All,
Apologies for spamming the list. As a new member, I am both happy to be
getting emails and also pretty overwhelmed to have them appear directly in my
inbox. As far as I can tell there is no sender email or other predictable
information I can use to put these messages into a nice Fl
