Hi all,
I'm trying to join the following two tables using a temporal join:
*table_1*
(
`f0` STRING NOT NULL,
`f1` DOUBLE NOT NULL,
`rowtime` TIMESTAMP(3) METADATA,
WATERMARK FOR `rowtime`: TIMESTAMP(3) AS rowtime - INTERVAL '10' SECOND
)
*table_2:*
(
`f0` STRING NOT NULL,
`f1` DOUBLE
Hi Dian,Sorry for missing your mail, so if I did as your suggestion and the Flink somehow crashed and we have to restart the service, does the Flink job know the offset where does it read from Kafka ? Sent from Mail for Windows From: Dian FuSent: Tuesday, April 26, 2022 7:54 AMTo: lan tranCc: user@
Hi everyone,
I've been thinking about running some production-critical applications
using Flink. The scale is small, to begin with (thousands of events per
second), but we do want to keep the uptime as high as possible.
What does a common team around this type of system look like? We have a
coupl
Hi Harshit,
I should have already replied to you in an earlier thread[1] for the same
question. It seems that you have missed that. Please double check if that
reply is helpful for you.
Regards,
Dian
[1] https://lists.apache.org/thread/cm6r569spq67249dxw57q8lxh0mk3f7y
On Wed, Apr 27, 2022 at 6
Dear Team,
I am new to pyflink and request for your support in issue I am facing with
Pyflink. I am using Pyflink version 1.14.4 & using reference code from
pyflink github.
I am getting following error .
grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC
that termin
You're misinterpreting the docs.
The parent/child-first classloading controls where Flink looks for a
class /first/, specifically whether we first load from /lib or the user-jar.
It does not allow you to load something from the user-jar in the parent
classloader. That's just not how it works.
