[PR] Update use-cases.md [flink-web]

2024-03-07 Thread via GitHub
Milunas opened a new pull request, #723: URL: https://github.com/apache/flink-web/pull/723 Changing expired link to active one -- 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

[PR] [FLINK-32261][table] Add built-in MAP_UNION function. [flink]

2024-03-07 Thread via GitHub
hanyuzheng7 opened a new pull request, #22842: URL: https://github.com/apache/flink/pull/22842 ## What is the purpose of the change This is an implementation of MAP_UNION Returns a map created by merging at least one map. These maps should have a common map type. If there are

Re: [PR] [FLINK-34622][docs] fix typo in execution_mode.md [flink]

2024-03-07 Thread via GitHub
flinkbot commented on PR #24467: URL: https://github.com/apache/flink/pull/24467#issuecomment-1985134591 ## CI report: * 9f8217fb084d6cfe35b301f5d12f363c4e9a84a9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-32261][table] Add built-in MAP_UNION function. [flink]

2024-03-07 Thread via GitHub
hanyuzheng7 commented on PR #22842: URL: https://github.com/apache/flink/pull/22842#issuecomment-1985133263 @snuyanzin by mistake. -- 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 com

[jira] [Updated] (FLINK-34622) Typo of execution_mode configuration name in Chinese document

2024-03-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34622: --- Labels: pull-request-available (was: ) > Typo of execution_mode configuration name in Chine

[PR] [FLINK-34622][docs] fix typo in execution_mode.md [flink]

2024-03-07 Thread via GitHub
yuchen-ecnu opened a new pull request, #24467: URL: https://github.com/apache/flink/pull/24467 ## What is the purpose of the change fix typo in execution_mode.md ## Brief change log - Replace `execute.runtime-mode` with `execution.runtime-mode` in Chinese documents

Re: [PR] [FLINK-32261][table] Add built-in MAP_UNION function. [flink]

2024-03-07 Thread via GitHub
snuyanzin commented on PR #22842: URL: https://github.com/apache/flink/pull/22842#issuecomment-1985127583 @hanyuzheng7 did you close it by mistake or there is a reason? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

[jira] [Updated] (FLINK-34622) Typo of execution_mode configuration name in Chinese document

2024-03-07 Thread Yu Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Chen updated FLINK-34622: Description: !image-2024-03-08-14-46-34-859.png|width=794,height=380! > Typo of execution_mode configurati

[jira] [Updated] (FLINK-34622) Typo of execution_mode configuration name in Chinese document

2024-03-07 Thread Yu Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Chen updated FLINK-34622: Attachment: image-2024-03-08-14-46-34-859.png > Typo of execution_mode configuration name in Chinese docum

[jira] [Created] (FLINK-34622) Typo of execution_mode configuration name in Chinese document

2024-03-07 Thread Yu Chen (Jira)
Yu Chen created FLINK-34622: --- Summary: Typo of execution_mode configuration name in Chinese document Key: FLINK-34622 URL: https://issues.apache.org/jira/browse/FLINK-34622 Project: Flink Issue Ty

[jira] [Commented] (FLINK-34588) FineGrainedSlotManager checks whether resources need to reconcile but doesn't act on the result

2024-03-07 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824616#comment-17824616 ] Weihua Hu commented on FLINK-34588: --- Thanks [~mapohl]  reporting this.  At the first

Re: [PR] [FLINK-34334][state] Add sub-task level RocksDB file count metrics [flink]

2024-03-07 Thread via GitHub
Zakelly commented on code in PR #24322: URL: https://github.com/apache/flink/pull/24322#discussion_r1517170682 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBProperty.java: ## @@ -31,55 +31,86 @@ */ @Internal

Re: [PR] [FLINK-34180][docs] Migrate doc website from ververica to flink [flink-web]

2024-03-07 Thread via GitHub
GOODBOY008 commented on PR #722: URL: https://github.com/apache/flink-web/pull/722#issuecomment-1985001432 @leonardBang @PatrickRen PTAL -- 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 speci

