Re: Taskmanager killed often after migrating to flink 1.12

2021-04-28 Thread Sambaran
Hi Till, Thank you for the response, we are currently running flink with an increased memory usage, so far the taskmanager is working fine, we will check if there is any further issue and will update you. Regards Sambaran On Wed, Apr 28, 2021 at 5:33 PM Till Rohrmann wrote: > Hi Samba

Taskmanager killed often after migrating to flink 1.12

2021-04-27 Thread Sambaran
as requested. While checking more logs we see flink not able to discard old checkpoints org.apache.flink.runtime.checkpoint.CheckpointsCleaner [] - Could not discard completed checkpoint 173. We are not sure of what is the reason here, has anyone faced this before? Regards Sambaran

Re: Alternatives to JDBCAppendTableSink in Flink 1.11

2021-04-21 Thread Sambaran
Hi Austin, Many thanks, we indeed were using the Api incorrectly. Now in local tests we can see the data population happened in the postgres. Have a nice day! Regards Sambaran On Tue, Apr 20, 2021 at 8:11 PM Austin Cawley-Edwards < austin.caw...@gmail.com> wrote: > Hi Sambaran, &g

Alternatives to JDBCAppendTableSink in Flink 1.11

2021-04-20 Thread Sambaran
looking for an alternative I could not find any suitable approach which would call database stored procedure. Is there any alternative approach to resolve this? Regards Sambaran