[jira] [Updated] (FLINK-33663) Serialize CallExpressions into SQL

2023-11-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33663: --- Labels: pull-request-available (was: ) > Serialize CallExpressions into SQL > -

Re: [PR] [FLINK-33663] Serialize CallExpressions into SQL [flink]

2023-11-27 Thread via GitHub
flinkbot commented on PR #23811: URL: https://github.com/apache/flink/pull/23811#issuecomment-1827684018 ## CI report: * cde4a0e477fd62d61477f481c28b101084b9c797 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Created] (FLINK-33664) Setup cron build for java 21

2023-11-27 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-33664: --- Summary: Setup cron build for java 21 Key: FLINK-33664 URL: https://issues.apache.org/jira/browse/FLINK-33664 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-33665) Invalid code execution

2023-11-27 Thread Peihui He (Jira)
Peihui He created FLINK-33665: - Summary: Invalid code execution Key: FLINK-33665 URL: https://issues.apache.org/jira/browse/FLINK-33665 Project: Flink Issue Type: Improvement Components

[jira] [Updated] (FLINK-33665) Invalid code execution

2023-11-27 Thread Peihui He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peihui He updated FLINK-33665: -- Description: !image-2023-11-27-20-00-28-715.png! !image-2023-11-27-20-00-59-544.png! As shown in the

[jira] [Commented] (FLINK-33665) Invalid code execution

2023-11-27 Thread Peihui He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790054#comment-17790054 ] Peihui He commented on FLINK-33665: --- If the problem persists, please assign it to me.:

[jira] [Commented] (FLINK-33623) Metaspce leak caused by Flink Netty Client thread

2023-11-27 Thread gabrywu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790058#comment-17790058 ] gabrywu commented on FLINK-33623: - I change value of Flink Netty Client to null, everyth

[PR] [FLINK-33664][ci] Setup cron build for java 21 [flink]

2023-11-27 Thread via GitHub
snuyanzin opened a new pull request, #23812: URL: https://github.com/apache/flink/pull/23812 ## What is the purpose of the change The PR enables cron build for java 21 ## Verifying this change I've also scheduled build with forced `java21-target` for latest available

[jira] [Updated] (FLINK-33664) Setup cron build for java 21

2023-11-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33664: --- Labels: pull-request-available (was: ) > Setup cron build for java 21 > ---

Re: [PR] [FLINK-33664][ci] Setup cron build for java 21 [flink]

2023-11-27 Thread via GitHub
flinkbot commented on PR #23812: URL: https://github.com/apache/flink/pull/23812#issuecomment-1827749970 ## CI report: * 8f96fb6d18ec6168e3b0d86cfbade578a044bdc4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-33638] Support variable-length data generation for variable-length data types [flink]

2023-11-27 Thread via GitHub
liyubin117 commented on PR #23810: URL: https://github.com/apache/flink/pull/23810#issuecomment-1827754298 @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 comment

[jira] [Commented] (FLINK-33623) Metaspce leak caused by Flink Netty Client thread

2023-11-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790066#comment-17790066 ] Martijn Visser commented on FLINK-33623: [~mapohl] WDYT? > Metaspce leak caused

[jira] [Commented] (FLINK-33652) First Steps documentation is having empty page link

2023-11-27 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790075#comment-17790075 ] Wencong Liu commented on FLINK-33652: - Hello [~pranav.sharma], thanks for the carefu

Re: [PR] [FLINK-33664][ci] Setup cron build for java 21 [flink]

2023-11-27 Thread via GitHub
snuyanzin commented on PR #23812: URL: https://github.com/apache/flink/pull/23812#issuecomment-1827795837 @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 comment.

Re: [PR] Using Flink 1.15.0 [flink-statefun]

2023-11-27 Thread via GitHub
MartijnVisser closed pull request #314: Using Flink 1.15.0 URL: https://github.com/apache/flink-statefun/pull/314 -- 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

Re: [PR] [FLINK-33643][runtime] Allow StreamExecutionEnvironment's executeAsync API to use default JobName [flink]

2023-11-27 Thread via GitHub
wangzzu commented on code in PR #23794: URL: https://github.com/apache/flink/pull/23794#discussion_r1406146111 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java: ## @@ -2213,12 +2211,24 @@ public final JobClient exec