[PR] [FLINK-34180][docs] Migrate doc website from ververica to flink [flink-web]

2024-03-07 Thread via GitHub
GOODBOY008 opened a new pull request, #722: URL: https://github.com/apache/flink-web/pull/722 Add flink cdc document link to flink website. -- 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 spe

Re: [PR] [FLINK-34334][state] Add sub-task level RocksDB file count metrics [flink]

2024-03-07 Thread via GitHub
hejufang commented on code in PR #24322: URL: https://github.com/apache/flink/pull/24322#discussion_r1517121573 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBNativeMetricMonitor.java: ## @@ -114,7 +114,14 @@ priv

[jira] [Commented] (FLINK-31663) Add ARRAY_EXCEPT supported in SQL & Table API

2024-03-07 Thread Jacky Lau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824607#comment-17824607 ] Jacky Lau commented on FLINK-31663: --- hi [~dwysakowicz] [~hanyuzheng] [~luoyuxia] , i f

[jira] [Commented] (FLINK-34519) Refine checkpoint scheduling and canceling logic

2024-03-07 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824599#comment-17824599 ] Hangxiang Yu commented on FLINK-34519: -- Thanks for reporting this. {quote}stopCheck

Re: [PR] [FLINK-32261][table] Add built-in MAP_UNION function. [flink]

2024-03-07 Thread via GitHub
hanyuzheng7 commented on PR #22842: URL: https://github.com/apache/flink/pull/22842#issuecomment-1984944407 @snuyanzin Ci test pass now. -- 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 sp

Re: [PR] [FLINK-32261][table] Add built-in MAP_UNION function. [flink]

2024-03-07 Thread via GitHub
hanyuzheng7 commented on PR #22842: URL: https://github.com/apache/flink/pull/22842#issuecomment-1984943907 > @hanyuzheng7 could you please have at build failure? it seems it is related to the recent changes > > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=5

Re: [PR] [FLINK-32261][table] Add built-in MAP_UNION function. [flink]

2024-03-07 Thread via GitHub
hanyuzheng7 closed pull request #22842: [FLINK-32261][table] Add built-in MAP_UNION function. URL: https://github.com/apache/flink/pull/22842 -- 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 spec

Re: [PR] [hotfix][doc] Update the Kafka DDL example in the hive catalog page to the new parameter style [flink]

2024-03-07 Thread via GitHub
hackergin commented on PR #24409: URL: https://github.com/apache/flink/pull/24409#issuecomment-1984924477 @leonardBang Could you please help review this PR when you have time? Thank you. -- This is an automated message from the Apache Git Service. To respond to the message, please log

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-03-07 Thread via GitHub
spoon-lz commented on PR #24461: URL: https://github.com/apache/flink/pull/24461#issuecomment-1984923835 @Zakelly Please help me take a look at this PR to see if it meets the requirements. -- This is an automated message from the Apache Git Service. To respond to the message, please log o

[jira] [Commented] (FLINK-34156) Move Flink Calcite rules from Scala to Java

2024-03-07 Thread Jacky Lau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824595#comment-17824595 ] Jacky Lau commented on FLINK-34156: --- [~Sergey Nuyanzin]  If the community is short on

[jira] [Commented] (FLINK-34156) Move Flink Calcite rules from Scala to Java

2024-03-07 Thread Jacky Lau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824594#comment-17824594 ] Jacky Lau commented on FLINK-34156: --- [~Sergey Nuyanzin] I agree that these can be set

[jira] [Commented] (FLINK-34558) Add RocksDB key/value size metrics

2024-03-07 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824593#comment-17824593 ] Hangxiang Yu commented on FLINK-34558: -- I think this mertic maybe useful, but since

[jira] [Closed] (FLINK-34616) python dist doesn't clean when open method construct resource

2024-03-07 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-34616. Fix Version/s: 1.19.1 1.18.2 Assignee: Jacky Lau Resolution: Fix

[jira] [Updated] (FLINK-34616) python dist doesn't clean when open method construct resource

2024-03-07 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-34616: - Affects Version/s: 1.18.1 1.19.0 (was: 1.20.0)

