Re: [PR] [FLINK-31481][table] Support enhanced show databases syntax [flink]

2023-10-28 Thread via GitHub
jeyhunkarimov commented on PR #23612: URL: https://github.com/apache/flink/pull/23612#issuecomment-1784015344 Hi @luoyuxia @chucheng92 could you please review the PR? Thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Closed] (FLINK-33366) can not accept statement "EXECUTE STATEMENT SET BEGIN"

2023-10-28 Thread macdoor615 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] macdoor615 closed FLINK-33366. -- Release Note: This is an issue of beeline 3.2.3, not Flink JDBC Driver's Resolution: Not A Bug >

Re: [PR] [FLINK-31481][table] Support enhanced show databases syntax [flink]

2023-10-28 Thread via GitHub
flinkbot commented on PR #23612: URL: https://github.com/apache/flink/pull/23612#issuecomment-1783926004 ## CI report: * 20780e6cdb3a857980151ed51bcb8deafdfa06b1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-31481) Support enhanced show databases syntax

2023-10-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31481: --- Labels: pull-request-available (was: ) > Support enhanced show databases syntax > -

[PR] [FLINK-31481][table] Support enhanced show databases syntax [flink]

2023-10-28 Thread via GitHub
jeyhunkarimov opened a new pull request, #23612: URL: https://github.com/apache/flink/pull/23612 ## What is the purpose of the change Support enhanced show functions syntax described in [FLIP-297](https://cwiki.apache.org/confluence/display/FLINK/FLIP-297%3A+Improve+Auxiliary+Sql+Stat

[jira] [Closed] (FLINK-33089) Drop Flink 1.13 and 1.14 support for the operator

2023-10-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-33089. -- Resolution: Fixed merged to main e1c3192fdda1b22373a0e5821856c028bd4183b8 > Drop Flink 1.13 and 1.14

Re: [PR] [FLINK-33089] Drop support for Flink 1.13 and 1.14 and clean up related codepaths [flink-kubernetes-operator]

2023-10-28 Thread via GitHub
gyfora merged PR #692: URL: https://github.com/apache/flink-kubernetes-operator/pull/692 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr

Re: [PR] [FLINK-33089] Drop support for Flink 1.13 and 1.14 and clean up related codepaths [flink-kubernetes-operator]

2023-10-28 Thread via GitHub
gyfora closed pull request #692: [FLINK-33089] Drop support for Flink 1.13 and 1.14 and clean up related codepaths URL: https://github.com/apache/flink-kubernetes-operator/pull/692 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Updated] (FLINK-33132) Flink Connector Redshift Sink Implementation

2023-10-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33132: --- Labels: pull-request-available (was: ) > Flink Connector Redshift Sink Implementation > --

[PR] [WIP][FLINK-33132]Flink Connector Redshift [flink-connector-aws]

2023-10-28 Thread via GitHub
Samrat002 opened a new pull request, #111: URL: https://github.com/apache/flink-connector-aws/pull/111 ## Purpose of the change Implement Redshift Sink ## Significant changes *(Please check any boxes [x] if the answer is "yes". You can first publish the PR and check them af

Re: [PR] Draft [FLINK-33335] (CI) [flink]

2023-10-28 Thread via GitHub
afedulov commented on PR #23605: URL: https://github.com/apache/flink/pull/23605#issuecomment-1783872492 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comme

Re: [PR] [hotfix] Prepare StatefulSequenceSource for removal in 2.0 [flink]

2023-10-28 Thread via GitHub
flinkbot commented on PR #23611: URL: https://github.com/apache/flink/pull/23611#issuecomment-1783807219 ## CI report: * 4e84ba69623b5e33b7dceba75e6eace819a48301 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32694) Migrate ParallelSourceFunction classes to Source V2 API or prepare for removal

2023-10-28 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-32694: -- Description:   * SimpleEndlessSourceWithBloatedState in HeavyDeploymentStressTestProg

[jira] [Updated] (FLINK-32694) Migrate ParallelSourceFunction classes to Source V2 API or prepare for removal

2023-10-28 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-32694: -- Summary: Migrate ParallelSourceFunction classes to Source V2 API or prepare for remova

Re: [PR] [FLINK-33260] Allow user to provide a list of recoverable exceptions [flink-connector-aws]

2023-10-28 Thread via GitHub
iemre commented on code in PR #110: URL: https://github.com/apache/flink-connector-aws/pull/110#discussion_r1375229089 ## flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/FanOutShardSubscriber.java: #

Re: [PR] [FLINK-33260] Allow user to provide a list of recoverable exceptions [flink-connector-aws]

2023-10-28 Thread via GitHub
iemre commented on code in PR #110: URL: https://github.com/apache/flink-connector-aws/pull/110#discussion_r1375229089 ## flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/FanOutShardSubscriber.java: #

[jira] [Resolved] (FLINK-33375) Add a RestoreTestBase

2023-10-28 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-33375. -- Resolution: Fixed Implemented in dcce3764a4500b2006cd260677169d14c553a3eb..d863ff38c0

Re: [PR] [FLINK-33375] Implement restore test base [flink]

2023-10-28 Thread via GitHub
dawidwys closed pull request #23603: [FLINK-33375] Implement restore test base URL: https://github.com/apache/flink/pull/23603 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. T

[jira] (FLINK-26050) Too many small sst files in rocksdb state backend when using processing time window

2023-10-28 Thread wuzq (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26050 ] wuzq deleted comment on FLINK-26050: -- was (Author: wzqiang1332): [~shenjiaqi] [~mayuehappy] Is there a solution to this problem.Using  _state.backend.rocksdb.timer-service.factory to heap, but rocks