[jira] [Commented] (FLINK-31182) CompiledPlan cannot deserialize BridgingSqlFunction with MissingTypeStrategy

2023-03-04 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696532#comment-17696532 ] Jane Chan commented on FLINK-31182: --- Hi [~twalthr], thanks for the fix!  LGTM, and feel free to merge.

[GitHub] [flink] 1996fanrui commented on a diff in pull request #22084: [WIP][FLINK-31293][runtime] LocalBufferPool request overdraft buffer only when no available buffer and pool size is reached

2023-03-04 Thread via GitHub
1996fanrui commented on code in PR #22084: URL: https://github.com/apache/flink/pull/22084#discussion_r1125605884 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java: ## @@ -396,7 +396,7 @@ private MemorySegment

[GitHub] [flink] flinkbot commented on pull request #22097: [FLINK-30983][runtime] Support configured ssl algorithms for external REST SSL

2023-03-04 Thread via GitHub
flinkbot commented on PR #22097: URL: https://github.com/apache/flink/pull/22097#issuecomment-1454976854 ## CI report: * 8ce5ceecce326e6dc777821a3f1dc332bb740cf5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] TanYuxin-tyx commented on pull request #21937: [FLINK-30983][runtime] Support configured ssl algorithms for external REST SSL

2023-03-04 Thread via GitHub
TanYuxin-tyx commented on PR #21937: URL: https://github.com/apache/flink/pull/21937#issuecomment-1454976667 > Thanks @TanYuxin-tyx, LGTM! Would you mind backport this to release-1.17 branch? OK, Thanks @reswqa , I have opened a new PR for 1.17.

[GitHub] [flink] TanYuxin-tyx opened a new pull request, #22097: [FLINK-30983][runtime] Support configured ssl algorithms for external REST SSL

2023-03-04 Thread via GitHub
TanYuxin-tyx opened a new pull request, #22097: URL: https://github.com/apache/flink/pull/22097 ## What is the purpose of the change *Support configured ssl algorithms for external REST SSL* ## Brief change log *(for example:)* - *Support configured

[GitHub] [flink] TanYuxin-tyx closed pull request #22095: [FLINK-30983][runtime] Support configured ssl algorithms for external REST SSL

2023-03-04 Thread via GitHub
TanYuxin-tyx closed pull request #22095: [FLINK-30983][runtime] Support configured ssl algorithms for external REST SSL URL: https://github.com/apache/flink/pull/22095 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] flinkbot commented on pull request #22095: [FLINK-30983][runtime] Support configured ssl algorithms for external REST SSL

2023-03-04 Thread via GitHub
flinkbot commented on PR #22095: URL: https://github.com/apache/flink/pull/22095#issuecomment-1454974947 ## CI report: * d04c9fab357e41ffa6a777d9796c8b56feb29f0a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] TanYuxin-tyx closed pull request #22096: [FLINK-30983][runtime] Support configured ssl algorithms for external REST SSL

2023-03-04 Thread via GitHub
TanYuxin-tyx closed pull request #22096: [FLINK-30983][runtime] Support configured ssl algorithms for external REST SSL URL: https://github.com/apache/flink/pull/22096 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] TanYuxin-tyx opened a new pull request, #22096: [FLINK-30983][runtime] Support configured ssl algorithms for external REST SSL

2023-03-04 Thread via GitHub
TanYuxin-tyx opened a new pull request, #22096: URL: https://github.com/apache/flink/pull/22096 ## What is the purpose of the change *Support configured ssl algorithms for external REST SSL* ## Brief change log *(for example:)* - *Support configured

[GitHub] [flink] TanYuxin-tyx opened a new pull request, #22095: [FLINK-30983][runtime] Support configured ssl algorithms for external REST SSL

2023-03-04 Thread via GitHub
TanYuxin-tyx opened a new pull request, #22095: URL: https://github.com/apache/flink/pull/22095 ## What is the purpose of the change *Support configured ssl algorithms for external REST SSL* Cherry-pick to 1.17, the change is reviewed in

[GitHub] [flink] felixzh2020 commented on pull request #22093: [FLINK-31321] Yarn-session mode, securityConfiguration supports dynam…

2023-03-04 Thread via GitHub
felixzh2020 commented on PR #22093: URL: https://github.com/apache/flink/pull/22093#issuecomment-1454951273 @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

