Re: [External] : Re: Need help with JDBC Broken Pipeline Issue after some idle time

2021-03-09 Thread Fuyao Li
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

Re: [External] : Re: Need help with JDBC Broken Pipeline Issue after some idle time

2021-03-03 Thread Fuyao Li
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

Re: Need help with JDBC Broken Pipeline Issue after some idle time

2021-03-02 Thread XU Qinghui
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

Re: Need help with JDBC Broken Pipeline Issue after some idle time

2021-03-02 Thread Fuyao Li
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

Need help with JDBC Broken Pipeline Issue after some idle time

2021-03-02 Thread Fuyao Li
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