Re: [PR] [FLINK-34616][python] Fix python dist dir doesn't clean when open met… [flink]

2024-03-07 Thread via GitHub
HuangXingBo merged PR #24462: URL: https://github.com/apache/flink/pull/24462 -- 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

Re: [PR] Add announcement blog post for Flink 1.19 [flink-web]

2024-03-07 Thread via GitHub
lincoln-lil commented on PR #721: URL: https://github.com/apache/flink-web/pull/721#issuecomment-1984885393 > Not sure if we should also update the following files in this PR: https://github.com/apache/flink-web/blob/asf-site/docs/data/flink.yml https://github.com/apache/flink-web/blob/

[jira] [Closed] (FLINK-34621) Bump com.google.guava:guava from 31.1-jre to 32.0.0-jre in /flink-connector-hbase-base

2024-03-07 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-34621. -- Fix Version/s: hbase-4.0.0 Resolution: Fixed Fixed in apache/flink-connector-hbase:main

Re: [PR] Bump com.google.guava:guava from 31.1-jre to 32.0.0-jre in /flink-connector-hbase-base [flink-connector-hbase]

2024-03-07 Thread via GitHub
MartijnVisser merged PR #43: URL: https://github.com/apache/flink-connector-hbase/pull/43 -- 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-unsubsc

[jira] [Created] (FLINK-34621) Bump com.google.guava:guava from 31.1-jre to 32.0.0-jre in /flink-connector-hbase-base

2024-03-07 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-34621: -- Summary: Bump com.google.guava:guava from 31.1-jre to 32.0.0-jre in /flink-connector-hbase-base Key: FLINK-34621 URL: https://issues.apache.org/jira/browse/FLINK-34621

Re: [PR] Bump org.apache.zookeeper:zookeeper from 3.4.14 to 3.7.2 [flink-connector-hbase]

2024-03-07 Thread via GitHub
dependabot[bot] commented on PR #37: URL: https://github.com/apache/flink-connector-hbase/pull/37#issuecomment-1984354931 OK, I won't notify you again about this release, but will get in touch when a new version is available. If you'd rather skip all updates until the next major or minor v

Re: [PR] Bump org.apache.zookeeper:zookeeper from 3.4.14 to 3.7.2 [flink-connector-hbase]

2024-03-07 Thread via GitHub
MartijnVisser commented on PR #37: URL: https://github.com/apache/flink-connector-hbase/pull/37#issuecomment-1984354885 Closing since HBase only works with Zookeeper 3.4 (per @ferenc-csaky his comment) -- This is an automated message from the Apache Git Service. To respond to the message

Re: [PR] Bump org.apache.zookeeper:zookeeper from 3.4.14 to 3.7.2 [flink-connector-hbase]

2024-03-07 Thread via GitHub
MartijnVisser closed pull request #37: Bump org.apache.zookeeper:zookeeper from 3.4.14 to 3.7.2 URL: https://github.com/apache/flink-connector-hbase/pull/37 -- 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

Re: [PR] [hotfix] [flink-parquet] avro parquet logical type fix [flink]

2024-03-07 Thread via GitHub
AlexRiedler closed pull request #21167: [hotfix] [flink-parquet] avro parquet logical type fix URL: https://github.com/apache/flink/pull/21167 -- 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 spe

Re: [PR] [FLINK-34620][formats][protobuf] add support of recursive schemas to PbToRowTypeUtil [flink]

2024-03-07 Thread via GitHub
wckdman commented on PR #24466: URL: https://github.com/apache/flink/pull/24466#issuecomment-1984332352 @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] [FLINK-32261][table] Add built-in MAP_UNION function. [flink]

2024-03-07 Thread via GitHub
hanyuzheng7 commented on PR #22842: URL: https://github.com/apache/flink/pull/22842#issuecomment-1984099455 @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 commen

Re: [PR] feat: autoscaling decision parallelism improvement [FLINK-34563] [flink-kubernetes-operator]

