Re: problem with the heartbeat interval feature

2024-09-02 Thread Thomas Peyric
at 9:03 PM Thomas Peyric > wrote: > >> Hi Flink Community ! >> >> I am using : >> * Flink >> * Flink CDC posgtres Connector >> * scala + sbt >> >> versions are : >> * orgApacheKafkaVersion = "3.2.3" >> * flinkVersion = "

Re: problem with the heartbeat interval feature

2024-05-18 Thread Hongshun Wang
io/documentation/reference/stable/connectors/postgresql.html#postgresql-property-heartbeat-action-query >> >> [4] https://issues.apache.org/jira/browse/FLINK-35387 >> >> >> Best >> >> Hongshun >> >> On Thu, May 16, 2024 at 9:03 PM Thomas Peyric < >> thomas.

Re: problem with the heartbeat interval feature

2024-05-17 Thread Thomas Peyric
ference/stable/connectors/postgresql.html#postgresql-property-heartbeat-action-query > > [4] https://issues.apache.org/jira/browse/FLINK-35387 > > > Best > > Hongshun > > On Thu, May 16, 2024 at 9:03 PM Thomas Peyric > wrote: > >> Hi Flink Community ! >&

Re: problem with the heartbeat interval feature

2024-05-16 Thread Hongshun Wang
onnector > * scala + sbt > > versions are : > * orgApacheKafkaVersion = "3.2.3" > * flinkVersion = "1.19.0" > * flinkKafkaVersion = "3.0.2-1.18" > * flinkConnectorPostgresCdcVersion = "3.0.1" > * debeziumVersion = "1.9.8.Fina

problem with the heartbeat interval feature

2024-05-16 Thread Thomas Peyric
quot; * debeziumVersion = "1.9.8.Final" * scalaVersion = "2.12.13" * javaVersion = "11" the problem --- I have a problem with the heartbeat interval feature: * when I am querying PG with `select * from pg_replication_slots;` for checking if inform