[jira] [Commented] (FLINK-31774) Add document for delete and update statement

2023-04-13 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712195#comment-17712195 ] Aitozi commented on FLINK-31774: Hi [~luoyuxia] The pr is ready for review, please take a look when you

[GitHub] [flink] flinkbot commented on pull request #22398: [FLINK-31774][doc] Add document for delete and update statement

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

[jira] [Updated] (FLINK-31774) Add document for delete and update statement

2023-04-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31774: --- Labels: pull-request-available (was: ) > Add document for delete and update statement >

[GitHub] [flink] Aitozi opened a new pull request, #22398: [FLINK-31774][doc] Add document for delete and update statement

2023-04-13 Thread via GitHub
Aitozi opened a new pull request, #22398: URL: https://github.com/apache/flink/pull/22398 ## What is the purpose of the change Add doc for update and delete statement. ## Brief change log *(for example:)* - *The TaskInfo is stored in the blob store on job

[GitHub] [flink] 1996fanrui commented on a diff in pull request #22392: [FLINK-31588][checkpoint] Correct the unaligned checkpoint type after aligned barrier timeout to unaligned barrier on PipelinedS

2023-04-13 Thread via GitHub
1996fanrui commented on code in PR #22392: URL: https://github.com/apache/flink/pull/22392#discussion_r1166290066 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java: ## @@ -381,7 +383,7 @@ private void

[GitHub] [flink-web] elphastori commented on a diff in pull request #640: Add MongoDB v1.0.1 for Flink 1.16.x and Flink 1.17.x

2023-04-13 Thread via GitHub
elphastori commented on code in PR #640: URL: https://github.com/apache/flink-web/pull/640#discussion_r1166270392 ## docs/data/release_archive.yml: ## @@ -428,6 +428,11 @@ release_archive: version: 1.0.0 release_date: 2022-12-21 filename: "opensearch" +

[jira] [Commented] (FLINK-31793) Remove dependency on flink-shaded for flink-connector-jdbc

2023-04-13 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712184#comment-17712184 ] Wencong Liu commented on FLINK-31793: - I've opened a pull request. Please take a look :)

[GitHub] [flink-web] elphastori commented on a diff in pull request #638: Add JDBC v3.1.0 for Flink 1.16.x and Flink 1.17.x

2023-04-13 Thread via GitHub
elphastori commented on code in PR #638: URL: https://github.com/apache/flink-web/pull/638#discussion_r1166254603 ## docs/data/release_archive.yml: ## @@ -428,6 +428,11 @@ release_archive: version: 1.0.0 release_date: 2022-12-21 filename: "opensearch" +

[jira] [Updated] (FLINK-31793) Remove dependency on flink-shaded for flink-connector-jdbc

2023-04-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31793: --- Labels: pull-request-available (was: ) > Remove dependency on flink-shaded for

[GitHub] [flink-connector-jdbc] boring-cyborg[bot] commented on pull request #40: [FLINK-31793] remove dependency on flink-shaded guava for flink-connector-jdbc

2023-04-13 Thread via GitHub
boring-cyborg[bot] commented on PR #40: URL: https://github.com/apache/flink-connector-jdbc/pull/40#issuecomment-1507890242 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This is

[GitHub] [flink-connector-jdbc] WencongLiu opened a new pull request, #40: [FLINK-31793] remove dependency on flink-shaded guava for flink-connector-jdbc

2023-04-13 Thread via GitHub
WencongLiu opened a new pull request, #40: URL: https://github.com/apache/flink-connector-jdbc/pull/40 _Remove the dependency on flink-shaded guava for flink-connector-jdbc._ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Commented] (FLINK-31754) Build flink master error with Error in ASM processing class org/apache/calcite/sql/validate/SqlValidatorImpl$NavigationExpander.class: 19

2023-04-13 Thread Small Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712182#comment-17712182 ] Small Wong commented on FLINK-31754: [~martijnvisser] hi, I met the same problem in Linux env. >

[jira] [Commented] (FLINK-29398) Utilize Rack Awareness in Flink Consumer