Re: [PR] [FLINK-26088][Connectors/ElasticSearch] Add Elasticsearch 8.0 support [flink-connector-elasticsearch]

2023-11-27 Thread via GitHub
MartijnVisser commented on PR #53: URL: https://github.com/apache/flink-connector-elasticsearch/pull/53#issuecomment-1827828796 @mtfelisb Are you still active on this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and us

Re: [PR] [FLINK-26088][Connectors/ElasticSearch] Add Elasticsearch 8.0 support [flink-connector-elasticsearch]

2023-11-27 Thread via GitHub
MartijnVisser commented on PR #74: URL: https://github.com/apache/flink-connector-elasticsearch/pull/74#issuecomment-1827829202 @StefanXiepj Are you still active on this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Commented] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

2023-11-27 Thread Maciej Obuchowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790083#comment-17790083 ] Maciej Obuchowski commented on FLINK-31275: --- >Why a `LineageVertex` have multi

[jira] [Comment Edited] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

2023-11-27 Thread Maciej Obuchowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790083#comment-17790083 ] Maciej Obuchowski edited comment on FLINK-31275 at 11/27/23 1:31 PM: -

Re: [PR] [FLINK-33664][ci] Setup cron build for java 21 [flink]

2023-11-27 Thread via GitHub
snuyanzin closed pull request #23812: [FLINK-33664][ci] Setup cron build for java 21 URL: https://github.com/apache/flink/pull/23812 -- 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 comm

Re: [PR] [FLINK-33664][ci] Setup cron build for java 21 [flink]

2023-11-27 Thread via GitHub
snuyanzin commented on PR #23812: URL: https://github.com/apache/flink/pull/23812#issuecomment-1827844210 looks like non unique job name made flinkbot non restartable... i'm going to close this PR and create another one to work around this issue -- This is an automated message from the

[PR] [FLINK-33664][ci] Setup cron build for java 21 [flink]

2023-11-27 Thread via GitHub
snuyanzin opened a new pull request, #23813: URL: https://github.com/apache/flink/pull/23813 ## What is the purpose of the change The PR enables cron build for java 21 ## Verifying this change I've also scheduled build with forced `java21-target` for latest available mas

Re: [PR] [FLINK-33664][ci] Setup cron build for java 21 [flink]

2023-11-27 Thread via GitHub
flinkbot commented on PR #23813: URL: https://github.com/apache/flink/pull/23813#issuecomment-1827862097 ## CI report: * cd75327df0332f39e4a5fe816959acb002658835 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-33587][docs] Tidy up docs around JDBC [flink]

2023-11-27 Thread via GitHub
rmoff commented on PR #23743: URL: https://github.com/apache/flink/pull/23743#issuecomment-1827889659 @alpinegizmo @snuyanzin any more thoughts on this? thanks :) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

Re: [PR] Support Flink 1.17.1 [flink-statefun]

2023-11-27 Thread via GitHub
MartijnVisser commented on PR #332: URL: https://github.com/apache/flink-statefun/pull/332#issuecomment-1827902004 @gfmio For context, I've made https://github.com/MartijnVisser/flink-statefun/pull/3 which would probably be sufficient -- This is an automated message from the Apache Git S

Re: [PR] FLINK-33600][table] print the query time cost for batch query in cli [flink]

2023-11-27 Thread via GitHub
JingGe commented on PR #23809: URL: https://github.com/apache/flink/pull/23809#issuecomment-1827902974 @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 comment. T

Re: [PR] [FLINK-33618][BuildSystem / Shaded] Upgrade swagger to 2.2.19 [flink-shaded]

2023-11-27 Thread via GitHub
snuyanzin merged PR #130: URL: https://github.com/apache/flink-shaded/pull/130 -- 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...@flink.

[jira] [Resolved] (FLINK-33618) Upgrade swagger for flink-shaded to 2.2.19

2023-11-27 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-33618. - Fix Version/s: shaded-18.0 Resolution: Fixed > Upgrade swagger for flink-shaded t

Re: [PR] FLINK-33600][table] print the query time cost for batch query in cli [flink]

2023-11-27 Thread via GitHub
JingGe commented on PR #23809: URL: https://github.com/apache/flink/pull/23809#issuecomment-1827956246 @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 comment. T

[jira] [Closed] (FLINK-33340) Bump Jackson to 2.15.3

