[jira] [Created] (FLINK-36427) Additional Integration Test cases for KDS source

Elphas Toringepi created FLINK-36427: Summary: Additional Integration Test cases for KDS source Key: FLINK-36427 URL: https://issues.apache.org/jira/browse/FLINK-36427 Project: Flink Issu

[jira] [Closed] (FLINK-35492) Add metrics for FlinkStateSnapshot resources

[ https://issues.apache.org/jira/browse/FLINK-35492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-35492. -- Fix Version/s: kubernetes-operator-1.10.0 Resolution: Fixed merged to main 6a27b3e4c954480085db

[jira] [Updated] (FLINK-36426) Introduce the strategy for adaptive scheduler to control state locality preferred or minimal task executors preferred when matching resource requests and slots

[ https://issues.apache.org/jira/browse/FLINK-36426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-36426: --- Description: as discussed in [https://github.com/apache/flink/pull/25218#discussion_r1771187666] j

[jira] (FLINK-36426) Introduce the strategy for adaptive scheduler to control state locality preferred or minimal task executors preferred when matching resource requests and slots

[ https://issues.apache.org/jira/browse/FLINK-36426 ] RocMarshal deleted comment on FLINK-36426: was (Author: rocmarshal): as discussed in [https://github.com/apache/flink/pull/25218#discussion_r1771187666] jobmanager.adaptive-scheduler.state

[jira] [Commented] (FLINK-36426) Introduce the strategy for adaptive scheduler to control state locality preferred or minimal task executors preferred when matching resource requests and slots

[ https://issues.apache.org/jira/browse/FLINK-36426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17886954#comment-17886954 ] RocMarshal commented on FLINK-36426: as discussed in [https://github.com/apache/fli

[jira] [Created] (FLINK-36426) Introduce the strategy for adaptive scheduler to control state locality preferred or minimal task executors preferred when matching resource requests and slots

RocMarshal created FLINK-36426: -- Summary: Introduce the strategy for adaptive scheduler to control state locality preferred or minimal task executors preferred when matching resource requests and slots Key: FLINK-36426

[jira] [Commented] (FLINK-22748) Allow dynamic target topic selection in SQL Kafka sinks

[ https://issues.apache.org/jira/browse/FLINK-22748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17886904#comment-17886904 ] Benoît Paris commented on FLINK-22748: -- Well, I'd like to pause and congratulate al

[jira] [Updated] (FLINK-36423) RichMapPartitionFunction does not invoke the open method in the KeyedPartitionWindowedStream

[ https://issues.apache.org/jira/browse/FLINK-36423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuhuang updated FLINK-36423: Summary: RichMapPartitionFunction does not invoke the open method in the KeyedPartitionWindowedStream (wa

[jira] [Updated] (FLINK-36423) RichMapPartitionFunction not call open method in KeyedPartitionWindowedStream

[ https://issues.apache.org/jira/browse/FLINK-36423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuhuang updated FLINK-36423: Summary: RichMapPartitionFunction not call open method in KeyedPartitionWindowedStream (was: Fix RichMapP

[jira] [Resolved] (FLINK-31986) Implement Integration test for FLIP-27 DataStreams API

[ https://issues.apache.org/jira/browse/FLINK-31986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-31986. - Resolution: Fixed  merged commit [{{b681cfc}}|https://github.com/apache/flink-connector

[jira] [Created] (FLINK-36425) Use JobStatus enum for status.job.state

Gyula Fora created FLINK-36425: -- Summary: Use JobStatus enum for status.job.state Key: FLINK-36425 URL: https://issues.apache.org/jira/browse/FLINK-36425 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-35414) Cancel jobs through rest api for last-state upgrades

[ https://issues.apache.org/jira/browse/FLINK-35414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-35414. -- Fix Version/s: kubernetes-operator-1.10.0 Resolution: Fixed merged to main d1827a4d0df0d674cb1b

[jira] [Comment Edited] (FLINK-36420) Upgrade org.apache.avro:avro to 1.11.4

[ https://issues.apache.org/jira/browse/FLINK-36420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17886786#comment-17886786 ] Danny Cranmer edited comment on FLINK-36420 at 10/4/24 7:54 AM: --

[jira] [Resolved] (FLINK-36420) Upgrade org.apache.avro:avro to 1.11.4

[ https://issues.apache.org/jira/browse/FLINK-36420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-36420. --- Resolution: Fixed > Upgrade org.apache.avro:avro to 1.11.4 > ---

[jira] [Comment Edited] (FLINK-36420) Upgrade org.apache.avro:avro to 1.11.4

[ https://issues.apache.org/jira/browse/FLINK-36420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17886786#comment-17886786 ] Danny Cranmer edited comment on FLINK-36420 at 10/4/24 7:54 AM: --

[jira] [Commented] (FLINK-36421) Missing fsync in FsCheckpointStreamFactory

[ https://issues.apache.org/jira/browse/FLINK-36421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17886847#comment-17886847 ] Gabor Somogyi commented on FLINK-36421: --- [~planet9] we're dealing with super huge

[jira] [Resolved] (FLINK-36422) Broken PyFlink jar download link for Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-36422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-36422. --- Resolution: Fixed > Broken PyFlink jar download link for Kafka connector > -