2023-04-13 Thread Chirag Dewan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712174#comment-17712174 ] Chirag Dewan commented on FLINK-29398: -- Yeah, that makes sense. Thanks [~jeremy.degroot] for taking

[jira] [Commented] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

2023-04-13 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712173#comment-17712173 ] Weihua Hu commented on FLINK-31757: --- I would like to bring in a common scenario that can't set tasks

[GitHub] [flink] FangYongs commented on pull request #22360: [FLINK-31741][jdbc-driver] Support data converter for value in statement result

2023-04-13 Thread via GitHub
FangYongs commented on PR #22360: URL: https://github.com/apache/flink/pull/22360#issuecomment-1507869543 Thanks @libenchao I have updated this PR -- 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

[GitHub] [flink] huwh commented on pull request #22305: [FLINK-31443][runtime] Maintain redundant taskmanagers to speed up failover

2023-04-13 Thread via GitHub
huwh commented on PR #22305: URL: https://github.com/apache/flink/pull/22305#issuecomment-1507864516 Thanks @xintongsong and @reswqa for the review. I have updated this pr as suggested -- This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Commented] (FLINK-31655) Adaptive Channel selection for partitioner

2023-04-13 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712168#comment-17712168 ] tartarus commented on FLINK-31655: -- [~akalash] [~pnowojski] [~pltbkd] Thank you very much for your

[jira] [Commented] (FLINK-31795) Add Config to enable/disable savepoint cleanup

2023-04-13 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712167#comment-17712167 ] Yun Tang commented on FLINK-31795: -- [~darenwkt] If users want to keep the full savepoint history, why

[GitHub] [flink] Aitozi commented on pull request #21622: [FLINK-30570] Fix error inferred partition condition

2023-04-13 Thread via GitHub
Aitozi commented on PR #21622: URL: https://github.com/apache/flink/pull/21622#issuecomment-1507842015 @godfreyhe Can you help take a final look on this PR ? Or the patch need to keep update to fix conflict -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Closed] (FLINK-27144) Provide timeout details when calling FutureUtils.orTimeout

2023-04-13 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang closed FLINK-27144. -- Resolution: Done > Provide timeout details when calling FutureUtils.orTimeout >

[jira] [Commented] (FLINK-27144) Provide timeout details when calling FutureUtils.orTimeout

2023-04-13 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712155#comment-17712155 ] Lijie Wang commented on FLINK-27144: Done via master: a81ffa6d019d9891bd3a54f50fb36ad847721daa >

[GitHub] [flink] wanglijie95 closed pull request #22367: [FLINK-27144][runtime] Provide timeout details when calling FutureUtils.orTimeout

2023-04-13 Thread via GitHub
wanglijie95 closed pull request #22367: [FLINK-27144][runtime] Provide timeout details when calling FutureUtils.orTimeout URL: https://github.com/apache/flink/pull/22367 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] liuyongvs commented on a diff in pull request #22324: [FLINK-31691][table] Add built-in MAP_FROM_ENTRIES function.

2023-04-13 Thread via GitHub
liuyongvs commented on code in PR #22324: URL: https://github.com/apache/flink/pull/22324#discussion_r1166210706 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/ExecutionConfigOptions.java: ## @@ -435,6 +435,16 @@ public class

[jira] [Closed] (FLINK-31007) The code generated by the IF function throws NullPointerException

2023-04-13 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-31007. --- Resolution: Duplicate > The code generated by the IF function throws NullPointerException >

[GitHub] [flink-connector-jdbc] xuzhiwen1255 commented on pull request #28: [hotfix] [doc] Fix the configuration item error of docs/content.zh/docs/connectors/table/jdbc.md

2023-04-13 Thread via GitHub
xuzhiwen1255 commented on PR #28: URL: https://github.com/apache/flink-connector-jdbc/pull/28#issuecomment-1507811739 @MartijnVisser Sorry, i made a mistake, it should be that the current jdbc lookup configuration is obsolete, and we should replace it with the latest lookup configuration.