[jira] [Updated] (FLINK-31321) Yarn-session mode, securityConfiguration supports dynamic configuration

2023-03-04 Thread felixzh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] felixzh updated FLINK-31321: Fix Version/s: 1.17.0 > Yarn-session mode, securityConfiguration supports dynamic configuration >

[jira] [Updated] (FLINK-31321) Yarn-session mode, securityConfiguration supports dynamic configuration

2023-03-04 Thread felixzh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] felixzh updated FLINK-31321: Affects Version/s: (was: 1.16.1) > Yarn-session mode, securityConfiguration supports dynamic

[jira] [Updated] (FLINK-31321) Yarn-session mode, securityConfiguration supports dynamic configuration

2023-03-04 Thread felixzh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] felixzh updated FLINK-31321: Affects Version/s: 1.16.1 > Yarn-session mode, securityConfiguration supports dynamic configuration >

[GitHub] [flink-connector-opensearch] lilyevsky commented on a diff in pull request #11: [FLINK-30998] Add optional exception handler to flink-connector-opensearch

2023-03-04 Thread via GitHub
lilyevsky commented on code in PR #11: URL: https://github.com/apache/flink-connector-opensearch/pull/11#discussion_r1125513579 ## flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/OpensearchSinkBuilder.java: ## @@ -148,6 +150,7 @@ public

[jira] [Closed] (FLINK-30331) Further improvement of production availability of hybrid shuffle

2023-03-04 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-30331. -- Fix Version/s: 1.17.0 Resolution: Done > Further improvement of production availability of

[GitHub] [flink] Myasuka commented on pull request #22058: [FLINK-31283][docs] Update the scala-2.11 related building doc

2023-03-04 Thread via GitHub
Myasuka commented on PR #22058: URL: https://github.com/apache/flink/pull/22058#issuecomment-1454790346 @zentol please take a review on this. -- 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

[GitHub] [flink] flinkbot commented on pull request #22094: [FLINK-31324][connector] Make previous SingleThreadFetcherManager constructor deprecated

2023-03-04 Thread via GitHub
flinkbot commented on PR #22094: URL: https://github.com/apache/flink/pull/22094#issuecomment-1454790168 ## CI report: * 6abcd0b030445a5fd0692ba67b397706231aa112 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-31324) Broken SingleThreadFetcherManager constructor API

2023-03-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31324: --- Labels: pull-request-available (was: ) > Broken SingleThreadFetcherManager constructor API

[GitHub] [flink] Myasuka opened a new pull request, #22094: [FLINK-31324][connector] Make previous SingleThreadFetcherManager constructor deprecated

2023-03-04 Thread via GitHub
Myasuka opened a new pull request, #22094: URL: https://github.com/apache/flink/pull/22094 ## What is the purpose of the change [FLINK-28853](https://issues.apache.org/jira/browse/FLINK-28853) changed the default constructor of SingleThreadFetcherManager. Though the

[GitHub] [flink-connector-opensearch] reta commented on a diff in pull request #11: [FLINK-30998] Add optional exception handler to flink-connector-opensearch

2023-03-04 Thread via GitHub
reta commented on code in PR #11: URL: https://github.com/apache/flink-connector-opensearch/pull/11#discussion_r1125495890 ## flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/OpensearchSinkBuilder.java: ## @@ -148,6 +150,7 @@ public

[GitHub] [flink-connector-opensearch] reta commented on pull request #11: [FLINK-30998] Add optional exception handler to flink-connector-opensearch

2023-03-04 Thread via GitHub
reta commented on PR #11: URL: https://github.com/apache/flink-connector-opensearch/pull/11#issuecomment-1454787590 @MartijnVisser @zentol could you please take a look guys? thank you! -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Comment Edited] (FLINK-31310) Force clear directory no matter what situation in HiveCatalog.dropTable

2023-03-04 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696460#comment-17696460 ] Nicholas Jiang edited comment on FLINK-31310 at 3/4/23 4:02 PM:

[GitHub] [flink-connector-opensearch] lilyevsky commented on a diff in pull request #11: [FLINK-30998] Add optional exception handler to flink-connector-opensearch

