at 15:14
To: XU Qinghui
Cc: user , Timo Walther
Subject: Re: [External] : Re: Need help with JDBC Broken Pipeline Issue after
some idle time
Hi Qinghui,
I agree. I am trying to found internal and resources on the internet to fix the
issue. Idle Time
Limits<https://docs.oracle.com/en/cl
Fuyao
From: XU Qinghui
Date: Tuesday, March 2, 2021 at 13:40
To: Fuyao Li
Cc: user , Timo Walther
Subject: [External] : Re: Need help with JDBC Broken Pipeline Issue after some
idle time
It sounds like the jdbc driver's connection is closed somehow, and probably has
nothing to do with fl
at java.base/java.lang.Thread.run(Thread.java:834)
>
> Caused by: java.io.IOException: Reestablish JDBC connection failed
>
> at
> org.apache.flink.connector.jdbc.internal.JdbcBatchingOutputFormat.flush(JdbcBatchingOutputFormat.java:202)
>
> a
tFormat.java:195)
... 30 more
Thanks,
Best regards,
Fuyao
From: Fuyao Li
Date: Tuesday, March 2, 2021 at 10:33
To: user , Timo Walther
Subject: Need help with JDBC Broken Pipeline Issue after some idle time
Hi Flink Community,
I need some help with JDBC sink in Datastrea
Hi Flink Community,
I need some help with JDBC sink in Datastream API. I can produce some records
and sink it to database correctly. However, if I wait for 5 minutes between
insertions. I will run into broken pipeline issue. Ater that, the Flink
application will restart and recover from checkpo