[GitHub] [flink-connector-jdbc] xuzhiwen1255 opened a new pull request, #28: [hotfix] [doc] Fix the configuration item error of docs/content.zh/docs/connectors/table/jdbc.md

2023-04-13 Thread via GitHub
xuzhiwen1255 opened a new pull request, #28: URL: https://github.com/apache/flink-connector-jdbc/pull/28 ## What is the purpose of the change Fix lookup.cache.max-rows in docs/content.zh/docs/connectors/table/jdbc.md configuration ## Brief change log Fix

[jira] [Commented] (FLINK-25509) FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records

2023-04-13 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712144#comment-17712144 ] Dong Lin commented on FLINK-25509: -- [~syhily] In the PR related to this JIRA, we added an internal

[jira] [Assigned] (FLINK-30282) Logical type ROW lost inner field's nullability after convert to RelDataType

2023-04-13 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-30282: --- Assignee: Jane Chan > Logical type ROW lost inner field's nullability after convert to

[GitHub] [flink-connector-jdbc] xuzhiwen1255 closed pull request #28: [hotfix] [doc] Fix the configuration item error of docs/content.zh/docs/connectors/table/jdbc.md

2023-04-13 Thread via GitHub
xuzhiwen1255 closed pull request #28: [hotfix] [doc] Fix the configuration item error of docs/content.zh/docs/connectors/table/jdbc.md URL: https://github.com/apache/flink-connector-jdbc/pull/28 -- This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Updated] (FLINK-31255) OperatorUtils#createWrappedOperatorConfig fails to wrap operator config

2023-04-13 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-31255: - Description: Currently we use operator wrapper to enable using normal operators in iterations.

[jira] [Created] (FLINK-31801) Missing elasticsearch connector on maven central repository

2023-04-13 Thread Fang Yong (Jira)
Fang Yong created FLINK-31801: - Summary: Missing elasticsearch connector on maven central repository Key: FLINK-31801 URL: https://issues.apache.org/jira/browse/FLINK-31801 Project: Flink

[GitHub] [flink] hustonic commented on pull request #22397: [hotfix] Fix typos of comment

2023-04-13 Thread via GitHub
hustonic commented on PR #22397: URL: https://github.com/apache/flink/pull/22397#issuecomment-1507772297 @MartijnVisser Hi, do you think it's right this time? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] hustonic commented on pull request #22397: [hotfix] Fix typos of comment

2023-04-13 Thread via GitHub
hustonic commented on PR #22397: URL: https://github.com/apache/flink/pull/22397#issuecomment-1507768849 Associated with this PR: #22370 -- 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] hustonic commented on pull request #22397: [hotfix] Fix typos of comment

2023-04-13 Thread via GitHub
hustonic commented on PR #22397: URL: https://github.com/apache/flink/pull/22397#issuecomment-1507432089 #22370 -- 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

[GitHub] [flink] flinkbot commented on pull request #22397: [hotfix] Fix typos of comment

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

[GitHub] [flink] hustonic opened a new pull request, #22397: [hotfix] Fix typos of comment

2023-04-13 Thread via GitHub
hustonic opened a new pull request, #22397: URL: https://github.com/apache/flink/pull/22397 ## What is the purpose of the change Fix typos of comment -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Commented] (FLINK-29692) Support early/late fires for Windowing TVFs

2023-04-13 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711990#comment-17711990 ] Martijn Visser commented on FLINK-29692: [~charles-tan] I don’t think there’s consensus yet how

[GitHub] [flink-statefun-playground] dependabot[bot] closed pull request #41: Bump undertow-core from 2.2.16.Final to 2.2.19.Final in /playground-internal/statefun-playground-entrypoint

2023-04-13 Thread via GitHub
dependabot[bot] closed pull request #41: Bump undertow-core from 2.2.16.Final to 2.2.19.Final in /playground-internal/statefun-playground-entrypoint URL: https://github.com/apache/flink-statefun-playground/pull/41 -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink-statefun-playground] dependabot[bot] commented on pull request #41: Bump undertow-core from 2.2.16.Final to 2.2.19.Final in /playground-internal/statefun-playground-entrypoint