2023-11-27 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin closed FLINK-33340. --- > Bump Jackson to 2.15.3 > -- > > Key: FLINK-33340 >

[jira] [Closed] (FLINK-33330) Bump zookeeper to address CVE-2023-44981

2023-11-27 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-0?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin closed FLINK-0. --- > Bump zookeeper to address CVE-2023-44981 > - > >

[jira] [Closed] (FLINK-33618) Upgrade swagger for flink-shaded to 2.2.19

2023-11-27 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin closed FLINK-33618. --- > Upgrade swagger for flink-shaded to 2.2.19 > -- > >

[jira] [Updated] (FLINK-33330) Bump zookeeper to address CVE-2023-44981

2023-11-27 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-0?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-0: Component/s: BuildSystem / Shaded > Bump zookeeper to address CVE-2023-44981 > --

[jira] [Updated] (FLINK-33340) Bump Jackson to 2.15.3

2023-11-27 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-33340: Component/s: BuildSystem / Shaded > Bump Jackson to 2.15.3 > -- > >

[jira] [Closed] (FLINK-33617) Upgrade tcnative for flink-shaded

2023-11-27 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin closed FLINK-33617. --- > Upgrade tcnative for flink-shaded > - > > Key:

Re: [PR] [FLINK-33617][BuildSystem / Shaded] Upgrade netty-tcnative to 2.0.62.Final [flink-shaded]

2023-11-27 Thread via GitHub
snuyanzin merged PR #129: URL: https://github.com/apache/flink-shaded/pull/129 -- 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...@flink.

[jira] [Resolved] (FLINK-33617) Upgrade tcnative for flink-shaded

2023-11-27 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-33617. - Fix Version/s: shaded-18.0 Resolution: Fixed > Upgrade tcnative for flink-shaded

[jira] [Commented] (FLINK-33617) Upgrade tcnative for flink-shaded

2023-11-27 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790103#comment-17790103 ] Sergey Nuyanzin commented on FLINK-33617: - Merged to master as [a192a0d1b4fa295

Re: [PR] [FLINK-33587][docs] Tidy up docs around JDBC [flink]

2023-11-27 Thread via GitHub
alpinegizmo merged PR #23743: URL: https://github.com/apache/flink/pull/23743 -- 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...@flink.a

[PR] Add GPG key for 1.16.3 release [flink-docker]

2023-11-27 Thread via GitHub
1996fanrui opened a new pull request, #164: URL: https://github.com/apache/flink-docker/pull/164 GPG key can be found from 1.16.3 vote mail and KEYS[2] [1] https://lists.apache.org/thread/dxfmt3v5n0xv5r9tjl30ob5d7y5t7pw3 [2] https://dist.apache.org/repos/dist/release/flink/KEYS

Re: [PR] [FLINK-26782] Remove PlannerExpression and related [flink]

2023-11-27 Thread via GitHub
jnh5y commented on code in PR #23761: URL: https://github.com/apache/flink/pull/23761#discussion_r1406286431 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/LegacyUserDefinedFunctionInference.java: ## @@ -0,0 +1,529 @@ +/* + * Licensed to the Apa

Re: [PR] [FLINK-26782] Remove PlannerExpression and related [flink]

2023-11-27 Thread via GitHub
jnh5y commented on code in PR #23761: URL: https://github.com/apache/flink/pull/23761#discussion_r1406291625 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/LegacyUserDefinedFunctionInference.java: ## @@ -0,0 +1,529 @@ +/* + * Licensed to the Apa

Re: [PR] [FLINK-26782] Remove PlannerExpression and related [flink]

2023-11-27 Thread via GitHub
jnh5y commented on code in PR #23761: URL: https://github.com/apache/flink/pull/23761#discussion_r1406305482 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/LegacyUserDefinedFunctionInference.java: ## @@ -0,0 +1,529 @@ +/* + * Licensed to the Apa

[PR] Update Dockerfiles for 1.16.3 release [flink-docker]

2023-11-27 Thread via GitHub
1996fanrui opened a new pull request, #165: URL: https://github.com/apache/flink-docker/pull/165 GPG key(`B2D64016B940A7E0B9B72E0D7D0528B28037D8BC`) can be found from 1.16.3 vote mail and KEYS[2]. [1] https://lists.apache.org/thread/dxfmt3v5n0xv5r9tjl30ob5d7y5t7pw3 [2] https://dist