2024-03-07 Thread via GitHub
Yang-LI-CS commented on PR #787: URL: https://github.com/apache/flink-kubernetes-operator/pull/787#issuecomment-1983999079 Hello @mxm , I have updated my pr : - With necessary adjustments to meet the constraints that render this feature effective. "I would like to us to take a

[jira] [Commented] (FLINK-25544) [JUnit5 Migration] Module: flink-streaming-java

2024-03-07 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824476#comment-17824476 ] Jiabao Sun commented on FLINK-25544: master: 395928901cb99c019d8885d1c39839c33e5ed58

Re: [PR] [FLINK-25544][streaming][JUnit5 Migration] The util,graph,experimental,environment package of module flink-stream-java [flink]

2024-03-07 Thread via GitHub
Jiabao-Sun merged PR #24432: URL: https://github.com/apache/flink/pull/24432 -- 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

[jira] [Closed] (FLINK-34580) Job run via REST erases "pipeline.classpaths" config

2024-03-07 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-34580. -- Resolution: Fixed merged to main d0ce5349fdf1a611518eba20a169c475ee0b46c5 > Job run via REST erases "

[jira] [Assigned] (FLINK-34580) Job run via REST erases "pipeline.classpaths" config

2024-03-07 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-34580: -- Assignee: Ferenc Csaky > Job run via REST erases "pipeline.classpaths" config > -

Re: [PR] [FLINK-34580][rest] Do not erase "pipeline.classpaths" config during REST job deploy [flink]

2024-03-07 Thread via GitHub
gyfora merged PR #24436: URL: https://github.com/apache/flink/pull/24436 -- 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

[PR] [hotfix] Minor autoscaler event and metric improvements [flink-kubernetes-operator]

2024-03-07 Thread via GitHub
gyfora opened a new pull request, #794: URL: https://github.com/apache/flink-kubernetes-operator/pull/794 ## Brief change log - *Set the proper key for ineffective event triggering to avoid spamming the user with events* - *Handle missing aggregated busy metrics gracefully in I

Re: [PR] Add announcement blog post for Flink 1.19 [flink-web]

2024-03-07 Thread via GitHub
rmoff commented on code in PR #721: URL: https://github.com/apache/flink-web/pull/721#discussion_r1516486388 ## docs/content/posts/2024-03-xx-release-1.19.0.md: ## @@ -0,0 +1,466 @@ +--- +authors: +- LincolnLee: + name: "Lincoln Lee" + twitter: lincoln_86xy + +date: "2024-03-0

Re: [PR] Add announcement blog post for Flink 1.19 [flink-web]

2024-03-07 Thread via GitHub
rmoff commented on code in PR #721: URL: https://github.com/apache/flink-web/pull/721#discussion_r1516436624 ## docs/content/posts/2024-03-xx-release-1.19.0.md: ## @@ -0,0 +1,466 @@ +--- +authors: +- LincolnLee: + name: "Lincoln Lee" + twitter: lincoln_86xy + +date: "2024-03-0

[jira] [Updated] (FLINK-34619) Do not wait for scaling completion in UPGRADE state with in-place scaling

2024-03-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34619: --- Labels: pull-request-available (was: ) > Do not wait for scaling completion in UPGRADE stat

Re: [PR] [FLINK-34152] Add an option to scale memory when downscaling [flink-kubernetes-operator]

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

Re: [PR] [FLINK-34152] Add an option to scale memory when downscaling [flink-kubernetes-operator]

2024-03-07 Thread via GitHub
mxm commented on PR #786: URL: https://github.com/apache/flink-kubernetes-operator/pull/786#issuecomment-1983822516 @1996fanrui I'm merging but I'll take any comments from your side that you might have reviewing this later on. -- This is an automated message from the Apache Git Service.

Re: [PR] feat: autoscaling decision parallelism improvement [FLINK-34563] [flink-kubernetes-operator]

2024-03-07 Thread via GitHub
Yang-LI-CS commented on code in PR #787: URL: https://github.com/apache/flink-kubernetes-operator/pull/787#discussion_r1516370446 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingExecutor.java: ## @@ -153,6 +160,52 @@ public boolean scaleResource( r