2023-04-13 Thread via GitHub
dependabot[bot] commented on PR #41: URL: https://github.com/apache/flink-statefun-playground/pull/41#issuecomment-1507331202 Superseded by #61. -- 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

[GitHub] [flink-statefun-playground] dependabot[bot] opened a new pull request, #61: Bump undertow-core from 2.2.16.Final to 2.2.24.Final in /playground-internal/statefun-playground-entrypoint

2023-04-13 Thread via GitHub
dependabot[bot] opened a new pull request, #61: URL: https://github.com/apache/flink-statefun-playground/pull/61 Bumps [undertow-core](https://github.com/undertow-io/undertow) from 2.2.16.Final to 2.2.24.Final. Commits

[GitHub] [flink-statefun-playground] dependabot[bot] closed pull request #40: Bump undertow-core from 1.4.18.Final to 2.2.19.Final in /java/connected-components

2023-04-13 Thread via GitHub
dependabot[bot] closed pull request #40: Bump undertow-core from 1.4.18.Final to 2.2.19.Final in /java/connected-components URL: https://github.com/apache/flink-statefun-playground/pull/40 -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink-statefun-playground] dependabot[bot] commented on pull request #40: Bump undertow-core from 1.4.18.Final to 2.2.19.Final in /java/connected-components

2023-04-13 Thread via GitHub
dependabot[bot] commented on PR #40: URL: https://github.com/apache/flink-statefun-playground/pull/40#issuecomment-1507329451 Superseded by #60. -- 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

[GitHub] [flink-statefun-playground] dependabot[bot] closed pull request #39: Bump undertow-core from 1.4.18.Final to 2.2.19.Final in /java/showcase

2023-04-13 Thread via GitHub
dependabot[bot] closed pull request #39: Bump undertow-core from 1.4.18.Final to 2.2.19.Final in /java/showcase URL: https://github.com/apache/flink-statefun-playground/pull/39 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink-statefun-playground] dependabot[bot] closed pull request #38: Bump undertow-core from 1.4.18.Final to 2.2.19.Final in /java/greeter

2023-04-13 Thread via GitHub
dependabot[bot] closed pull request #38: Bump undertow-core from 1.4.18.Final to 2.2.19.Final in /java/greeter URL: https://github.com/apache/flink-statefun-playground/pull/38 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink-statefun-playground] dependabot[bot] commented on pull request #39: Bump undertow-core from 1.4.18.Final to 2.2.19.Final in /java/showcase

2023-04-13 Thread via GitHub
dependabot[bot] commented on PR #39: URL: https://github.com/apache/flink-statefun-playground/pull/39#issuecomment-1507329421 Superseded by #59. -- 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

[GitHub] [flink-statefun-playground] dependabot[bot] closed pull request #37: Bump undertow-core from 1.4.18.Final to 2.2.19.Final in /java/shopping-cart

2023-04-13 Thread via GitHub
dependabot[bot] closed pull request #37: Bump undertow-core from 1.4.18.Final to 2.2.19.Final in /java/shopping-cart URL: https://github.com/apache/flink-statefun-playground/pull/37 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink-statefun-playground] dependabot[bot] opened a new pull request, #60: Bump undertow-core from 1.4.18.Final to 2.2.24.Final in /java/connected-components

2023-04-13 Thread via GitHub
dependabot[bot] opened a new pull request, #60: URL: https://github.com/apache/flink-statefun-playground/pull/60 Bumps [undertow-core](https://github.com/undertow-io/undertow) from 1.4.18.Final to 2.2.24.Final. Commits

[GitHub] [flink-statefun-playground] dependabot[bot] commented on pull request #37: Bump undertow-core from 1.4.18.Final to 2.2.19.Final in /java/shopping-cart

2023-04-13 Thread via GitHub
dependabot[bot] commented on PR #37: URL: https://github.com/apache/flink-statefun-playground/pull/37#issuecomment-1507329389 Superseded by #57. -- 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