Re: [PR] [FLINK-26782] Remove PlannerExpression and related [flink]

2023-11-27 Thread via GitHub
jnh5y commented on code in PR #23761: URL: https://github.com/apache/flink/pull/23761#discussion_r1406314626 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/LegacyUserDefinedFunctionInference.java: ## @@ -0,0 +1,529 @@ +/* + * Licensed to the Apa

Re: [PR] [FLINK-26782] Remove PlannerExpression and related [flink]

2023-11-27 Thread via GitHub
jnh5y commented on code in PR #23761: URL: https://github.com/apache/flink/pull/23761#discussion_r1406316719 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/LegacyUserDefinedFunctionInference.java: ## @@ -0,0 +1,529 @@ +/* + * Licensed to the Apa

[jira] [Created] (FLINK-33666) MergeTableLikeUtil uses different constraint name than Schema

2023-11-27 Thread Timo Walther (Jira)
Timo Walther created FLINK-33666: Summary: MergeTableLikeUtil uses different constraint name than Schema Key: FLINK-33666 URL: https://issues.apache.org/jira/browse/FLINK-33666 Project: Flink

[jira] [Updated] (FLINK-33666) MergeTableLikeUtil uses different constraint name than Schema

2023-11-27 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-33666: - Affects Version/s: 1.18.0 > MergeTableLikeUtil uses different constraint name than Schema >

[jira] [Updated] (FLINK-33652) First Steps documentation is having empty page link

2023-11-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-33652: --- Component/s: Documentation > First Steps documentation is having empty page link > -

[jira] [Commented] (FLINK-33635) Some connectors can not compile in 1.19-SNAPSHOT

2023-11-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790133#comment-17790133 ] Martijn Visser commented on FLINK-33635: One note from my end: I think it's not

Re: [PR] [FLINK-32353] [hotfix] DO NOT MERGE: build against new Flink version [flink-connector-cassandra]

2023-11-27 Thread via GitHub
echauchot commented on PR #21: URL: https://github.com/apache/flink-connector-cassandra/pull/21#issuecomment-1828063833 To pass, it requires to release flink-connector-parent:1.0.1 with the ability to skip archunit tests (for flink 1.17.1) -- This is an automated message from the Apache

[jira] [Comment Edited] (FLINK-33635) Some connectors can not compile in 1.19-SNAPSHOT

2023-11-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790133#comment-17790133 ] Martijn Visser edited comment on FLINK-33635 at 11/27/23 3:32 PM:

[jira] [Comment Edited] (FLINK-33443) Make the test "testWriteComplexType" stable

2023-11-27 Thread huiyang chi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789859#comment-17789859 ] huiyang chi edited comment on FLINK-33443 at 11/27/23 3:35 PM: ---

[jira] [Updated] (FLINK-33443) Make the test "testWriteComplexType" stable

2023-11-27 Thread huiyang chi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huiyang chi updated FLINK-33443: Attachment: image-2023-11-27-09-36-03-081.png > Make the test "testWriteComplexType" stable >

[jira] [Commented] (FLINK-33443) Make the test "testWriteComplexType" stable

2023-11-27 Thread huiyang chi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790136#comment-17790136 ] huiyang chi commented on FLINK-33443: - Oh as this example: !image-2023-11-27-09-3

[jira] [Commented] (FLINK-33443) Make the test "testWriteComplexType" stable

2023-11-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790146#comment-17790146 ] Martijn Visser commented on FLINK-33443: [~hannahchi] I feel like you're not act

[jira] [Commented] (FLINK-33621) Table Store with PyFlink

2023-11-27 Thread Mehmet Aktas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790147#comment-17790147 ] Mehmet Aktas commented on FLINK-33621: -- Hi [~lzljs3620320], Thank you for your com

[PR] Update Dockerfiles for 1.17.2 release [flink-docker]

2023-11-27 Thread via GitHub
Myasuka opened a new pull request, #166: URL: https://github.com/apache/flink-docker/pull/166 The GPG key `2E0E1AB5D39D55E608071FB9F795C02A4D2482B3` can by found [here](https://dist.apache.org/repos/dist/release/flink/KEYS) with `Yun Tang` singed. -- This is an automated message from th

[PR] Add GPG key for 1.17.2 release [flink-docker]