Re: [PR] [FLINK-32261][table] Add built-in MAP_UNION function. [flink]

2024-03-07 Thread via GitHub
snuyanzin commented on PR #22842: URL: https://github.com/apache/flink/pull/22842#issuecomment-1983757510 @hanyuzheng7 could you please have at build failure? it seems it is related to the recent changes https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=57976&v

Re: [PR] [FLINK-34620] add support of recursive schemas to PbToRowTypeUtil [flink]

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

[jira] [Commented] (FLINK-34620) Process recursive protobuf schemas in PbToRowTypeUtil

2024-03-07 Thread Artem (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824443#comment-17824443 ] Artem commented on FLINK-34620: --- Opened a PR https://github.com/apache/flink/pull/24466 >

[jira] [Updated] (FLINK-34620) Process recursive protobuf schemas in PbToRowTypeUtil

2024-03-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34620: --- Labels: pull-request-available (was: ) > Process recursive protobuf schemas in PbToRowTypeU

[PR] [FLINK-34620] add support of recursive schemas to PbToRowTypeUtil [flink]

2024-03-07 Thread via GitHub
wckdman opened a new pull request, #24466: URL: https://github.com/apache/flink/pull/24466 ## 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 on

[jira] [Updated] (FLINK-34620) Process recursive protobuf schemas in PbToRowTypeUtil

2024-03-07 Thread Artem (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Artem updated FLINK-34620: -- Description: The current version of _PbToRowTypeUtil.generateRowType_ doesn't support recursive protobuf sche

[jira] [Updated] (FLINK-34620) Process recursive protobuf schemas in PbToRowTypeUtil

2024-03-07 Thread Artem (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Artem updated FLINK-34620: -- Description: The current version of _PbToRowTypeUtil.generateRowType_ doesn't support recursive protobuf sche

[jira] [Updated] (FLINK-34620) Process recursive protobuf schemas in PbToRowTypeUtil

2024-03-07 Thread Artem (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Artem updated FLINK-34620: -- Description: The current version of _PbToRowTypeUtil.generateRowType_ doesn't support recursive protobuf sche

[jira] [Updated] (FLINK-34620) Process recursive protobuf schemas in PbToRowTypeUtil

2024-03-07 Thread Artem (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Artem updated FLINK-34620: -- Description: The current version of _PbToRowTypeUtil.generateRowType_ doesn't support recursive protobuf sche

[jira] [Created] (FLINK-34620) Process recursive protobuf schemas in PbToRowTypeUtil

2024-03-07 Thread Artem (Jira)
Artem created FLINK-34620: - Summary: Process recursive protobuf schemas in PbToRowTypeUtil Key: FLINK-34620 URL: https://issues.apache.org/jira/browse/FLINK-34620 Project: Flink Issue Type: Improveme

Re: [PR] use Robert Metzger patch from https://issues.apache.org/jira/browse/F… [flink-kubernetes-operator]

2024-03-07 Thread via GitHub
klam-shop closed pull request #792: use Robert Metzger patch from https://issues.apache.org/jira/browse/F… URL: https://github.com/apache/flink-kubernetes-operator/pull/792 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[PR] use Robert Metzger patch from https://issues.apache.org/jira/browse/F… [flink-kubernetes-operator]

2024-03-07 Thread via GitHub
klam-shop opened a new pull request, #792: URL: https://github.com/apache/flink-kubernetes-operator/pull/792 …LINK-31860 ## What is the purpose of the change *(For example: This pull request adds a new feature to periodically create and maintain savepoints through the `

[jira] [Closed] (FLINK-31663) Add ARRAY_EXCEPT supported in SQL & Table API

2024-03-07 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-31663. Fix Version/s: 1.20.0 Resolution: Fixed Implemented in 2429c296a60bf0a0e8a4acebc04a

Re: [PR] [FLINK-31663][table] Add-ARRAY_EXCEPT-function. [flink]

2024-03-07 Thread via GitHub
dawidwys merged PR #23173: URL: https://github.com/apache/flink/pull/23173 -- 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.apac

Re: [PR] [FLINK-34324][ci] Replaces AWS-based S3 e2e tests with Minio-backed version [flink]

2024-03-07 Thread via GitHub
flinkbot commented on PR #24465: URL: https://github.com/apache/flink/pull/24465#issuecomment-1983574353 ## CI report: * 7a179f5a0cfb8829ca5c75a81360634f4d0f2d84 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-34324][ci] Replaces AWS-based S3 e2e tests with Minio-backed version [flink]

2024-03-07 Thread via GitHub
XComp opened a new pull request, #24465: URL: https://github.com/apache/flink/pull/24465 ## What is the purpose of the change * Fixes error message in test execution * unifies S3-related code in one location * Replaces AWS-backed S3 filesink e2e test with Minio backend ##

Re: [PR] [BP-1.17][FLINK-34324][test] Makes all s3 related operations being declared and called in a single location [flink]

2024-03-07 Thread via GitHub
XComp closed pull request #24269: [BP-1.17][FLINK-34324][test] Makes all s3 related operations being declared and called in a single location URL: https://github.com/apache/flink/pull/24269 -- This is an automated message from the Apache Git Service. To respond to the message, please log on t

Re: [PR] [FLINK-34324][test] Makes all s3 related operations being declared and called in a single location [flink]

2024-03-07 Thread via GitHub
XComp commented on PR #24463: URL: https://github.com/apache/flink/pull/24463#issuecomment-1983532633 I deleted the branch again because it doesn't enable the S3 credentials, of course. :facepalm: Anyway, it's better to replace it with Minio. -- This is an automated message from the Apach

Re: [PR] [FLINK-34324][test] Makes all s3 related operations being declared and called in a single location [flink]

2024-03-07 Thread via GitHub
XComp closed pull request #24463: [FLINK-34324][test] Makes all s3 related operations being declared and called in a single location URL: https://github.com/apache/flink/pull/24463 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Created] (FLINK-34619) Do not wait for scaling completion in UPGRADE state with in-place scaling

2024-03-07 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-34619: -- Summary: Do not wait for scaling completion in UPGRADE state with in-place scaling Key: FLINK-34619 URL: https://issues.apache.org/jira/browse/FLINK-34619 Project: Flink

[jira] [Created] (FLINK-34618) Migrate SplitPythonConditionFromJoinRule

2024-03-07 Thread Yongming Zhang (Jira)
Yongming Zhang created FLINK-34618: -- Summary: Migrate SplitPythonConditionFromJoinRule Key: FLINK-34618 URL: https://issues.apache.org/jira/browse/FLINK-34618 Project: Flink Issue Type: Sub-

[jira] [Comment Edited] (FLINK-32483) RescaleCheckpointManuallyITCase.testCheckpointRescalingOutKeyedState fails on AZP

2024-03-07 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824392#comment-17824392 ] Ryan Skraba edited comment on FLINK-32483 at 3/7/24 12:34 PM:

[jira] [Commented] (FLINK-32483) RescaleCheckpointManuallyITCase.testCheckpointRescalingOutKeyedState fails on AZP

2024-03-07 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824392#comment-17824392 ] Ryan Skraba commented on FLINK-32483: - https://dev.azure.com/apache-flink/apache-fli

Re: [PR] [FLINK-34617][docs] Correct the Javadoc of org.apache.flink.api.common.time.Time [flink]

2024-03-07 Thread via GitHub
flinkbot commented on PR #24464: URL: https://github.com/apache/flink/pull/24464#issuecomment-1983409431 ## CI report: * 1304c1d4fdd7a60fa990fe09f85580080179fd44 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-34484][state] Split 'state.backend.local-recovery' into two options for checkpointing and recovery [flink]

2024-03-07 Thread via GitHub
ljz2051 commented on code in PR #24402: URL: https://github.com/apache/flink/pull/24402#discussion_r1516073138 ## flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java: ## @@ -169,6 +173,26 @@ public class CheckpointingOptions {

Re: [PR] [FLINK-34617][docs] Correct the Javadoc of org.apache.flink.api.common.time.Time [flink]

2024-03-07 Thread via GitHub
yuchen-ecnu commented on PR #24464: URL: https://github.com/apache/flink/pull/24464#issuecomment-1983402438 Thanks for taking this. LGTM. -- 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 speci

[jira] [Updated] (FLINK-34617) Correct the Javadoc of org.apache.flink.api.common.time.Time

2024-03-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34617: --- Labels: pull-request-available (was: ) > Correct the Javadoc of org.apache.flink.api.common

[PR] [FLINK-34617][docs] Correct the Javadoc of org.apache.flink.api.common.time.Time [flink]

2024-03-07 Thread via GitHub
Myasuka opened a new pull request, #24464: URL: https://github.com/apache/flink/pull/24464 ## What is the purpose of the change Correct the Javadoc of `org.apache.flink.api.common.time.Time` ## Brief change log Correct the Javadoc of `org.apache.flink.api.common.time.Time

[jira] [Commented] (FLINK-34156) Move Flink Calcite rules from Scala to Java

2024-03-07 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824390#comment-17824390 ] Sergey Nuyanzin commented on FLINK-34156: - I would suggest put it on hold with t

Re: [PR] Add announcement blog post for Flink 1.19 [flink-web]

2024-03-07 Thread via GitHub
Myasuka commented on code in PR #721: URL: https://github.com/apache/flink-web/pull/721#discussion_r1515992776 ## docs/content/posts/2024-03-xx-release-1.19.0.md: ## @@ -0,0 +1,466 @@ +--- +authors: +- LincolnLee: + name: "Lincoln Lee" + twitter: lincoln_86xy + +date: "2024-03

[jira] [Commented] (FLINK-34156) Move Flink Calcite rules from Scala to Java

2024-03-07 Thread Jacky Lau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824380#comment-17824380 ] Jacky Lau commented on FLINK-34156: --- [~Sergey Nuyanzin]  I've noticed that some Scala

Re: [PR] [FLINK-34533][release] Add release note for version 1.19 [flink]

2024-03-07 Thread via GitHub
1996fanrui commented on code in PR #24394: URL: https://github.com/apache/flink/pull/24394#discussion_r1516026799 ## docs/content.zh/release-notes/flink-1.19.md: ## @@ -0,0 +1,354 @@ +--- +title: "Release Notes - Flink 1.19" +--- + + +# Release notes - Flink 1.19 + +These releas

[jira] [Created] (FLINK-34617) Correct the Javadoc of org.apache.flink.api.common.time.Time

2024-03-07 Thread Yun Tang (Jira)
Yun Tang created FLINK-34617: Summary: Correct the Javadoc of org.apache.flink.api.common.time.Time Key: FLINK-34617 URL: https://issues.apache.org/jira/browse/FLINK-34617 Project: Flink Issue T

Re: [PR] [FLINK-34533][release] Add release note for version 1.19 [flink]

2024-03-07 Thread via GitHub
1996fanrui commented on code in PR #24394: URL: https://github.com/apache/flink/pull/24394#discussion_r1516025744 ## docs/content.zh/release-notes/flink-1.19.md: ## @@ -0,0 +1,354 @@ +--- +title: "Release Notes - Flink 1.19" +--- + + +# Release notes - Flink 1.19 + +These releas

[jira] [Commented] (FLINK-25544) [JUnit5 Migration] Module: flink-streaming-java

2024-03-07 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824373#comment-17824373 ] Jiabao Sun commented on FLINK-25544: master: 6f7b24817a81995e90cfc2cd77efadb41be8cdd

Re: [PR] [FLINK-25544][streaming][JUnit5 Migration] The api package of module flink-stream-java [flink]

2024-03-07 Thread via GitHub
Jiabao-Sun merged PR #24429: URL: https://github.com/apache/flink/pull/24429 -- 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

[jira] [Commented] (FLINK-34529) Projection cannot be pushed down through rank operator.

2024-03-07 Thread yisha zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824368#comment-17824368 ] yisha zhou commented on FLINK-34529: Hi, [~libenchao] , [~lincoln.86xy] , I got some

Re: [PR] [FLINK-34324][test] Makes all s3 related operations being declared and called in a single location [flink]

2024-03-07 Thread via GitHub
flinkbot commented on PR #24463: URL: https://github.com/apache/flink/pull/24463#issuecomment-1983274468 ## CI report: * 2d78f0d7ea556f374bc7f9ba62953045713fe86e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] Flink 34324 [flink]

2024-03-07 Thread via GitHub
XComp opened a new pull request, #24463: URL: https://github.com/apache/flink/pull/24463 ## What is the purpose of the change This PR contains some refactorings of the s3-related tests. I moved the branch from my fork (see related PR #24244) to the main repo to check whether this wou

Re: [PR] [FLINK-34324][test] Makes all s3 related operations being declared and called in a single location [flink]

2024-03-07 Thread via GitHub
XComp commented on PR #24244: URL: https://github.com/apache/flink/pull/24244#issuecomment-1983251954 Closing this one becaue [there are still issues](https://issues.apache.org/jira/browse/FLINK-34324?focusedCommentId=17814891&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabp

Re: [PR] [FLINK-34324][test] Makes all s3 related operations being declared and called in a single location [flink]

2024-03-07 Thread via GitHub
XComp closed pull request #24244: [FLINK-34324][test] Makes all s3 related operations being declared and called in a single location URL: https://github.com/apache/flink/pull/24244 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

Re: [PR] [BP-1.17][FLINK-34324][test] Makes all s3 related operations being declared and called in a single location [flink]

2024-03-07 Thread via GitHub
XComp commented on PR #24269: URL: https://github.com/apache/flink/pull/24269#issuecomment-1983251362 Closing this one becaue [there are still issues](https://issues.apache.org/jira/browse/FLINK-34324?focusedCommentId=17814891&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabp

Re: [PR] [FLINK-34524] Scale down JM deployment to 0 before deletion [flink-kubernetes-operator]

2024-03-07 Thread via GitHub
mxm commented on code in PR #791: URL: https://github.com/apache/flink-kubernetes-operator/pull/791#discussion_r1515949420 ## flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/service/StandaloneFlinkServiceTest.java: ## @@ -90,14 +90,12 @@ public void

Re: [PR] [FLINK-34524] Scale down JM deployment to 0 before deletion [flink-kubernetes-operator]

2024-03-07 Thread via GitHub
mxm commented on PR #791: URL: https://github.com/apache/flink-kubernetes-operator/pull/791#issuecomment-1983245010 Ah, got it! That makes sense. -- 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

Re: [PR] [FLINK-34524] Scale down JM deployment to 0 before deletion [flink-kubernetes-operator]

2024-03-07 Thread via GitHub
gyfora commented on PR #791: URL: https://github.com/apache/flink-kubernetes-operator/pull/791#issuecomment-1983241805 > I wonder, what is the difference between scaling the deployment to zero vs removing it? I would think both issue a SIGINT to the container. If that is the case, there sh

[jira] [Updated] (FLINK-34616) python dist doesn't clean when open method construct resource

2024-03-07 Thread Jacky Lau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jacky Lau updated FLINK-34616: -- Description: our enviroment found lots of python-dist causing disk full. the main resource is constru

[jira] [Updated] (FLINK-34616) python dist doesn't clean when open method construct resource

2024-03-07 Thread Jacky Lau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jacky Lau updated FLINK-34616: -- Description: our enviroment found lots of python-dist causing disk full. the main resource is constru

Re: [PR] [FLINK-34616][python] Fix python dist dir doesn't clean when open met… [flink]

2024-03-07 Thread via GitHub
flinkbot commented on PR #24462: URL: https://github.com/apache/flink/pull/24462#issuecomment-1983180808 ## CI report: * 24d72e6a0ea034d49daeab4a15ea379809c24964 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-34616) python dist doesn't clean when open method construct resource

2024-03-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34616: --- Labels: pull-request-available (was: ) > python dist doesn't clean when open method constru

  1   2   >