[GitHub] [flink-statefun-playground] dependabot[bot] commented on pull request #38: Bump undertow-core from 1.4.18.Final to 2.2.19.Final in /java/greeter

2023-04-13 Thread via GitHub
dependabot[bot] commented on PR #38: URL: https://github.com/apache/flink-statefun-playground/pull/38#issuecomment-1507329412 Superseded by #58. -- 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

[GitHub] [flink-statefun-playground] dependabot[bot] opened a new pull request, #59: Bump undertow-core from 1.4.18.Final to 2.2.24.Final in /java/showcase

2023-04-13 Thread via GitHub
dependabot[bot] opened a new pull request, #59: URL: https://github.com/apache/flink-statefun-playground/pull/59 Bumps [undertow-core](https://github.com/undertow-io/undertow) from 1.4.18.Final to 2.2.24.Final. Commits

[GitHub] [flink-statefun-playground] dependabot[bot] opened a new pull request, #57: Bump undertow-core from 1.4.18.Final to 2.2.24.Final in /java/shopping-cart

2023-04-13 Thread via GitHub
dependabot[bot] opened a new pull request, #57: URL: https://github.com/apache/flink-statefun-playground/pull/57 Bumps [undertow-core](https://github.com/undertow-io/undertow) from 1.4.18.Final to 2.2.24.Final. Commits

[GitHub] [flink-statefun-playground] dependabot[bot] opened a new pull request, #58: Bump undertow-core from 1.4.18.Final to 2.2.24.Final in /java/greeter

2023-04-13 Thread via GitHub
dependabot[bot] opened a new pull request, #58: URL: https://github.com/apache/flink-statefun-playground/pull/58 Bumps [undertow-core](https://github.com/undertow-io/undertow) from 1.4.18.Final to 2.2.24.Final. Commits

[GitHub] [flink] hustonic closed pull request #22370: [hotfix] Fix typos of comment

2023-04-13 Thread via GitHub
hustonic closed pull request #22370: [hotfix] Fix typos of comment URL: https://github.com/apache/flink/pull/22370 -- 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

[jira] [Updated] (FLINK-22828) Allow using a custom AWS credentials provider for the Kinesis Connector

2023-04-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22828: --- Labels: auto-unassigned pull-request-available (was: auto-unassigned) > Allow using a

[GitHub] [flink-connector-aws] iemre opened a new pull request, #69: [FLINK-22828][Connectors/AWS] DRAFT - Configure custom AWS creds provider

2023-04-13 Thread via GitHub
iemre opened a new pull request, #69: URL: https://github.com/apache/flink-connector-aws/pull/69 ## Purpose of the change *For example: Implements the Table API for the Kinesis Source.* ## Verifying this change Please make sure both new and modified tests in this

[GitHub] [flink] flinkbot commented on pull request #22396: [hotfix] [docs] fix typo in mysql db prompt

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

[jira] [Commented] (FLINK-31121) KafkaSink should be able to catch and ignore exp via config on/off

2023-04-13 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711966#comment-17711966 ] Mason Chen commented on FLINK-31121: [~zjureel] gentle ping^ let me know if you are still into it!

[GitHub] [flink] jayjayjpg opened a new pull request, #22396: [hotfix] [docs] fix typo in mysql db prompt

2023-04-13 Thread via GitHub
jayjayjpg opened a new pull request, #22396: URL: https://github.com/apache/flink/pull/22396 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

[jira] [Commented] (FLINK-29692) Support early/late fires for Windowing TVFs

2023-04-13 Thread Chalres Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711958#comment-17711958 ] Chalres Tan commented on FLINK-29692: - Hi all, I notice this thread has gotten a little bit stale

[jira] [Created] (FLINK-31800) Update tika to current

2023-04-13 Thread Morey Straus (Jira)
Morey Straus created FLINK-31800: Summary: Update tika to current Key: FLINK-31800 URL: https://issues.apache.org/jira/browse/FLINK-31800 Project: Flink Issue Type: Technical Debt

