Re: [PR] [FLINK-36543] Fix string serialization for OVER windows [flink]

2024-10-16 Thread via GitHub
fhueske commented on code in PR #25526: URL: https://github.com/apache/flink/pull/25526#discussion_r1801586512 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/SqlCallSyntax.java: ## @@ -316,4 +316,23 @@ private String doUnParse(

[jira] [Updated] (FLINK-36543) Table API over windows cannot be string serialized

2024-10-16 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-36543: - Fix Version/s: 2.0.0 2.0-preview > Table API over windows cannot be s

[jira] [Updated] (FLINK-36543) Table API over windows cannot be string serialized

2024-10-16 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-36543: - Fix Version/s: (was: 2.0-preview) > Table API over windows cannot be string serializ

[jira] [Updated] (FLINK-34063) When snapshot compression is enabled, rescaling of a source operator leads to some splits getting lost

2024-10-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34063: -- Fix Version/s: 1.19.0 > When snapshot compression is enabled, rescaling of a source operator l

Re: [PR] [FLINK-36533][runtime] Fix detecting bind failure in case of Netty EPOLL transport [flink]

2024-10-16 Thread via GitHub
flinkbot commented on PR #25531: URL: https://github.com/apache/flink/pull/25531#issuecomment-2416036232 ## CI report: * f111d732ed87ac84c20df34c23944f6a93359f78 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-34466] Lineage interfaces for kafka connector [flink-connector-kafka]

2024-10-16 Thread via GitHub
pawel-big-lebowski commented on code in PR #130: URL: https://github.com/apache/flink-connector-kafka/pull/130#discussion_r1802889898 ## flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/LineageFacetProvider.java: ## @@ -0,0 +1,19 @@ +package org.apac

Re: [PR] [FLINK-34466] Lineage interfaces for kafka connector [flink-connector-kafka]

2024-10-16 Thread via GitHub
pawel-big-lebowski commented on code in PR #130: URL: https://github.com/apache/flink-connector-kafka/pull/130#discussion_r1802892892 ## flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/LineageFacetProvider.java: ## @@ -0,0 +1,19 @@ +package org.apac

Re: [PR] [1.19][FLINK-36511] Prevent StackOverflow in FlinkSecurityManager [flink]

2024-10-16 Thread via GitHub
zentol merged PR #25496: URL: https://github.com/apache/flink/pull/25496 -- 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

Re: [PR] [FLINK-36511] Prevent StackOverflow in FlinkSecurityManager [flink]

2024-10-16 Thread via GitHub
zentol merged PR #25495: URL: https://github.com/apache/flink/pull/25495 -- 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

Re: [PR] [1.20][FLINK-36511] Prevent StackOverflow in FlinkSecurityManager [flink]

2024-10-16 Thread via GitHub
zentol merged PR #25497: URL: https://github.com/apache/flink/pull/25497 -- 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

[jira] [Closed] (FLINK-36511) FlinkSecurityManager#checkExit StackOverFlow if haltOnSystemExit is enabled

2024-10-16 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-36511. Resolution: Fixed master: 52e034f7a8d7f456ce3cc48b63d0e88d5d3210e6 1.20: b59241970d92b32bd

[jira] [Commented] (FLINK-36476) Remove all deprecated methods under public APIs in table modules and adapt the related tests to make them pass

