Re: Difference between table.exec.source.idle-timeout and setIdleStateRetentionTime ?

2021-01-27 Thread Dcosta, Agnelo (HBO)
-retention-time And if table.exec.state.ttl makes any difference to match_recognize state ? From: Dawid Wysakowicz Date: Wednesday, January 27, 2021 at 12:41 AM To: Dcosta, Agnelo (HBO) , user@flink.apache.org Subject: Re: Difference between table.exec.source.idle-timeout and

Re: Difference between table.exec.source.idle-timeout and setIdleStateRetentionTime ?

2021-01-26 Thread Dcosta, Agnelo (HBO)
. thanks. From: Dawid Wysakowicz Date: Tuesday, January 26, 2021 at 3:14 AM To: Dcosta, Agnelo (HBO) , user@flink.apache.org Subject: Re: Difference between table.exec.source.idle-timeout and setIdleStateRetentionTime ? **External Email received from: dwysakow...@apache.org ** Hi, The

Difference between table.exec.source.idle-timeout and setIdleStateRetentionTime ?

2021-01-25 Thread Dcosta, Agnelo (HBO)
Hi, What is the difference between table.exec.source.idle-timeout and setIdleStateRetentionTime ? table.exec.source.idle-timeout: https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/config.html#table-exec-source-idle-timeout setIdleStateRetentionTime: https://ci.apache.or

FW: NPE in disposing flink sql group window when running flink using ./gradlew shadowJar run

2020-10-12 Thread Dcosta, Agnelo (HBO)
Flink application using kafka topics as source and destination. Using javaVersion = '1.11' flinkVersion = '1.11.1' scalaBinaryVersion ='2.11' the application is primarily using Flink SQL apis. We have a StatementSet and add sql inserts to that set using addInsertSql. when there are more insert st