[jira] [Commented] (FLINK-31789) Update axel to current

2023-04-13 Thread Morey Straus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711954#comment-17711954 ] Morey Straus commented on FLINK-31789: -- This is coming from a Black Duck BA scan. It is part of an

[jira] [Commented] (FLINK-31655) Adaptive Channel selection for partitioner

2023-04-13 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711950#comment-17711950 ] Anton Kalashnikov commented on FLINK-31655: --- ??I wonder why the implementation in the pull

[GitHub] [flink] flinkbot commented on pull request #22395: [FLINK-31799][docs] Python connector download link should refer to the url defined in externalized repository

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

[GitHub] [flink-connector-pulsar] reswqa commented on a diff in pull request #43: [FLINK-31748] Dummy implementation to fix compilation failure

2023-04-13 Thread via GitHub
reswqa commented on code in PR #43: URL: https://github.com/apache/flink-connector-pulsar/pull/43#discussion_r1165713014 ## flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/PulsarSourceFetcherManager.java: ## @@ -86,6 +86,11 @@ public void

[jira] [Updated] (FLINK-31799) Python connector download link should refer to the url defined in externalized repository

2023-04-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31799: --- Labels: pull-request-available (was: ) > Python connector download link should refer to

[GitHub] [flink] reswqa opened a new pull request, #22395: [FLINK-31799][docs] Python connector download link should refer to the url defined in externalized repository

2023-04-13 Thread via GitHub
reswqa opened a new pull request, #22395: URL: https://github.com/apache/flink/pull/22395 ## What is the purpose of the change *Each externalized connector has its own yml file to manage the url of uber jar. We should introduce a new shortcode to support this.* ## Brief

[jira] [Updated] (FLINK-31799) Python connector download link should refer to the url defined in externalized repository

2023-04-13 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31799: --- Description: Each externalized connector has its own yml file to manage the url of uber jar. We

[GitHub] [flink] Aitozi commented on a diff in pull request #22386: [FLINK-31787][doc] Add explicit ROW constructor to sql functions doc

2023-04-13 Thread via GitHub
Aitozi commented on code in PR #22386: URL: https://github.com/apache/flink/pull/22386#discussion_r1165694629 ## docs/data/sql_functions.yml: ## @@ -933,11 +933,13 @@ valueconstruction: - sql: | -- implicit constructor with parenthesis (value1 [, value2]*) +

[jira] [Updated] (FLINK-31799) Python connector download link should refer to the url defined in externalized repository

2023-04-13 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31799: --- Affects Version/s: 1.18.0 > Python connector download link should refer to the url defined in >

[jira] [Created] (FLINK-31799) Python connector download link should refer to the url defined in externalized repository

2023-04-13 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-31799: -- Summary: Python connector download link should refer to the url defined in externalized repository Key: FLINK-31799 URL: https://issues.apache.org/jira/browse/FLINK-31799

[jira] [Closed] (FLINK-31759) Update some external connectors to use sql_connector_download_table and connector_artifact shortcode

2023-04-13 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-31759. -- Resolution: Fixed > Update some external connectors to use sql_connector_download_table and >

[jira] [Comment Edited] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

2023-04-13 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711932#comment-17711932 ] Rui Fan edited comment on FLINK-31757 at 4/13/23 3:08 PM: -- Hi [~chesnay] ,

[jira] [Commented] (FLINK-31759) Update some external connectors to use sql_connector_download_table and connector_artifact shortcode

2023-04-13 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711937#comment-17711937 ] Weijie Guo commented on FLINK-31759: flink-connector-elasticsearch: main via

[jira] [Resolved] (FLINK-31700) MongoDB nightly CI failure

2023-04-13 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-31700. --- Resolution: Fixed > MongoDB nightly CI failure > -- > >

[jira] [Comment Edited] (FLINK-31700) MongoDB nightly CI failure

2023-04-13 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711931#comment-17711931 ] Danny Cranmer edited comment on FLINK-31700 at 4/13/23 3:07 PM: CI now