2023-11-27 Thread via GitHub
Myasuka opened a new pull request, #167: URL: https://github.com/apache/flink-docker/pull/167 The GPG key 2E0E1AB5D39D55E608071FB9F795C02A4D2482B3 can by found [here](https://dist.apache.org/repos/dist/release/flink/KEYS) with Yun Tang singed. -- This is an automated message from the Apa

[jira] (FLINK-33443) Make the test "testWriteComplexType" stable

2023-11-27 Thread huiyang chi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33443 ] huiyang chi deleted comment on FLINK-33443: - was (Author: JIRAUSER303032): Oh as this example: !image-2023-11-27-09-36-03-081.png!   The direct producer might be the just simple change o

[jira] [Updated] (FLINK-33443) Make the test "testWriteComplexType" stable

2023-11-27 Thread huiyang chi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huiyang chi updated FLINK-33443: Attachment: (was: image-2023-11-27-09-36-03-081.png) > Make the test "testWriteComplexType" st

[jira] [Commented] (FLINK-33443) Make the test "testWriteComplexType" stable

2023-11-27 Thread huiyang chi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790153#comment-17790153 ] huiyang chi commented on FLINK-33443: - Okay! have a good day > Make the test "testW

[jira] [Comment Edited] (FLINK-33443) Make the test "testWriteComplexType" stable

2023-11-27 Thread huiyang chi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790153#comment-17790153 ] huiyang chi edited comment on FLINK-33443 at 11/27/23 4:03 PM: ---

Re: [PR] [FLINK-33664][ci] Setup cron build for java 21 [flink]

2023-11-27 Thread via GitHub
snuyanzin commented on PR #23813: URL: https://github.com/apache/flink/pull/23813#issuecomment-1828227753 @zentol , @XComp this is about enabling java 21 in cron builds since you 've participated in similar activity for java 17 could you please have a look here ? -- This is an automate

Re: [PR] [FLINK-33470] Implement restore tests for Join node [flink]

2023-11-27 Thread via GitHub
jnh5y commented on code in PR #23680: URL: https://github.com/apache/flink/pull/23680#discussion_r1406603182 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/JoinTestPrograms.java: ## @@ -0,0 +1,272 @@ +/* + * Licensed to

Re: [PR] [FLINK-33470] Implement restore tests for Join node [flink]

2023-11-27 Thread via GitHub
jnh5y commented on code in PR #23680: URL: https://github.com/apache/flink/pull/23680#discussion_r1406603980 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/JoinTestPrograms.java: ## @@ -0,0 +1,272 @@ +/* + * Licensed to

Re: [PR] [FLINK-33470] Implement restore tests for Join node [flink]

2023-11-27 Thread via GitHub
jnh5y commented on code in PR #23680: URL: https://github.com/apache/flink/pull/23680#discussion_r1406605453 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/RestoreTestBase.java: ## @@ -224,7 +242,9 @@ void testRestore(Ta

Re: [PR] [FLINK-33470] Implement restore tests for Join node [flink]

2023-11-27 Thread via GitHub
jnh5y commented on code in PR #23680: URL: https://github.com/apache/flink/pull/23680#discussion_r1406604611 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/RestoreTestBase.java: ## @@ -181,12 +186,25 @@ public void gener

Re: [PR] [FLINK-33470] Implement restore tests for Join node [flink]

2023-11-27 Thread via GitHub
jnh5y commented on code in PR #23680: URL: https://github.com/apache/flink/pull/23680#discussion_r1406606039 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/factories/TestValuesTableFactory.java: ## @@ -280,6 +280,15 @@ public static void register

Re: [PR] [FLINK-33470] Implement restore tests for Join node [flink]

2023-11-27 Thread via GitHub
jnh5y commented on code in PR #23680: URL: https://github.com/apache/flink/pull/23680#discussion_r1406606618 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/JoinTestPrograms.java: ## @@ -0,0 +1,409 @@ +/* + * Licensed to

Re: [PR] [FLINK-32986][test] Fix createTemporaryFunction type inference error [flink]

2023-11-27 Thread via GitHub
jnh5y commented on PR #23586: URL: https://github.com/apache/flink/pull/23586#issuecomment-1828429647 @jeyhunkarimov Thanks for contributing to Flink! Can you sort out the conflict that has happened? @lincoln-lil may be the best person to review this PR. -- This is an automated