2024-10-16 Thread david radley (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890033#comment-17890033 ] david radley commented on FLINK-36476: -- [~xuyangzhong] somne thoughts on the scope

[PR] FLINK-36551: [OLM] ensure that docker-entry.sh actually replaces the keystore pod volume [flink-kubernetes-operator]

2024-10-16 Thread via GitHub
k-wall opened a new pull request, #903: URL: https://github.com/apache/flink-kubernetes-operator/pull/903 ## Contribution Checklist - Make sure that the pull request corresponds to a [JIRA issue](https://issues.apache.org/jira/projects/FLINK/issues). Exceptions are made for typ

[jira] [Updated] (FLINK-12173) Optimize "SELECT DISTINCT" into Deduplicate with keep first row

2024-10-16 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-12173: - Labels: (was: auto-deprioritized-major auto-deprioritized-minor) > Optimize "SELECT DI

[jira] [Assigned] (FLINK-12173) Optimize "SELECT DISTINCT" into Deduplicate with keep first row

2024-10-16 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-12173: Assignee: Yiyu Tian > Optimize "SELECT DISTINCT" into Deduplicate with keep first

Re: [PR] [FLINK-36543] Fix string serialization for OVER windows [flink]

2024-10-16 Thread via GitHub
dawidwys commented on code in PR #25526: URL: https://github.com/apache/flink/pull/25526#discussion_r1802857026 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/SqlCallSyntax.java: ## @@ -316,4 +316,23 @@ private String doUnParse(

[jira] [Comment Edited] (FLINK-36551) Generated OLM bundle fails to deploy with install strategy failed .. Duplicate value: "keystore"

2024-10-16 Thread Keith Wall (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890024#comment-17890024 ] Keith Wall edited comment on FLINK-36551 at 10/16/24 10:34 AM: ---

Re: [PR] [FLINK-33410] Add a test for UNBOUNDED PRECEDING [flink]

2024-10-16 Thread via GitHub
dawidwys commented on PR #25536: URL: https://github.com/apache/flink/pull/25536#issuecomment-2416436664 Do you mind reviewing this PR @fhueske? I added the test you asked for. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

Re: [PR] [FLINK-36543] Fix string serialization for OVER windows [flink]

2024-10-16 Thread via GitHub
dawidwys commented on code in PR #25526: URL: https://github.com/apache/flink/pull/25526#discussion_r1802865897 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/SqlCallSyntax.java: ## @@ -316,4 +316,23 @@ private String doUnParse(

[jira] [Created] (FLINK-36552) Fix Table API OVER window support in batch mode

2024-10-16 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-36552: Summary: Fix Table API OVER window support in batch mode Key: FLINK-36552 URL: https://issues.apache.org/jira/browse/FLINK-36552 Project: Flink Issue

Re: [PR] [FLINK-33410] Add a test for UNBOUNDED PRECEDING [flink]

2024-10-16 Thread via GitHub
flinkbot commented on PR #25536: URL: https://github.com/apache/flink/pull/25536#issuecomment-2416449626 ## CI report: * dcc95d8c6ccdc2e130aa3d4e56f9d2f4b73344ed UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-36543] Fix string serialization for OVER windows [flink]

2024-10-16 Thread via GitHub
dawidwys commented on code in PR #25526: URL: https://github.com/apache/flink/pull/25526#discussion_r1802563488 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/SqlCallSyntax.java: ## @@ -316,4 +316,23 @@ private String doUnParse(

Re: [PR] [FLINK-36543] Fix string serialization for OVER windows [flink]

2024-10-16 Thread via GitHub
dawidwys commented on code in PR #25526: URL: https://github.com/apache/flink/pull/25526#discussion_r1802563488 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/SqlCallSyntax.java: ## @@ -316,4 +316,23 @@ private String doUnParse(

[PR] [FLINK-36533][runtime] Fix detecting bind failure in case of Netty EPOLL transport [flink]

2024-10-16 Thread via GitHub
ferenc-csaky opened a new pull request, #25531: URL: https://github.com/apache/flink/pull/25531 1.20 backport of https://github.com/apache/flink/pull/25518 -- 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

[PR] [FLINK-36533][runtime] Fix detecting bind failure in case of Netty EPOLL transport [flink]

2024-10-16 Thread via GitHub
ferenc-csaky opened a new pull request, #25532: URL: https://github.com/apache/flink/pull/25532 1.19 backport of https://github.com/apache/flink/pull/25518 -- 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

[jira] [Created] (FLINK-36550) Use ‘Thread.currentThread().getContextClassLoader()’ instead of ‘ClassLoader.getSystemClassLoader()’ when passing ClassLoader

2024-10-16 Thread Jira
原来你是小幸运001 created FLINK-36550: -- Summary: Use ‘Thread.currentThread().getContextClassLoader()’ instead of ‘ClassLoader.getSystemClassLoader()’ when passing ClassLoader Key: FLINK-36550 URL: https://issues.apache.org/

[jira] [Updated] (FLINK-36550) Use ‘Thread.currentThread().getContextClassLoader()’ instead of ‘ClassLoader.getSystemClassLoader()’ when passing ClassLoader

2024-10-16 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-36550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 原来你是小幸运001 updated FLINK-36550: --- Description: ClassLoader. getSystemClassLoad() only loads dependencies under the ClassPath, which c

[jira] [Updated] (FLINK-36551) Generated OLM bundle fails to deploy with install strategy failed .. Duplicate value: "keystore"

2024-10-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36551: --- Labels: pull-request-available (was: ) > Generated OLM bundle fails to deploy with install

[jira] [Comment Edited] (FLINK-36544) Failing to generate working OLM bundle (open manifests/flink-kubernetes-operator.clusterserviceversion.yaml: permission denied)

2024-10-16 Thread Keith Wall (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17889756#comment-17889756 ] Keith Wall edited comment on FLINK-36544 at 10/16/24 9:53 AM:

Re: [PR] [FLINK-36546] Handle batch sources in DataSinkTranslator [flink-cdc]

2024-10-16 Thread via GitHub
lvyanquan commented on PR #3646: URL: https://github.com/apache/flink-cdc/pull/3646#issuecomment-2416311635 I think a test for this is still necessary. We have two bound sources(values, MySQL when setting scan.startup.mode to snapshot), and I don't get the point that you said "the sink n

Re: [PR] [FLINK-35109] Update website data for 3.3.0 [flink-connector-kafka]

2024-10-16 Thread via GitHub
AHeise merged PR #131: URL: https://github.com/apache/flink-connector-kafka/pull/131 -- 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...@

[jira] [Created] (FLINK-36551) Generated OLM bundle fails to deploy with install strategy failed .. Duplicate value: "keystore"

2024-10-16 Thread Keith Wall (Jira)
Keith Wall created FLINK-36551: -- Summary: Generated OLM bundle fails to deploy with install strategy failed .. Duplicate value: "keystore" Key: FLINK-36551 URL: https://issues.apache.org/jira/browse/FLINK-36551

[jira] [Closed] (FLINK-24530) GlobalCommitter might not commit all records on drain

2024-10-16 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-24530. --- Resolution: Fixed > GlobalCommitter might not commit all records on drain >

[jira] [Assigned] (FLINK-36075) Add paginate partition strategy for mongodb connector

2024-10-16 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun reassigned FLINK-36075: -- Assignee: yux (was: Jiabao Sun) > Add paginate partition strategy for mongodb connector > --

Re: [PR] [FLINK-36543] Fix string serialization for OVER windows [flink]

2024-10-16 Thread via GitHub
dawidwys merged PR #25526: URL: https://github.com/apache/flink/pull/25526 -- 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

[jira] [Updated] (FLINK-36075) Add paginate partition strategy for mongodb connector

2024-10-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36075: --- Labels: pull-request-available (was: ) > Add paginate partition strategy for mongodb connec

Re: [PR] feat: Remove deprecated function [flink]

2024-10-16 Thread via GitHub
flinkbot commented on PR #25529: URL: https://github.com/apache/flink/pull/25529#issuecomment-2415902701 ## CI report: * 89e8508b05829270d311a47cebd5ba1f565e4ed6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Comment Edited] (FLINK-33696) FLIP-385: Add OpenTelemetryTraceReporter and OpenTelemetryMetricReporter

2024-10-16 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17889969#comment-17889969 ] Piotr Nowojski edited comment on FLINK-33696 at 10/16/24 7:07 AM:

[jira] [Commented] (FLINK-33696) FLIP-385: Add OpenTelemetryTraceReporter and OpenTelemetryMetricReporter

2024-10-16 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17889969#comment-17889969 ] Piotr Nowojski commented on FLINK-33696: Hi [~mateczagany]. I'm working on the P

Re: [PR] [FLINK-36543] Fix string serialization for OVER windows (#25526) [flink]

2024-10-16 Thread via GitHub
flinkbot commented on PR #25530: URL: https://github.com/apache/flink/pull/25530#issuecomment-2415918204 ## CI report: * 5f50109259562885fca858502bf18f3f477a7a2e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-36551) Generated OLM bundle fails to deploy with install strategy failed .. Duplicate value: "keystore"

2024-10-16 Thread Keith Wall (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890024#comment-17890024 ] Keith Wall commented on FLINK-36551: I believe the intent of [docker-entry.sh#L88|h

[PR] [FLINK-35109] Bump kafka connector version in doc [flink]

2024-10-16 Thread via GitHub
AHeise opened a new pull request, #25533: URL: https://github.com/apache/flink/pull/25533 (no comment) -- 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-mai

[PR] [FLINK-35109] Bump kafka connector version in doc [flink]

2024-10-16 Thread via GitHub
AHeise opened a new pull request, #25534: URL: https://github.com/apache/flink/pull/25534 (no comment) -- 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-mai

Re: [PR] [FLINK-35109] Bump kafka connector version in doc [1.20] [flink]

2024-10-16 Thread via GitHub
AHeise merged PR #25534: URL: https://github.com/apache/flink/pull/25534 -- 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

Re: [PR] [FLINK-35109] Bump kafka connector version in doc [1.19] [flink]

2024-10-16 Thread via GitHub
AHeise merged PR #25533: URL: https://github.com/apache/flink/pull/25533 -- 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

Re: [PR] [FLINK-35109] Bump kafka connector version in doc [flink]

2024-10-16 Thread via GitHub
AHeise merged PR #25535: URL: https://github.com/apache/flink/pull/25535 -- 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] [FLINK-35109] Bump kafka connector version in doc [flink]

2024-10-16 Thread via GitHub
AHeise opened a new pull request, #25535: URL: https://github.com/apache/flink/pull/25535 ## 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

Re: [PR] [BP-1.19][FLINK-36533][runtime] Fix detecting bind failure in case of Netty EPOLL transport [flink]

2024-10-16 Thread via GitHub
flinkbot commented on PR #25532: URL: https://github.com/apache/flink/pull/25532#issuecomment-2416049215 ## CI report: * 641366e7206059552ba894222df9df0a84aa8222 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] feat: Remove deprecated function [flink]

2024-10-16 Thread via GitHub
davidradl commented on PR #25529: URL: https://github.com/apache/flink/pull/25529#issuecomment-2416058016 @ammu20-dev please could you amend the title to follow the usual pattern to include the issue number in square brackets. -- This is an automated message from the Apache Git Service.

Re: [PR] feat: Remove deprecated function [flink]

2024-10-16 Thread via GitHub
davidradl commented on code in PR #25529: URL: https://github.com/apache/flink/pull/25529#discussion_r1802593639 ## flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/api/bridge/java/StreamTableEnvironment.java: ## @@ -122,56 +118,6 @@ static StreamTabl

Re: [PR] [FLINK-36484] [TABLE-SQL] Remove deprecated methods StreamTableEnvironment#registerFunction [flink]

2024-10-16 Thread via GitHub
ammu20-dev commented on code in PR #25529: URL: https://github.com/apache/flink/pull/25529#discussion_r1802607402 ## flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/api/bridge/java/StreamTableEnvironment.java: ## @@ -122,56 +118,6 @@ static StreamTab

[jira] [Updated] (FLINK-36484) Remove deprecated method `StreamTableEnvironment#registerFunction`

2024-10-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36484: --- Labels: pull-request-available (was: ) > Remove deprecated method `StreamTableEnvironment#r

Re: [PR] [FLINK-36543] Fix string serialization for OVER windows [flink]

2024-10-16 Thread via GitHub
fhueske commented on code in PR #25526: URL: https://github.com/apache/flink/pull/25526#discussion_r1802680725 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/SqlCallSyntax.java: ## @@ -316,4 +316,23 @@ private String doUnParse(

Re: [PR] FLINK-36540.[Runtime / Task] Add Support for Hadoop Caller Context when using Flink to operate hdfs. [flink]

2024-10-16 Thread via GitHub
liangyu-1 commented on PR #25516: URL: https://github.com/apache/flink/pull/25516#issuecomment-2415971297 @xintongsong Hi, would you please help me check this issue? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Comment Edited] (FLINK-36545) generate-olm-bundle.sh switches uid/gid when running the OLM tool image

2024-10-16 Thread Keith Wall (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17889781#comment-17889781 ] Keith Wall edited comment on FLINK-36545 at 10/16/24 7:29 AM:

[jira] [Created] (FLINK-36556) Allow to configure starting buffer size when using buffer debloating

2024-10-16 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-36556: -- Summary: Allow to configure starting buffer size when using buffer debloating Key: FLINK-36556 URL: https://issues.apache.org/jira/browse/FLINK-36556 Project: Fli

[PR] FLINK-36500 remove deprecated methods CallExpression [flink]

2024-10-16 Thread via GitHub
jbalchan opened a new pull request, #25537: URL: https://github.com/apache/flink/pull/25537 ## What is the purpose of the change [FLINK-36500] https://issues.apache.org/jira/browse/FLINK-36500 Remove all deprecated methods in CallExpression ## Brief change log Re

[jira] [Commented] (FLINK-36505) Remove all deprecated methods in `ImperativeAggregateFunction`, `ScalarFunction` and `TableFunction`

2024-10-16 Thread Jeyassri Balachandran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890052#comment-17890052 ] Jeyassri Balachandran commented on FLINK-36505: --- I have started looking in

[jira] [Updated] (FLINK-36505) Remove all deprecated methods in `ImperativeAggregateFunction`, `ScalarFunction` and `TableFunction`

2024-10-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36505: --- Labels: pull-request-available (was: ) > Remove all deprecated methods in `ImperativeAggreg

Re: [PR] [FLINK-34466] Lineage interfaces for kafka connector [flink-connector-kafka]

2024-10-16 Thread via GitHub
pawel-big-lebowski commented on code in PR #130: URL: https://github.com/apache/flink-connector-kafka/pull/130#discussion_r1802993588 ## flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilder.java: ## @@ -369,5 +377,23 @@

Re: [PR] [FLINK-33696][metrics] Add OpenTelemetryMetricReporter and OpenTelemetryTraceReporter [flink]

2024-10-16 Thread via GitHub
flinkbot commented on PR #25539: URL: https://github.com/apache/flink/pull/25539#issuecomment-2416698429 ## CI report: * 8c7b919e63eccbe14fb80c7df136b9b8a5493b45 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-34466] Lineage interfaces for kafka connector [flink-connector-kafka]

2024-10-16 Thread via GitHub
AHeise commented on code in PR #130: URL: https://github.com/apache/flink-connector-kafka/pull/130#discussion_r1803045472 ## flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/LineageUtil.java: ## @@ -0,0 +1,156 @@ +/* + * Licensed to the Apache Softwa

[jira] [Updated] (FLINK-36500) Remove all deprecated methods in `CallExpression`

2024-10-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36500: --- Labels: pull-request-available (was: ) > Remove all deprecated methods in `CallExpression`

[jira] [Commented] (FLINK-36500) Remove all deprecated methods in `CallExpression`

2024-10-16 Thread Jeyassri Balachandran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890047#comment-17890047 ] Jeyassri Balachandran commented on FLINK-36500: --- I have started looking in

Re: [PR] [FLINK-34466] Lineage interfaces for kafka connector [flink-connector-kafka]

2024-10-16 Thread via GitHub
pawel-big-lebowski commented on code in PR #130: URL: https://github.com/apache/flink-connector-kafka/pull/130#discussion_r1802998271 ## flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilder.java: ## @@ -369,5 +377,23 @@

Re: [PR] FLINK-36505 remove deprecated methods TableFunction [flink]

2024-10-16 Thread via GitHub
flinkbot commented on PR #25538: URL: https://github.com/apache/flink/pull/25538#issuecomment-2416677634 ## CI report: * bf8d5e0cff634c86fc51e278f677a7c2d4389664 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] FLINK-36505 remove deprecated methods TableFunction [flink]

2024-10-16 Thread via GitHub
jbalchan commented on PR #25538: URL: https://github.com/apache/flink/pull/25538#issuecomment-2416890299 @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-36479 remove deprecated method Table getSchema as [flink]

2024-10-16 Thread via GitHub
flinkbot commented on PR #25540: URL: https://github.com/apache/flink/pull/25540#issuecomment-2416887514 ## CI report: * 2301bb6bfe7e0f5596690386ac7a56170c771077 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] FLINK-36500 remove deprecated methods CallExpression [flink]

2024-10-16 Thread via GitHub
flinkbot commented on PR #25537: URL: https://github.com/apache/flink/pull/25537#issuecomment-2416628988 ## CI report: * 0ad46f9fb5ebd67527652fc7e79d7b2accd4f631 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Created] (FLINK-36554) Support MapState in Operator State

2024-10-16 Thread Jacob Jona Fahlenkamp (Jira)
Jacob Jona Fahlenkamp created FLINK-36554: - Summary: Support MapState in Operator State Key: FLINK-36554 URL: https://issues.apache.org/jira/browse/FLINK-36554 Project: Flink Issue Ty

[PR] FLINK-36479 remove deprecated method Table getSchema as [flink]

2024-10-16 Thread via GitHub
jbalchan opened a new pull request, #25540: URL: https://github.com/apache/flink/pull/25540 ## What is the purpose of the change [FLINK-36479] (https://issues.apache.org/jira/browse/FLINK-36479) Component: [Table SQL / API](https://issues.apache.org/jira/issues/?jql=projec

Re: [PR] [FLINK-34466] Lineage interfaces for kafka connector [flink-connector-kafka]

2024-10-16 Thread via GitHub
pawel-big-lebowski commented on code in PR #130: URL: https://github.com/apache/flink-connector-kafka/pull/130#discussion_r1802987183 ## flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/facets/KafkaPropertiesFacet.java: ## @@ -0,0 +1,56 @@ +/* + * Li

[PR] FLINK-36505 remove deprecated methods TableFunction [flink]

2024-10-16 Thread via GitHub
jbalchan opened a new pull request, #25538: URL: https://github.com/apache/flink/pull/25538 ## What is the purpose of the change [FLINK-36505] https://issues.apache.org/jira/browse/FLINK-36505 Removed all deprecated methods - getResultType and getParameterTypes from TableFunct

Re: [PR] [FLINK-34440][formats][protobuf-confluent] Protobuf confluent dynamic format [flink]

2024-10-16 Thread via GitHub
dmariassy commented on PR #25114: URL: https://github.com/apache/flink/pull/25114#issuecomment-2416769187 > Looks like I failed so far, sorry. Thanks @rmetzger ! We'd love to get this reviewed and merged 🙂 -- This is an automated message from the Apache Git Service. To respond to t

Re: [PR] [FLINK-36543] Fix string serialization for OVER windows (#25526) [flink]

2024-10-16 Thread via GitHub
dawidwys merged PR #25530: URL: https://github.com/apache/flink/pull/25530 -- 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-36379] Improve (Global)Committer with UC disabled [flink]

2024-10-16 Thread via GitHub
fapaul commented on code in PR #25456: URL: https://github.com/apache/flink/pull/25456#discussion_r1803152409 ## flink-runtime/src/main/java/org/apache/flink/streaming/api/connector/sink2/GlobalCommitterOperator.java: ## @@ -47,10 +47,50 @@ import java.util.Collections; import

[jira] [Updated] (FLINK-36379) Improve (Global)Committer with UC disabled

2024-10-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36379: --- Labels: pull-request-available (was: ) > Improve (Global)Committer with UC disabled > -

[PR] [FLINK-33696][metrics] Add OpenTelemetryMetricReporter and OpenTelemetryTraceReporter [flink]

2024-10-16 Thread via GitHub
pnowojski opened a new pull request, #25539: URL: https://github.com/apache/flink/pull/25539 ## What is the purpose of the change This adds support for reporting metrics and traces to OpenTelemetry using gRPC. ## Brief change log Please check individual commit messages.

[jira] [Updated] (FLINK-33696) FLIP-385: Add OpenTelemetryTraceReporter and OpenTelemetryMetricReporter

2024-10-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33696: --- Labels: pull-request-available (was: ) > FLIP-385: Add OpenTelemetryTraceReporter and OpenT

[jira] [Commented] (FLINK-36476) Remove all deprecated methods under public APIs in table modules and adapt the related tests to make them pass

2024-10-16 Thread david radley (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890062#comment-17890062 ] david radley commented on FLINK-36476: -- [~xuyangzhong] I think getting wider points

Re: [PR] FLINK-36479 Remove deprecated method Table getSchema as [flink]

2024-10-16 Thread via GitHub
jbalchan closed pull request #25519: FLINK-36479 Remove deprecated method Table getSchema as URL: https://github.com/apache/flink/pull/25519 -- 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] [Closed] (FLINK-36416) Enable splittable timers for temporal join, temporal sort and windowed aggregation in SQL/Table API

2024-10-16 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-36416. -- Resolution: Fixed merged commit 00a94ad into apache:master > Enable splittable timers for tem

[jira] [Created] (FLINK-36555) Guarantee debloated buffer size grows even with very small alpha

2024-10-16 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-36555: -- Summary: Guarantee debloated buffer size grows even with very small alpha Key: FLINK-36555 URL: https://issues.apache.org/jira/browse/FLINK-36555 Project: Flink

[jira] [Commented] (FLINK-36476) Remove all deprecated methods under public APIs in table modules and adapt the related tests to make them pass

2024-10-16 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890045#comment-17890045 ] xuyang commented on FLINK-36476: Hi, [~davidradl] . > I suggest in addition to the code

Re: [PR] FLINK-36479 Remove deprecated method Table getSchema as [flink]

2024-10-16 Thread via GitHub
jbalchan commented on PR #25519: URL: https://github.com/apache/flink/pull/25519#issuecomment-2416861263 i'm sorry. I was trying to remove my commit which failed the jenkins check. But PR itself got closed. -- This is an automated message from the Apache Git Service. To respond to th

Re: [PR] FLINK-36487 remove deprecated method createTemporaryView StreamTableE… [flink]

2024-10-16 Thread via GitHub
jbalchan commented on PR #25524: URL: https://github.com/apache/flink/pull/25524#issuecomment-2416864438 @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] [Created] (FLINK-36553) Local Global aggregation in Datasream API

2024-10-16 Thread Jacob Jona Fahlenkamp (Jira)
Jacob Jona Fahlenkamp created FLINK-36553: - Summary: Local Global aggregation in Datasream API Key: FLINK-36553 URL: https://issues.apache.org/jira/browse/FLINK-36553 Project: Flink I

[jira] [Updated] (FLINK-36553) Local Global aggregation in Datasream API

2024-10-16 Thread Jacob Jona Fahlenkamp (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jacob Jona Fahlenkamp updated FLINK-36553: -- Description: This would be useful for the same reasons as in Table API. Aggreg

[jira] [Updated] (FLINK-36553) Local Global aggregation in Datasream API

2024-10-16 Thread Jacob Jona Fahlenkamp (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jacob Jona Fahlenkamp updated FLINK-36553: -- Description: This would be useful for the same reasons as in Table API. Aggreg

[jira] [Commented] (FLINK-36535) Optimize the scale down logic based on historical parallelism

2024-10-16 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890332#comment-17890332 ] Rui Fan commented on FLINK-36535: - Thanks [~heigebupahei] for the comment! {quote}that w

Re: [PR] [FLINK-36510][rpc] bump pekko to 1.1.2, remove netty 3 [flink]

2024-10-16 Thread via GitHub
gracegrimwood commented on code in PR #25494: URL: https://github.com/apache/flink/pull/25494#discussion_r1804138258 ## flink-rpc/flink-rpc-akka/pom.xml: ## @@ -94,8 +94,8 @@ under the License. io.netty -

[jira] [Resolved] (FLINK-33201) Memory leak in CachingTopicSelector

2024-10-16 Thread Sunyeop Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sunyeop Lee resolved FLINK-33201. - Resolution: Fixed The PR has been merged and released in v3.3.0 (including v3.3.0-rc1) > Memory

Re: [PR] [BP-1.20][FLINK-36533][runtime] Fix detecting bind failure in case of Netty EPOLL transport [flink]

2024-10-16 Thread via GitHub
ferenc-csaky merged PR #25531: URL: https://github.com/apache/flink/pull/25531 -- 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.

Re: [PR] [FLINK-36533][runtime] Fix detecting bind failure in case of Netty EPOLL transport [flink]

2024-10-16 Thread via GitHub
ferenc-csaky merged PR #25518: URL: https://github.com/apache/flink/pull/25518 -- 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.

Re: [PR] [BP-1.19][FLINK-36533][runtime] Fix detecting bind failure in case of Netty EPOLL transport [flink]

2024-10-16 Thread via GitHub
ferenc-csaky merged PR #25532: URL: https://github.com/apache/flink/pull/25532 -- 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] [Closed] (FLINK-36533) Fix detecting bind failure in case of Netty EPOLL transport

2024-10-16 Thread Ferenc Csaky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ferenc Csaky closed FLINK-36533. Resolution: Fixed [{{8ef273c}}|https://github.com/apache/flink/commit/8ef273c54da8286218f8a46c33a3

Re: [PR] [FLINK-36510][rpc] bump pekko to 1.1.2, remove netty 3 [flink]

2024-10-16 Thread via GitHub
SamBarker commented on code in PR #25494: URL: https://github.com/apache/flink/pull/25494#discussion_r1804065549 ## flink-rpc/flink-rpc-akka/pom.xml: ## @@ -94,8 +94,8 @@ under the License. io.netty -

Re: [PR] [FLINK-35031][runtime] LatencyMarker/RecordAttribute emitting under async execution model [flink]

2024-10-16 Thread via GitHub
yunfengzhou-hub commented on PR #25503: URL: https://github.com/apache/flink/pull/25503#issuecomment-2418271874 Thank for the update. 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 spe

[jira] [Created] (FLINK-36558) MySQL CDC Fails to parse array-typed key index binlog created between 8.0.17 and 8.0.18

2024-10-16 Thread yux (Jira)
yux created FLINK-36558: --- Summary: MySQL CDC Fails to parse array-typed key index binlog created between 8.0.17 and 8.0.18 Key: FLINK-36558 URL: https://issues.apache.org/jira/browse/FLINK-36558 Project: Flink

Re: [PR] Flink Kubernetes Operator 1.10.0 [flink-web]

2024-10-16 Thread via GitHub
1996fanrui commented on code in PR #758: URL: https://github.com/apache/flink-web/pull/758#discussion_r1803996694 ## docs/content/posts/2024-10-30-release-kubernetes-operator-1.10.0.md: ## @@ -0,0 +1,75 @@ +--- +title: "Apache Flink Kubernetes Operator 1.10.0 Release Announceme

  1   2   >