[GitHub] [flink-connector-gcp-pubsub] boring-cyborg[bot] commented on pull request #7: [FLINK-31759][pubsub] Using connector_artifact shortcode for datastream document.

2023-04-13 Thread via GitHub
boring-cyborg[bot] commented on PR #7: URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/7#issuecomment-1507135130 Awesome work, congrats on your first merged pull request! -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink-connector-gcp-pubsub] reswqa merged pull request #7: [FLINK-31759][pubsub] Using connector_artifact shortcode for datastream document.

2023-04-13 Thread via GitHub
reswqa merged PR #7: URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/7 -- 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:

[GitHub] [flink-connector-gcp-pubsub] reswqa commented on pull request #7: [FLINK-31759][pubsub] Using connector_artifact shortcode for datastream document.

2023-04-13 Thread via GitHub
reswqa commented on PR #7: URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/7#issuecomment-1507134796 Thanks @TanYuxin-tyx, merged. -- 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

[GitHub] [flink-connector-hbase] boring-cyborg[bot] commented on pull request #8: [FLINK-31759][hbase] Using sql_connector_download_table shortcode for table document.

2023-04-13 Thread via GitHub
boring-cyborg[bot] commented on PR #8: URL: https://github.com/apache/flink-connector-hbase/pull/8#issuecomment-1507130686 Awesome work, congrats on your first merged pull request! -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink-connector-hbase] reswqa merged pull request #8: [FLINK-31759][hbase] Using sql_connector_download_table shortcode for table document.

2023-04-13 Thread via GitHub
reswqa merged PR #8: URL: https://github.com/apache/flink-connector-hbase/pull/8 -- 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:

[jira] [Updated] (FLINK-31798) Add config to enable/disable Kubernetes Events

2023-04-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31798: --- Labels: pull-request-available (was: ) > Add config to enable/disable Kubernetes Events >

[GitHub] [flink-connector-hbase] reswqa commented on pull request #8: [FLINK-31759][hbase] Using sql_connector_download_table shortcode for table document.

2023-04-13 Thread via GitHub
reswqa commented on PR #8: URL: https://github.com/apache/flink-connector-hbase/pull/8#issuecomment-1507130333 Thanks @TanYuxin-tyx, merged. -- 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-kubernetes-operator] darenwkt opened a new pull request, #566: [FLINK-31798] Add config to disable EventRecorder

2023-04-13 Thread via GitHub
darenwkt opened a new pull request, #566: URL: https://github.com/apache/flink-kubernetes-operator/pull/566 ## What is the purpose of the change Add config to give user control to enable/disable Kubernetes Events. ## Brief change log - Added a new config

[GitHub] [flink-connector-rabbitmq] boring-cyborg[bot] commented on pull request #9: [FLINK-31759][rabbitmq] Update some external connectors to use sql_connector_download_table and connector_artifact

2023-04-13 Thread via GitHub
boring-cyborg[bot] commented on PR #9: URL: https://github.com/apache/flink-connector-rabbitmq/pull/9#issuecomment-1507125707 Awesome work, congrats on your first merged pull request! -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink-connector-rabbitmq] reswqa merged pull request #9: [FLINK-31759][rabbitmq] Update some external connectors to use sql_connector_download_table and connector_artifact shortcode

2023-04-13 Thread via GitHub
reswqa merged PR #9: URL: https://github.com/apache/flink-connector-rabbitmq/pull/9 -- 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:

[GitHub] [flink-connector-rabbitmq] reswqa commented on pull request #9: [FLINK-31759][rabbitmq] Update some external connectors to use sql_connector_download_table and connector_artifact shortcode

2023-04-13 Thread via GitHub
reswqa commented on PR #9: URL: https://github.com/apache/flink-connector-rabbitmq/pull/9#issuecomment-1507125295 Thanks @TanYuxin-tyx, merged. -- 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-31757) Optimize Flink un-balanced tasks scheduling

2023-04-13 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711932#comment-17711932 ] Rui Fan commented on FLINK-31757: - Hi [~chesnay] , thanks for your reply. {quote}The obvious solution