2023-03-04 Thread via GitHub
lilyevsky commented on code in PR #11: URL: https://github.com/apache/flink-connector-opensearch/pull/11#discussion_r1125495620 ## flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/OpensearchWriter.java: ## @@ -122,10 +128,11 @@ }

[jira] [Commented] (FLINK-31310) Force clear directory no matter what situation in HiveCatalog.dropTable

2023-03-04 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696460#comment-17696460 ] Nicholas Jiang commented on FLINK-31310: [~lzljs3620320], the `dropTable` interface is invoked

[jira] [Commented] (FLINK-31324) Broken SingleThreadFetcherManager constructor API

2023-03-04 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696457#comment-17696457 ] Yun Tang commented on FLINK-31324: -- cc [~jark] [~mxm] > Broken SingleThreadFetcherManager constructor

[jira] [Updated] (FLINK-31324) Broken SingleThreadFetcherManager constructor API

2023-03-04 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-31324: - Description: FLINK-28853 changed the default constructor of {{SingleThreadFetcherManager}}. Though the

[jira] [Created] (FLINK-31324) Broken SingleThreadFetcherManager constructor API

2023-03-04 Thread Yun Tang (Jira)
Yun Tang created FLINK-31324: Summary: Broken SingleThreadFetcherManager constructor API Key: FLINK-31324 URL: https://issues.apache.org/jira/browse/FLINK-31324 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-28853) FLIP-217 Support watermark alignment of source splits

2023-03-04 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696448#comment-17696448 ] Yun Tang commented on FLINK-28853: -- [~mxm] It seems the docs are still not updated? > FLIP-217 Support

[GitHub] [flink-connector-opensearch] reta commented on a diff in pull request #11: [FLINK-30998] Add optional exception handler to flink-connector-opensearch

2023-03-04 Thread via GitHub
reta commented on code in PR #11: URL: https://github.com/apache/flink-connector-opensearch/pull/11#discussion_r1125470984 ## flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/OpensearchWriter.java: ## @@ -122,10 +128,11 @@ } catch

[GitHub] [flink] felixzh2020 commented on pull request #22093: [FLINK-31321] Yarn-session mode, securityConfiguration supports dynam…

2023-03-04 Thread via GitHub
felixzh2020 commented on PR #22093: URL: https://github.com/apache/flink/pull/22093#issuecomment-1454738229 @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

[jira] [Updated] (FLINK-31319) Inconsistent condition judgement about kafka partitionDiscoveryIntervalMs cause potential bug

2023-03-04 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-31319: Description: As kafka option description, partitionDiscoveryIntervalMs <=0 means disabled.

[GitHub] [flink-ml] lindong28 commented on a diff in pull request #218: [FLINK-31306] Add Servable for PipelineModel

2023-03-04 Thread via GitHub
lindong28 commented on code in PR #218: URL: https://github.com/apache/flink-ml/pull/218#discussion_r1125428753 ## flink-ml-core/src/main/java/org/apache/flink/ml/builder/PipelineModel.java: ## @@ -82,6 +85,33 @@ public static PipelineModel load(StreamTableEnvironment tEnv,

[GitHub] [flink-connector-cassandra] echauchot commented on pull request #3: [FLINK-26822] Add Cassandra Source

2023-03-04 Thread via GitHub
echauchot commented on PR #3: URL: https://github.com/apache/flink-connector-cassandra/pull/3#issuecomment-1454671877 @mosche contributed testContainers configuration that allows to avoid having a private docker image + timeouts etc... -- This is an automated message from the Apache Git

[jira] [Updated] (FLINK-31323) Fix unstable merge-into E2E test

2023-03-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31323: --- Labels: pull-request-available (was: ) > Fix unstable merge-into E2E test >

[GitHub] [flink-table-store] yuzelin opened a new pull request, #580: [FLINK-31323] Fix unstable merge-into E2E test

2023-03-04 Thread via GitHub
yuzelin opened a new pull request, #580: URL: https://github.com/apache/flink-table-store/pull/580 Simplify `FlinkActionsE2eTest#testMergeInto`. -- 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

[jira] [Commented] (FLINK-27051) CompletedCheckpoint.DiscardObject.discard is not idempotent

2023-03-04 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696419#comment-17696419 ] Wencong Liu commented on FLINK-27051: - Hello [~mapohl] , I'm quite interested in the issues under