Re: [PR] corrected released version in the release doc. [flink-web]

2025-03-19 Thread via GitHub
sn-12-3 commented on PR #778: URL: https://github.com/apache/flink-web/pull/778#issuecomment-2739345748 @gyfora , Gentle reminder -- 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-36659] Bump to 2.0-preview1. [flink-connector-jdbc]

2025-03-19 Thread via GitHub
ruanhang1993 commented on code in PR #153: URL: https://github.com/apache/flink-connector-jdbc/pull/153#discussion_r2004869583 ## flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/JdbcSink.java: ## @@ -74,14 +79,26 @@ public static Jd

[jira] [Assigned] (FLINK-37519) Add clearer logs when fail to write to YAML DataSink.

2025-03-19 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37519: -- Assignee: Yanquan Lv > Add clearer logs when fail to write to YAML DataSink. > --

[jira] [Updated] (FLINK-37516) Whether to only synchronize the structure of the table.

2025-03-19 Thread vertern (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vertern updated FLINK-37516: Description: I think a feature should be provided:'Whether to only synchronize the structure of the table

[PR] FLINK-33634 [flink-kubernetes-operator]

2025-03-19 Thread via GitHub
lajith2006 opened a new pull request, #957: URL: https://github.com/apache/flink-kubernetes-operator/pull/957 **(The sections below can be removed for hotfixes of typos)** --> ## What is the purpose of the change This PR address the [FLIP](https://cwiki.apache.org/confluence

[jira] [Updated] (FLINK-34603) Migrate BatchPhysicalBoundedStreamScanRule

2025-03-19 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-34603: --- Affects Version/s: 2.1.0 (was: 1.20.0) > Migrate BatchPhysicalBoundedStre

[jira] [Created] (FLINK-37519) Add clearer logs when fail to write to YAML DataSink.

2025-03-19 Thread Yanquan Lv (Jira)
Yanquan Lv created FLINK-37519: -- Summary: Add clearer logs when fail to write to YAML DataSink. Key: FLINK-37519 URL: https://issues.apache.org/jira/browse/FLINK-37519 Project: Flink Issue Type:

Re: [PR] [FLINK-37512] Fix the OOM for SlidingEventTimeWindows [flink]

2025-03-19 Thread via GitHub
beliefer commented on code in PR #26321: URL: https://github.com/apache/flink/pull/26321#discussion_r2004741073 ## flink-runtime/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingEventTimeWindows.java: ## @@ -59,6 +59,11 @@ protected SlidingEventTimeWindows

[jira] [Created] (FLINK-37518) Optimize number of files created by flink history server

2025-03-19 Thread Biao Geng (Jira)
Biao Geng created FLINK-37518: - Summary: Optimize number of files created by flink history server Key: FLINK-37518 URL: https://issues.apache.org/jira/browse/FLINK-37518 Project: Flink Issue Type

Re: [PR] [code clean] clean unuse code for schema operator&coordinator. [flink-cdc]

2025-03-19 Thread via GitHub
leonardBang merged PR #3958: URL: https://github.com/apache/flink-cdc/pull/3958 -- 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] [Updated] (FLINK-37517) Bump flink 2.0 for elasticsearch connector

2025-03-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37517: --- Labels: pull-request-available (was: ) > Bump flink 2.0 for elasticsearch connector > -

Re: [PR] [FLINK-37517][[Connectors/Elasticsearch] Bump flink to 2.0.0 [flink-connector-elasticsearch]

2025-03-19 Thread via GitHub
reswqa commented on PR #118: URL: https://github.com/apache/flink-connector-elasticsearch/pull/118#issuecomment-2739031224 Thanks for the review, updated. -- 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

Re: [PR] [MINOR] Remove unnecessary InternalPriorityQueue [flink]

2025-03-19 Thread via GitHub
beliefer commented on PR #26315: URL: https://github.com/apache/flink/pull/26315#issuecomment-2739019036 > @beliefer I have approved this - nit: please could you change the title so it starts with [hotfix] in line with the dev process. Thanks Thank you for your reminder. -- This is

Re: [PR] [FLINK-37443] Add returns() method to DataStream V2 API for specifying output types with lambda expressions [flink]

2025-03-19 Thread via GitHub
codenohup commented on code in PR #26284: URL: https://github.com/apache/flink/pull/26284#discussion_r2004740218 ## flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/dsv2/wordcount/WordCountUsingLambda.java: ## @@ -0,0 +1,265 @@ +/* + * Li

Re: [PR] [FLINK-37443] Add returns() method to DataStream V2 API for specifying output types with lambda expressions [flink]

2025-03-19 Thread via GitHub
codenohup commented on code in PR #26284: URL: https://github.com/apache/flink/pull/26284#discussion_r2004739392 ## flink-datastream-api/src/main/java/org/apache/flink/datastream/api/stream/NonKeyedPartitionStream.java: ## @@ -41,6 +42,20 @@ public interface NonKeyedPartitionStr

Re: [PR] [FLINK-37222][table] Don't resolve the CatalogView to QueryOperationC… [flink]

2025-03-19 Thread via GitHub
flinkbot commented on PR #26324: URL: https://github.com/apache/flink/pull/26324#issuecomment-2739009906 ## CI report: * 8551cb103f4b88225fecbae91f921a329e2aa3ef UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-37443] Add returns() method to DataStream V2 API for specifying output types with lambda expressions [flink]

2025-03-19 Thread via GitHub
codenohup commented on code in PR #26284: URL: https://github.com/apache/flink/pull/26284#discussion_r2004738242 ## flink-datastream-api/pom.xml: ## @@ -40,5 +40,11 @@ under the License. flink-core-api ${project.version}

Re: [PR] [FLINK-37222][table] Don't resolve the CatalogView to QueryOperationCatalogView if view is created by SQL [flink]

2025-03-19 Thread via GitHub
fsk119 merged PR #26314: URL: https://github.com/apache/flink/pull/26314 -- 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] [Commented] (FLINK-37222) Table planner exception when sql client submit job

2025-03-19 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936990#comment-17936990 ] Shengkai Fang commented on FLINK-37222: --- Merged into release-1.20 at: 7c9fed55cc1

[jira] [Created] (FLINK-37516) Whether to only synchronize the structure of the table.

2025-03-19 Thread vertern (Jira)
vertern created FLINK-37516: --- Summary: Whether to only synchronize the structure of the table. Key: FLINK-37516 URL: https://issues.apache.org/jira/browse/FLINK-37516 Project: Flink Issue Type: New

[jira] [Created] (FLINK-37517) Bump flink 2.0 for elasticsearch connector

2025-03-19 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-37517: -- Summary: Bump flink 2.0 for elasticsearch connector Key: FLINK-37517 URL: https://issues.apache.org/jira/browse/FLINK-37517 Project: Flink Issue Type: Bug

Re: [PR] Bump flink to 2.0 [flink-connector-elasticsearch]

2025-03-19 Thread via GitHub
reswqa commented on code in PR #118: URL: https://github.com/apache/flink-connector-elasticsearch/pull/118#discussion_r2004644361 ## .github/workflows/push_pr.yml: ## @@ -28,8 +28,8 @@ jobs: compile_and_test: strategy: matrix: -flink: [ 1.19-SNAPSHOT, 1.2

[jira] [Closed] (FLINK-35350) Add documentation for Kudu

2025-03-19 Thread Ferenc Csaky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ferenc Csaky closed FLINK-35350. Resolution: Fixed [f40edf4|https://github.com/apache/flink-connector-kudu/commit/f40edf46af5cbbc91

[jira] [Commented] (FLINK-37248) Scala was removed in flink 2.0

2025-03-19 Thread 911432 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936967#comment-17936967 ] 911432 commented on FLINK-37248: [https://github.com/apache/flink-web/pull/777/files] S

[jira] [Updated] (FLINK-37478) [flink-operator][FlinkDeployment] Doesn't provide a mechanism to label the service

2025-03-19 Thread Julian (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julian updated FLINK-37478: --- Description: I don't see a way to add labels to the Service created by the FlinkDeployment. My organization

[jira] [Updated] (FLINK-37478) [flink-operator][FlinkDeployment] Doesn't provide a mechanism to label the Services

2025-03-19 Thread Julian (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julian updated FLINK-37478: --- Summary: [flink-operator][FlinkDeployment] Doesn't provide a mechanism to label the Services (was: [flink-o

[jira] [Closed] (FLINK-34928) FLIP-439: Externalize Kudu Connector from Bahir

2025-03-19 Thread Ferenc Csaky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ferenc Csaky closed FLINK-34928. Resolution: Fixed > FLIP-439: Externalize Kudu Connector from Bahir >

[jira] [Commented] (FLINK-37504) Handle TLS Certificate Renewal

2025-03-19 Thread David Radley (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936883#comment-17936883 ] David Radley commented on FLINK-37504: -- Hi I think this should be a Flip - similar

Re: [PR] FLINK-35350 [flink-connector-kudu]

2025-03-19 Thread via GitHub
ferenc-csaky closed pull request #9: FLINK-35350 URL: https://github.com/apache/flink-connector-kudu/pull/9 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-ma

[jira] [Created] (FLINK-37515) FLIP-503: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic)

2025-03-19 Thread Sergio Chong (Jira)
Sergio Chong created FLINK-37515: Summary: FLIP-503: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic) Key: FLINK-37515 URL: https://issues.apache.org/jira/browse/FLINK-37515 Project: Fl

Re: [PR] [FLINK-37510] Avoid duplicate calculations for SlidingEventTimeWindows [flink]

2025-03-19 Thread via GitHub
flinkbot commented on PR #26319: URL: https://github.com/apache/flink/pull/26319#issuecomment-2735654752 ## CI report: * f8f9085734eeda119712af756b504dd4775c7985 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-37512] Fix the OOM for SlidingEventTimeWindows [flink]

2025-03-19 Thread via GitHub
nilmadhab commented on code in PR #26321: URL: https://github.com/apache/flink/pull/26321#discussion_r2003824113 ## flink-runtime/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingEventTimeWindows.java: ## @@ -59,6 +59,11 @@ protected SlidingEventTimeWindow

[jira] [Commented] (FLINK-37483) Native kubernetes clusters losing checkpoint state on FAILED

2025-03-19 Thread Max Feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936886#comment-17936886 ] Max Feng commented on FLINK-37483: -- Here are logs from job submission to when cleanup o

Re: [PR] [FLIP-481][FLINK-37426] Introduce Event Reporting [flink]

2025-03-19 Thread via GitHub
davidradl commented on code in PR #26316: URL: https://github.com/apache/flink/pull/26316#discussion_r2003780312 ## docs/layouts/shortcodes/generated/event_configuration.html: ## @@ -0,0 +1,60 @@ + + + +Key +Default +Type +

[jira] [Updated] (FLINK-29058) Analyze table xxx For columns will thrown error while encounter String type column with null value

2025-03-19 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-29058: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Analyze table xxx For columns will thrown

[jira] [Updated] (FLINK-36986) Migrate SplitRemoteConditionFromJoinRule

2025-03-19 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36986: --- Affects Version/s: 2.1.0 (was: 2.0.0) > Migrate SplitRemoteConditionFromJ

[jira] [Updated] (FLINK-18564) Add Support for Azure Event Hub DataStream Connector

2025-03-19 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-18564: --- Affects Version/s: 2.1.0 (was: 1.12.0) > Add Support for Azure Event Hub

[jira] [Updated] (FLINK-29027) Fix HiveTableSink failed to report statistic to hive metastore in stream mode

2025-03-19 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-29027: --- Affects Version/s: 2.1.0 > Fix HiveTableSink failed to report statistic to hive metastore in stream

[jira] [Comment Edited] (FLINK-37504) Handle TLS Certificate Renewal

2025-03-19 Thread David Radley (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936883#comment-17936883 ] David Radley edited comment on FLINK-37504 at 3/19/25 4:26 PM: ---

Re: [PR] Support config yaml [flink-kubernetes-operator]

2025-03-19 Thread via GitHub
ctrlaltdilj commented on PR #848: URL: https://github.com/apache/flink-kubernetes-operator/pull/848#issuecomment-2737284875 @gyfora that should be possible, let me take a look -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

[jira] [Updated] (FLINK-37478) [flink-operator][FlinkDeployment] Doesn't provide a mechanism to label the service

2025-03-19 Thread Julian (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julian updated FLINK-37478: --- Description: I don't see a way to add labels to the Service created by the FlinkDeployment. My organization

Re: [PR] [FLINK-37512] Fix the OOM for SlidingEventTimeWindows [flink]

2025-03-19 Thread via GitHub
davidradl commented on code in PR #26321: URL: https://github.com/apache/flink/pull/26321#discussion_r2003671455 ## flink-runtime/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingEventTimeWindows.java: ## @@ -59,6 +59,11 @@ protected SlidingEventTimeWindow

[PR] [FLINK-37512] Fix the OOM for SlidingEventTimeWindows [flink]

2025-03-19 Thread via GitHub
beliefer opened a new pull request, #26321: URL: https://github.com/apache/flink/pull/26321 ## What is the purpose of the change This PR aim to fix the OOM for `SlidingEventTimeWindows`. `SlidingEventTimeWindows` has potential OOM risks if the window size is big and the slide is sm

[jira] [Resolved] (FLINK-37412) Add slot allocation strategy to for selecting TMs first that have already slots assigned

2025-03-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-37412. --- Release Note: A new strategy MIN_RESOURCES for selecting a TaskManager for slot allocation o

Re: [PR] [MINOR] Remove unnecessary InternalPriorityQueue [flink]

2025-03-19 Thread via GitHub
davidradl commented on PR #26315: URL: https://github.com/apache/flink/pull/26315#issuecomment-2737080857 @beliefer I have approved this - nit: please could you change the title so it starts with [hotfix] in line with the dev process. Thanks -- This is an automated message from the Apache

Re: [PR] [FLINK-37510] Avoid duplicate calculations for SlidingEventTimeWindows [flink]

2025-03-19 Thread via GitHub
davidradl commented on code in PR #26319: URL: https://github.com/apache/flink/pull/26319#discussion_r2003630811 ## flink-runtime/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingEventTimeWindows.java: ## @@ -71,7 +71,8 @@ public Collection assignWindows(

[jira] [Commented] (FLINK-37412) Add slot allocation strategy to for selecting TMs first that have already slots assigned

2025-03-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936865#comment-17936865 ] Matthias Pohl commented on FLINK-37412: --- Sorry, [~Jiangang], I missed your comment

Re: [PR] [FLINK-37412] Add MIN_RESOURCES TaskManagerLoadBalanceMode to maximize TM usage [flink]

2025-03-19 Thread via GitHub
XComp merged PR #26308: URL: https://github.com/apache/flink/pull/26308 -- 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] [Updated] (FLINK-37511) JobPlan properties aren't listed in OpenAPI spec

2025-03-19 Thread Efrat Levitan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Efrat Levitan updated FLINK-37511: -- Description: Currently JobPlanInfo uses custom serialization, which is not recognized by open

Re: [PR] [FLINK-36931][cdc] FlinkCDC YAML supports batch mode [flink-cdc]

2025-03-19 Thread via GitHub
aiwenmo commented on code in PR #3812: URL: https://github.com/apache/flink-cdc/pull/3812#discussion_r2003485777 ## flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaDerivator.java: ## @@ -341,4 +355,57 @@ public Optional coerceDataRecord

Re: [PR] [FLINK-36931][cdc] FlinkCDC YAML supports batch mode [flink-cdc]

2025-03-19 Thread via GitHub
aiwenmo commented on code in PR #3812: URL: https://github.com/apache/flink-cdc/pull/3812#discussion_r2003452471 ## flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaDerivator.java: ## @@ -134,6 +135,19 @@ public static Set reverseLookup

Re: [PR] [FLINK-36931][cdc] FlinkCDC YAML supports batch mode [flink-cdc]

2025-03-19 Thread via GitHub
aiwenmo commented on code in PR #3812: URL: https://github.com/apache/flink-cdc/pull/3812#discussion_r2003444291 ## flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator/DataSinkTranslator.java: ## @@ -158,8 +176,7 @@ private void addCommittingTopology

[jira] [Updated] (FLINK-16800) TypeMappingUtils#checkIfCompatible didn't deal with nested types

2025-03-19 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-16800: --- Fix Version/s: 2.1.0 (was: 2.0.0) > TypeMappingUtils#checkIfCompatible didn't

Re: [PR] [FLINK-37512] Fix the OOM for SlidingEventTimeWindows [flink]

2025-03-19 Thread via GitHub
beliefer commented on PR #26321: URL: https://github.com/apache/flink/pull/26321#issuecomment-2736781172 ping @aljoscha @StephanEwen cc @1996fanrui @davidradl -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abo

Re: [PR] Support config yaml [flink-kubernetes-operator]

2025-03-19 Thread via GitHub
gyfora commented on PR #848: URL: https://github.com/apache/flink-kubernetes-operator/pull/848#issuecomment-2736779092 I think this will require some more testing and some e2es to make sure that this type of configuration on the operator side still works with Flink versions. Can we e

[jira] [Created] (FLINK-37514) Display if incremental checkpoints are enabled on Flink dashboard's checkpoints tab

2025-03-19 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-37514: --- Summary: Display if incremental checkpoints are enabled on Flink dashboard's checkpoints tab Key: FLINK-37514 URL: https://issues.apache.org/jira/browse/FLINK-37514

Re: [PR] [FLINK-36931][cdc] FlinkCDC YAML supports batch mode [flink-cdc]

2025-03-19 Thread via GitHub
aiwenmo commented on code in PR #3812: URL: https://github.com/apache/flink-cdc/pull/3812#discussion_r2003397123 ## flink-cdc-cli/src/test/resources/definitions/pipeline-definition-full.yaml: ## @@ -58,6 +58,7 @@ pipeline: parallelism: 4 schema.change.behavior: evolve s

[jira] [Updated] (FLINK-19935) Supports configure heap memory of sql-client to avoid OOM

2025-03-19 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-19935: --- Affects Version/s: 2.1.0 (was: 1.11.2) > Supports configure heap memory o

[jira] [Updated] (FLINK-37511) JobPlanInfo properties aren't listed in OpenAPI spec

2025-03-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37511: --- Labels: pull-request-available (was: ) > JobPlanInfo properties aren't listed in OpenAPI sp

Re: [PR] [hotfix][doc] two modes instead of three [flink]

2025-03-19 Thread via GitHub
JingGe merged PR #26300: URL: https://github.com/apache/flink/pull/26300 -- 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] [Updated] (FLINK-28061) create new tech blog for connector development based on Source API

2025-03-19 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-28061: --- Affects Version/s: 2.1.0 (was: 1.15.3) > create new tech blog for connect

Re: [PR] [FLINK-37510] Avoid duplicate calculations for SlidingEventTimeWindows [flink]

2025-03-19 Thread via GitHub
beliefer commented on PR #26319: URL: https://github.com/apache/flink/pull/26319#issuecomment-2736322387 ping @aljoscha @StephanEwen cc @1996fanrui @davidradl -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL ab

Re: [PR] [FLINK-37511][rest] Use Jackson serialization in JobPlanInfo.Plan [flink]

2025-03-19 Thread via GitHub
davidradl commented on PR #26320: URL: https://github.com/apache/flink/pull/26320#issuecomment-2736071087 - this appears to be an issue with the open api and rest docs - that are not generating correctly. - the fix seems to be to change the way we do job serialization - on the face of

Re: [PR] [FLINK-37412] Add MIN_RESOURCES TaskManagerLoadBalanceMode to maximize TM usage [flink]

2025-03-19 Thread via GitHub
vahmed-hamdy commented on code in PR #26308: URL: https://github.com/apache/flink/pull/26308#discussion_r2002993245 ## flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/DefaultResourceAllocationStrategyTest.java: ## @@ -138,6 +137,99 @@ void testFu

Re: [PR] Cherry-pick FLINK-37222 [flink]

2025-03-19 Thread via GitHub
fsk119 closed pull request #26310: Cherry-pick FLINK-37222 URL: https://github.com/apache/flink/pull/26310 -- 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-37512] Fix the OOM for SlidingEventTimeWindows [flink]

2025-03-19 Thread via GitHub
beliefer commented on code in PR #26321: URL: https://github.com/apache/flink/pull/26321#discussion_r2002952066 ## flink-runtime/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingEventTimeWindows.java: ## @@ -59,6 +59,11 @@ protected SlidingEventTimeWindows

[jira] [Updated] (FLINK-28104) Drop the unused order parameter in FirstValueFunction/LastValueFunction

2025-03-19 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-28104: --- Affects Version/s: 2.1.0 > Drop the unused order parameter in FirstValueFunction/LastValueFunction >

[jira] [Updated] (FLINK-20091) Introduce avro.ignore-parse-errors for AvroRowDataDeserializationSchema

2025-03-19 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-20091: --- Affects Version/s: 2.1.0 (was: 1.12.0) > Introduce avro.ignore-parse-erro

[PR] [FLINK-37491][release] Build 2.0 docs in GitHub Action and mark 2.0 as stable in docs [flink]

2025-03-19 Thread via GitHub
reswqa opened a new pull request, #26322: URL: https://github.com/apache/flink/pull/26322 (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-37491][release] Build 2.0 docs in GitHub Action and mark 2.0 as stable in docs [flink]

2025-03-19 Thread via GitHub
flinkbot commented on PR #26322: URL: https://github.com/apache/flink/pull/26322#issuecomment-2735848233 ## CI report: * 6788de932c39b10c653c931fc7df0cbc97347dd3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Created] (FLINK-37513) CassandraSource CQL_PROHIBITED_CLAUSES_REGEXP invalid regex

2025-03-19 Thread Maciej Bak (Jira)
Maciej Bak created FLINK-37513: -- Summary: CassandraSource CQL_PROHIBITED_CLAUSES_REGEXP invalid regex Key: FLINK-37513 URL: https://issues.apache.org/jira/browse/FLINK-37513 Project: Flink Issu

Re: [PR] [FLINK-37512] Fix the OOM for SlidingEventTimeWindows [flink]

2025-03-19 Thread via GitHub
flinkbot commented on PR #26321: URL: https://github.com/apache/flink/pull/26321#issuecomment-2735765192 ## CI report: * ef9b8f377868b1de759701106d492c6e171b950e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-37510] Avoid duplicate calculations for SlidingEventTimeWindows [flink]

2025-03-19 Thread via GitHub
nilmadhab commented on PR #26319: URL: https://github.com/apache/flink/pull/26319#issuecomment-2735679717 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 specific comment. To unsubscrib

[jira] [Updated] (FLINK-37032) Prepare Flink 2.0 Release

2025-03-19 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37032: - Fix Version/s: 2.0.0 (was: 2.1.0) > Prepare Flink 2.0 Release > -

[jira] [Closed] (FLINK-37032) Prepare Flink 2.0 Release

2025-03-19 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-37032. Resolution: Fixed > Prepare Flink 2.0 Release > - > > Key:

[jira] [Updated] (FLINK-37040) [Release-2.0] Review and update documentation

2025-03-19 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37040: - Fix Version/s: 2.0.0 (was: 2.1.0) > [Release-2.0] Review and update docum

[jira] [Updated] (FLINK-37040) [Release-2.0] Review and update documentation

2025-03-19 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37040: - Affects Version/s: (was: 2.1.0) > [Release-2.0] Review and update documentation > --

[jira] [Closed] (FLINK-37040) [Release-2.0] Review and update documentation

2025-03-19 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-37040. Resolution: Fixed > [Release-2.0] Review and update documentation > --

Re: [PR] [FLINK-37512] Fix the OOM for SlidingEventTimeWindows [flink]

2025-03-19 Thread via GitHub
nilmadhab commented on code in PR #26321: URL: https://github.com/apache/flink/pull/26321#discussion_r2002764455 ## flink-runtime/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingEventTimeWindows.java: ## @@ -59,6 +59,11 @@ protected SlidingEventTimeWindow

[jira] [Updated] (FLINK-37491) Build 2.0 docs in GitHub Action and mark 2.0 as stable in docs

2025-03-19 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-37491: --- Description: Build 2.0 docs in GitHub Action and mark 2.0 as stable in docs > Build 2.0 docs in GitH

Re: [PR] [minor][docs][style] Update documentation link and improve code style [flink-cdc]

2025-03-19 Thread via GitHub
jinkachy commented on code in PR #3961: URL: https://github.com/apache/flink-cdc/pull/3961#discussion_r2002733514 ## flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksDataSinkOptio

Re: [PR] [FLINK-37511] Use Jackson serialization in JobPlanInfo.Plan [flink]

2025-03-19 Thread via GitHub
flinkbot commented on PR #26320: URL: https://github.com/apache/flink/pull/26320#issuecomment-2735726302 ## CI report: * eae16b2aee4074c28b489ad5fcd03360468c5b86 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Assigned] (FLINK-37511) JobPlanInfo properties aren't listed in OpenAPI spec

2025-03-19 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-37511: Assignee: Efrat Levitan > JobPlanInfo properties aren't listed in OpenAPI spec >

[jira] [Updated] (FLINK-37512) SlidingEventTimeWindows causes OOM

2025-03-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37512: --- Labels: pull-request-available (was: ) > SlidingEventTimeWindows causes OOM > -

[jira] [Created] (FLINK-37512) SlidingEventTimeWindows causes OOM

2025-03-19 Thread Jiaan Geng (Jira)
Jiaan Geng created FLINK-37512: -- Summary: SlidingEventTimeWindows causes OOM Key: FLINK-37512 URL: https://issues.apache.org/jira/browse/FLINK-37512 Project: Flink Issue Type: Bug Comp

[jira] [Updated] (FLINK-37511) JobPlanInfo properties aren't listed in OpenAPI spec

2025-03-19 Thread Efrat Levitan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Efrat Levitan updated FLINK-37511: -- Summary: JobPlanInfo properties aren't listed in OpenAPI spec (was: JobPlan properties aren't

[jira] [Commented] (FLINK-21752) NullPointerException on restore in PojoSerializer

2025-03-19 Thread Hao Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936722#comment-17936722 ] Hao Yu commented on FLINK-21752: we also encounter the problem. {code:java} //代码占位符 org.

[jira] [Created] (FLINK-37511) JobPlan properties aren't listed in OpenAPI spec

2025-03-19 Thread Efrat Levitan (Jira)
Efrat Levitan created FLINK-37511: - Summary: JobPlan properties aren't listed in OpenAPI spec Key: FLINK-37511 URL: https://issues.apache.org/jira/browse/FLINK-37511 Project: Flink Issue Type

[jira] [Updated] (FLINK-37510) Avoid duplicate calculations for SlidingEventTimeWindows

2025-03-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37510: --- Labels: pull-request-available (was: ) > Avoid duplicate calculations for SlidingEventTimeW

[PR] [FLINK-37510] Avoid duplicate calculations for SlidingEventTimeWindows [flink]

2025-03-19 Thread via GitHub
beliefer opened a new pull request, #26319: URL: https://github.com/apache/flink/pull/26319 ## What is the purpose of the change This PR aim to avoid duplicate calculations for `SlidingEventTimeWindows`. ## Brief change log Avoid duplicate calculations for `SlidingEve

Re: [PR] [minor][docs][style] Update documentation link and improve code style [flink-cdc]

2025-03-19 Thread via GitHub
yuxiqian commented on code in PR #3961: URL: https://github.com/apache/flink-cdc/pull/3961#discussion_r2002649068 ## flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksDataSinkOptio

[jira] [Commented] (FLINK-37483) Native kubernetes clusters losing checkpoint state on FAILED

2025-03-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936726#comment-17936726 ] Matthias Pohl commented on FLINK-37483: --- This is the stacktrace you got when the J

[jira] [Updated] (FLINK-37510) Avoid duplicate calculations for SlidingEventTimeWindows

2025-03-19 Thread Jiaan Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiaan Geng updated FLINK-37510: --- Summary: Avoid duplicate calculations for SlidingEventTimeWindows (was: Improve the code for Slidin

[jira] [Created] (FLINK-37510) Improve the code for SlidingEventTimeWindows

2025-03-19 Thread Jiaan Geng (Jira)
Jiaan Geng created FLINK-37510: -- Summary: Improve the code for SlidingEventTimeWindows Key: FLINK-37510 URL: https://issues.apache.org/jira/browse/FLINK-37510 Project: Flink Issue Type: Improvem

[jira] [Resolved] (FLINK-37497) Deploy Python artifacts to PyPI

2025-03-19 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-37497. Fix Version/s: 2.0.0 (was: 1.20.0) Resolution: Fixed Done. > Deploy

Re: [PR] [FLINK-37443] Add returns() method to DataStream V2 API for specifying output types with lambda expressions [flink]

2025-03-19 Thread via GitHub
reswqa commented on PR #26284: URL: https://github.com/apache/flink/pull/26284#issuecomment-2735564783 cc @codenohup -- 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 uns

[jira] [Updated] (FLINK-37493) Update japicmp configuration

2025-03-19 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-37493: --- Fix Version/s: (was: 1.20.0) (was: 2.0-preview) > Update japicmp configur

[jira] [Updated] (FLINK-37499) Create Git tag and mark version as released in Jira

2025-03-19 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-37499: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Create Git tag and mark version as relea

[jira] [Commented] (FLINK-37433) Schema Registry is busy now, waiting for next request...

2025-03-19 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936412#comment-17936412 ] yux commented on FLINK-37433: - I think Doris sink does not support shrinking column types fo

[jira] [Resolved] (FLINK-37499) Create Git tag and mark version as released in Jira

2025-03-19 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-37499. Resolution: Done > Create Git tag and mark version as released in Jira > -

  1   2   >