[jira] [Commented] (FLINK-31700) MongoDB nightly CI failure

2023-04-13 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711931#comment-17711931 ] Danny Cranmer commented on FLINK-31700: --- CI now passes on main

[GitHub] [flink] flinkbot commented on pull request #22394: [FLINK-31780][component=Runtime/Coordination] Allow users to disable 'Ensemble tracking' feature for ZooKeeper Curator framework

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

[GitHub] [flink-connector-jdbc] boring-cyborg[bot] commented on pull request #38: [FLINK-31759][JDBC] Update some external connectors to use sql_connector_download_table and connector_artifact shortco

2023-04-13 Thread via GitHub
boring-cyborg[bot] commented on PR #38: URL: https://github.com/apache/flink-connector-jdbc/pull/38#issuecomment-1507103599 Awesome work, congrats on your first merged pull request! -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink-connector-jdbc] reswqa merged pull request #38: [FLINK-31759][JDBC] Update some external connectors to use sql_connector_download_table and connector_artifact shortcode

2023-04-13 Thread via GitHub
reswqa merged PR #38: URL: https://github.com/apache/flink-connector-jdbc/pull/38 -- 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:

[jira] [Commented] (FLINK-29398) Utilize Rack Awareness in Flink Consumer

2023-04-13 Thread Jeremy DeGroot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711929#comment-17711929 ] Jeremy DeGroot commented on FLINK-29398: [~chiggi_dev] There is a PR open for it now

[GitHub] [flink-connector-jdbc] reswqa commented on pull request #38: [FLINK-31759][JDBC] Update some external connectors to use sql_connector_download_table and connector_artifact shortcode

2023-04-13 Thread via GitHub
reswqa commented on PR #38: URL: https://github.com/apache/flink-connector-jdbc/pull/38#issuecomment-1507103208 Thanks @TanYuxin-tyx for the review, AZP failed is irrelevant. Merged. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Updated] (FLINK-31780) Allow users to disable "Ensemble tracking" for ZooKeeper

2023-04-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31780: --- Labels: pull-request-available (was: ) > Allow users to disable "Ensemble tracking" for

[GitHub] [flink] JTaky opened a new pull request, #22394: [FLINK-31780][component=Runtime/Coordination] Allow users to disable 'Ensemble tracking' feature for ZooKeeper Curator framework

2023-04-13 Thread via GitHub
JTaky opened a new pull request, #22394: URL: https://github.com/apache/flink/pull/22394 ## What is the purpose of the change Given PR adds a new configuration to disable EnsembleTracking feature for Apache Curator. ## Brief change log - Adds a new

[GitHub] [flink-connector-elasticsearch] reswqa commented on pull request #58: [FLINK-31759][es] Update ElasticSearch connector to use sql_connector_download_table shortcode.

2023-04-13 Thread via GitHub
reswqa commented on PR #58: URL: https://github.com/apache/flink-connector-elasticsearch/pull/58#issuecomment-1507093996 Thanks @TanYuxin-tyx for the review, merged. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink-connector-elasticsearch] reswqa merged pull request #58: [FLINK-31759][es] Update ElasticSearch connector to use sql_connector_download_table shortcode.

2023-04-13 Thread via GitHub
reswqa merged PR #58: URL: https://github.com/apache/flink-connector-elasticsearch/pull/58 -- 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:

[jira] [Created] (FLINK-31798) Add config to enable/disable Kubernetes Events

2023-04-13 Thread Daren Wong (Jira)
Daren Wong created FLINK-31798: -- Summary: Add config to enable/disable Kubernetes Events Key: FLINK-31798 URL: https://issues.apache.org/jira/browse/FLINK-31798 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

2023-04-13 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711925#comment-17711925 ] Chesnay Schepler edited comment on FLINK-31757 at 4/13/23 2:38 PM: ---

[jira] [Commented] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

2023-04-13 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711925#comment-17711925 ] Chesnay Schepler commented on FLINK-31757: -- This scenario can only occur if the user explicitly

  1   2   3   >