[PR] [FLINK-33647] Implement restore tests for LookupJoin node [flink]

2023-11-27 Thread via GitHub
bvarghese1 opened a new pull request, #23814: URL: https://github.com/apache/flink/pull/23814 ## What is the purpose of the change Implement restore tests for LookupJoin node ## Verifying this change This change added tests and can be verified as follows:

[jira] [Updated] (FLINK-33647) Implement restore tests for LookupJoin node

2023-11-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33647: --- Labels: pull-request-available (was: ) > Implement restore tests for LookupJoin node >

Re: [PR] [FLINK-33647] Implement restore tests for LookupJoin node [flink]

2023-11-27 Thread via GitHub
flinkbot commented on PR #23814: URL: https://github.com/apache/flink/pull/23814#issuecomment-1828441266 ## CI report: * 40058dbde8aa6676a411809110590296bd40a47c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

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

2023-11-27 Thread via GitHub
jnh5y commented on code in PR #23612: URL: https://github.com/apache/flink/pull/23612#discussion_r1406627733 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ShowDatabasesOperation.java: ## @@ -20,26 +20,108 @@ import org.apache.flink.annota

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

2023-11-27 Thread via GitHub
jnh5y commented on code in PR #23612: URL: https://github.com/apache/flink/pull/23612#discussion_r1406630035 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ShowDatabasesOperation.java: ## @@ -20,26 +20,108 @@ import org.apache.flink.annota

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

2023-11-27 Thread via GitHub
jnh5y commented on code in PR #23612: URL: https://github.com/apache/flink/pull/23612#discussion_r1406631017 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/SqlShowDatabasesConverter.java: ## @@ -0,0 +1,58 @@ +/* + * Licensed

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

2023-11-27 Thread via GitHub
jnh5y commented on code in PR #23612: URL: https://github.com/apache/flink/pull/23612#discussion_r1406632513 ## flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/dql/SqlShowDatabases.java: ## @@ -29,14 +31,55 @@ import java.util.Collections; import java.ut

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

2023-11-27 Thread via GitHub
jnh5y commented on PR #23612: URL: https://github.com/apache/flink/pull/23612#issuecomment-1828465094 This is looking pretty good. Since implementing FLIP-297 is assigned to @chucheng92, we should get his input as well! @jeyhunkarimov have you signed up for the Flink JIRA? You may n

Re: [PR] [FLINK-33470] Implement restore tests for Join node [flink]

2023-11-27 Thread via GitHub
jnh5y commented on PR #23680: URL: https://github.com/apache/flink/pull/23680#issuecomment-1828467648 @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 comment. To

[jira] [Created] (FLINK-33667) Implement restore tests for MatchRecognize node

2023-11-27 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-33667: -- Summary: Implement restore tests for MatchRecognize node Key: FLINK-33667 URL: https://issues.apache.org/jira/browse/FLINK-33667 Project: Flink Issue Type: Sub-t

[jira] [Updated] (FLINK-33466) Bounded Kafka source never finishes after restore from savepoint

2023-11-27 Thread Jonas Weile (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonas Weile updated FLINK-33466: Component/s: Connectors / Kafka > Bounded Kafka source never finishes after restore from savepoint

Re: [PR] [FLINK-30400][build] Stop bundling flink-connector-base [flink-connector-pulsar]

2023-11-27 Thread via GitHub
ruanhang1993 commented on PR #61: URL: https://github.com/apache/flink-connector-pulsar/pull/61#issuecomment-1828957321 @leonardBang Thanks for review. I have rebased the main branch. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

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

2023-11-27 Thread via GitHub
chucheng92 commented on PR #23612: URL: https://github.com/apache/flink/pull/23612#issuecomment-1828958938 > This is looking pretty good. Since implementing FLIP-297 is assigned to @chucheng92, we should get his input as well! > > @jeyhunkarimov have you signed up for the Flink JIRA?

Re: [PR] [FLINK-33643][runtime] Allow StreamExecutionEnvironment's executeAsync API to use default JobName [flink]

2023-11-27 Thread via GitHub
huwh merged PR #23794: URL: https://github.com/apache/flink/pull/23794 -- 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...@flink.apache.o

[jira] [Created] (FLINK-33668) Decoupling Shuffle network memory and job topology

2023-11-27 Thread Jiang Xin (Jira)
Jiang Xin created FLINK-33668: - Summary: Decoupling Shuffle network memory and job topology Key: FLINK-33668 URL: https://issues.apache.org/jira/browse/FLINK-33668 Project: Flink Issue Type: Impr

[jira] [Resolved] (FLINK-33643) Allow StreamExecutionEnvironment's executeAsync API to use default JobName

2023-11-27 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu resolved FLINK-33643. --- Fix Version/s: 1.19.0 Resolution: Fixed resolved in master: 220287539854c8f32f9d85541026f2b01

[jira] [Updated] (FLINK-33668) Decoupling Shuffle network memory and job topology

2023-11-27 Thread Jiang Xin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiang Xin updated FLINK-33668: -- Description: With FLINK-30469  and FLINK-31643, we have decoupled the shuffle network memory and the

Re: [PR] FLINK-33600][table] print the query time cost for batch query in cli [flink]

2023-11-27 Thread via GitHub
fsk119 commented on code in PR #23809: URL: https://github.com/apache/flink/pull/23809#discussion_r1406993946 ## flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliTableauResultView.java: ## @@ -128,8 +128,13 @@ private void printBatchResults(AtomicI

[jira] [Commented] (FLINK-33597) Can not use a nested column for a join condition

2023-11-27 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790358#comment-17790358 ] lincoln lee commented on FLINK-33597: - [~twalthr] IIUC, [FLINK-31830|https://issues

[jira] [Commented] (FLINK-27681) Improve the availability of Flink when the RocksDB file is corrupted.

2023-11-27 Thread Yue Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790359#comment-17790359 ] Yue Ma commented on FLINK-27681:   {quote}Fail job directly is fine for me, but I guess

Re: [PR] Update Dockerfiles for 1.17.2 release [flink-docker]

2023-11-27 Thread via GitHub
Myasuka merged PR #166: URL: https://github.com/apache/flink-docker/pull/166 -- 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...@flink.ap

Re: [PR] Add GPG key for 1.17.2 release [flink-docker]

2023-11-27 Thread via GitHub
Myasuka merged PR #167: URL: https://github.com/apache/flink-docker/pull/167 -- 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...@flink.ap

Re: [PR] [FLINK-31339][tests] Fix unstable tests of flink-end-to-end-tests-sql module [flink]

2023-11-27 Thread via GitHub
leonardBang commented on PR #23507: URL: https://github.com/apache/flink/pull/23507#issuecomment-1829154493 Thanks @Jiabao-Sun and @ruanhang1993 for the contribution , could you change the PR description? IIUC, it has been outdated. -- This is an automated message from the Apache Git Serv

Re: [PR] [FLINK-31339][tests] Fix unstable tests of flink-end-to-end-tests-sql module [flink]

2023-11-27 Thread via GitHub
Jiabao-Sun commented on PR #23507: URL: https://github.com/apache/flink/pull/23507#issuecomment-1829182205 > Thanks @Jiabao-Sun and @ruanhang1993 for the contribution , could you change the PR description? IIUC, it has been outdated. Thanks @leonardBang and @ruanhang1993 for the revie

Re: [PR] [FLINK-33581][core] Deprecate configuration getters/setters that return/set complex Java objects. [flink]

2023-11-27 Thread via GitHub
zhuzhurk closed pull request #23758: [FLINK-33581][core] Deprecate configuration getters/setters that return/set complex Java objects. URL: https://github.com/apache/flink/pull/23758 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[jira] [Closed] (FLINK-33581) FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects

2023-11-27 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-33581. --- Fix Version/s: 1.19.0 Resolution: Done Done via 0e0099b4eb1285929fec02326f661cba899eedcd 139db3f4bc7f

[jira] [Updated] (FLINK-33581) FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects

2023-11-27 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-33581: -- Description: Deprecate the non-ConfigOption objects in the StreamExecutionEnvironment, CheckpointConfi

Re: [PR] [FLINK-26010] Develop archunit test for filesystem test code [flink]

2023-11-27 Thread via GitHub
PatrickRen commented on code in PR #23798: URL: https://github.com/apache/flink/pull/23798#discussion_r1407290209 ## flink-filesystems/flink-azure-fs-hadoop/pom.xml: ## @@ -47,6 +47,14 @@ under the License. provided + Re

<    1   2   3   >