[jira] [Commented] (FLINK-36201) StateLocalitySlotAssigner should be only used when local recovery is enabled for Adaptive Scheduler

2024-09-04 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-36201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17879116#comment-17879116 ] David Morávek commented on FLINK-36201: --- ma

[jira] [Created] (FLINK-36237) socket closed exception when using JdbcSource with split configuration

2024-09-09 Thread Jira
Martin Krüger created FLINK-36237: - Summary: socket closed exception when using JdbcSource with split configuration Key: FLINK-36237 URL: https://issues.apache.org/jira/browse/FLINK-36237 Project

[jira] [Updated] (FLINK-36237) socket closed exception when using JdbcSource with split configuration

2024-09-09 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-36237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martin Krüger updated FLINK-36237: -- Description: When using the JdbcSource with a split configuration and a

[jira] [Updated] (FLINK-36237) socket closed exception when using JdbcSource with split configuration

2024-09-09 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-36237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martin Krüger updated FLINK-36237: -- Description: When using the JdbcSource with a split configuration and a

[jira] [Created] (FLINK-36271) Support json and jsonb type in PostgreSQL JDBC Dialect

2024-09-12 Thread Jira
Grzegorz Kołakowski created FLINK-36271: --- Summary: Support json and jsonb type in PostgreSQL JDBC Dialect Key: FLINK-36271 URL: https://issues.apache.org/jira/browse/FLINK-36271 Project: Flink

[jira] [Commented] (FLINK-36146) NoSuchElement exception from SingleThreadFetcherManager

2024-09-13 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-36146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881576#comment-17881576 ] Kim Gräsman commented on FLINK-36146: - cc [~becket_qin], I saw you've mad

[jira] [Commented] (FLINK-36146) NoSuchElement exception from SingleThreadFetcherManager

2024-09-14 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-36146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881762#comment-17881762 ] Kim Gräsman commented on FLINK-36146: - [~becket_qin] Thanks! That suggestion

[jira] [Commented] (FLINK-36146) NoSuchElement exception from SingleThreadFetcherManager

2024-09-15 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-36146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881867#comment-17881867 ] Kim Gräsman commented on FLINK-36146: - Thank you! Hmm, yeah, I don't u

[jira] [Comment Edited] (FLINK-36146) NoSuchElement exception from SingleThreadFetcherManager

2024-09-16 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-36146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881867#comment-17881867 ] Kim Gräsman edited comment on FLINK-36146 at 9/16/24 7:0

[jira] [Commented] (FLINK-36146) NoSuchElement exception from SingleThreadFetcherManager

2024-09-16 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-36146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881941#comment-17881941 ] Kim Gräsman commented on FLINK-36146: - Thanks for your support, I posted: h

[jira] [Created] (FLINK-35228) DynamicKafkaSource does not read re-added topic for the same cluster

2024-04-24 Thread Jira
Ignas Daukšas created FLINK-35228: - Summary: DynamicKafkaSource does not read re-added topic for the same cluster Key: FLINK-35228 URL: https://issues.apache.org/jira/browse/FLINK-35228 Project

[jira] [Assigned] (FLINK-33212) Introduce job status changed listener for lineage

2024-04-29 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-33212: -- Assignee: Zhenqiu Huang > Introduce job status changed listener for line

[jira] [Created] (FLINK-35278) Occasional NPE on k8s operator status replacement

2024-04-30 Thread Jira
Márton Balassi created FLINK-35278: -- Summary: Occasional NPE on k8s operator status replacement Key: FLINK-35278 URL: https://issues.apache.org/jira/browse/FLINK-35278 Project: Flink Issue

[jira] [Assigned] (FLINK-35278) Occasional NPE on k8s operator status replacement

2024-05-01 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-35278: -- Assignee: Ferenc Csaky > Occasional NPE on k8s operator status replacem

[jira] [Closed] (FLINK-35278) Occasional NPE on k8s operator status replacement

2024-05-04 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-35278. -- Resolution: Fixed [e73363f|https://github.com/apache/flink-kubernetes-operator/commit

[jira] [Closed] (FLINK-35183) Expose FlinkMinorVersion as metric for applications in operator

2024-05-09 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-35183. -- Resolution: Fixed [{{84d9b74}}|https://github.com/apache/flink-kubernetes-operator/commit

[jira] [Created] (FLINK-35352) Add -sae submit task to run for a period of time and automatically cancel

2024-05-14 Thread Jira
谷金城 created FLINK-35352: --- Summary: Add -sae submit task to run for a period of time and automatically cancel Key: FLINK-35352 URL: https://issues.apache.org/jira/browse/FLINK-35352 Project: Flink

[jira] [Commented] (FLINK-35333) JdbcXaSinkTestBase fails in weekly Flink JDBC Connector tests

2024-05-14 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846370#comment-17846370 ] João Boto commented on FLINK-35333: --- [~martijnvisser] could you assign this t

[jira] [Commented] (FLINK-35333) JdbcXaSinkTestBase fails in weekly Flink JDBC Connector tests

2024-05-14 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846373#comment-17846373 ] João Boto commented on FLINK-35333: --- I think I resolve the problem, but on v3.1

[jira] [Comment Edited] (FLINK-35333) JdbcXaSinkTestBase fails in weekly Flink JDBC Connector tests

2024-05-14 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846373#comment-17846373 ] João Boto edited comment on FLINK-35333 at 5/14/24 4:4

[jira] [Commented] (FLINK-35333) JdbcXaSinkTestBase fails in weekly Flink JDBC Connector tests

2024-05-14 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846380#comment-17846380 ] João Boto commented on FLINK-35333: --- on #120 I try to fix the error, but ano

[jira] [Commented] (FLINK-34904) [Feature] submit Flink CDC pipeline job to yarn application cluster.

2024-05-15 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-34904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846571#comment-17846571 ] 王俊博 commented on FLINK-34904: - For now flink-cdc pipeline support cli yarn session

[jira] [Comment Edited] (FLINK-34904) [Feature] submit Flink CDC pipeline job to yarn application cluster.

2024-05-15 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-34904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846571#comment-17846571 ] 王俊博 edited comment on FLINK-34904 at 5/15/24 9:49 AM: -- For

[jira] [Comment Edited] (FLINK-34904) [Feature] submit Flink CDC pipeline job to yarn application cluster.

2024-05-15 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-34904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846571#comment-17846571 ] 王俊博 edited comment on FLINK-34904 at 5/15/24 9:50 AM: -- For

[jira] (FLINK-34904) [Feature] submit Flink CDC pipeline job to yarn application cluster.

2024-05-15 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-34904 ] 王俊博 deleted comment on FLINK-34904: - was (Author: kwafor): For now flink-cdc pipeline support cli yarn session mode submit.I'm willing to support yarn application mode submit, could assign it

[jira] [Created] (FLINK-35360) [Feature] Submit Flink CDC pipeline job to yarn Application mode

2024-05-15 Thread Jira
王俊博 created FLINK-35360: --- Summary: [Feature] Submit Flink CDC pipeline job to yarn Application mode Key: FLINK-35360 URL: https://issues.apache.org/jira/browse/FLINK-35360 Project: Flink Issue Type

[jira] [Updated] (FLINK-35360) [Feature] Submit Flink CDC pipeline job yarn Application mode

2024-05-15 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 王俊博 updated FLINK-35360: Summary: [Feature] Submit Flink CDC pipeline job yarn Application mode (was: [Feature] Submit Flink CDC pipeline

[jira] [Created] (FLINK-35362) Reorganization of flink-connector-jdbc

2024-05-15 Thread Jira
João Boto created FLINK-35362: - Summary: Reorganization of flink-connector-jdbc Key: FLINK-35362 URL: https://issues.apache.org/jira/browse/FLINK-35362 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-35363) Reorganization of flink-connector-jdbc

2024-05-15 Thread Jira
João Boto created FLINK-35363: - Summary: Reorganization of flink-connector-jdbc Key: FLINK-35363 URL: https://issues.apache.org/jira/browse/FLINK-35363 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-35364) Create core module and move code

2024-05-15 Thread Jira
João Boto created FLINK-35364: - Summary: Create core module and move code Key: FLINK-35364 URL: https://issues.apache.org/jira/browse/FLINK-35364 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-35365) Reorganize catalog and dialect code

2024-05-15 Thread Jira
João Boto created FLINK-35365: - Summary: Reorganize catalog and dialect code Key: FLINK-35365 URL: https://issues.apache.org/jira/browse/FLINK-35365 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-35366) Create all database modules

2024-05-15 Thread Jira
João Boto created FLINK-35366: - Summary: Create all database modules Key: FLINK-35366 URL: https://issues.apache.org/jira/browse/FLINK-35366 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-35367) Reorganize datastream sink and source

2024-05-15 Thread Jira
João Boto created FLINK-35367: - Summary: Reorganize datastream sink and source Key: FLINK-35367 URL: https://issues.apache.org/jira/browse/FLINK-35367 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-35368) Reorganize table code

2024-05-15 Thread Jira
João Boto created FLINK-35368: - Summary: Reorganize table code Key: FLINK-35368 URL: https://issues.apache.org/jira/browse/FLINK-35368 Project: Flink Issue Type: Sub-task Reporter

[jira] [Commented] (FLINK-35362) Reorganization of flink-connector-jdbc

2024-05-15 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846727#comment-17846727 ] João Boto commented on FLINK-35362: --- closing as duplicated.. > Reorganiza

[jira] [Closed] (FLINK-35362) Reorganization of flink-connector-jdbc

2024-05-15 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] João Boto closed FLINK-35362. - Resolution: Duplicate > Reorganization of flink-connector-j

[jira] [Updated] (FLINK-35363) FLIP-449: Reorganization of flink-connector-jdbc

2024-05-15 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] João Boto updated FLINK-35363: -- Summary: FLIP-449: Reorganization of flink-connector-jdbc (was: Reorganization of flink-connector

[jira] [Commented] (FLINK-35363) FLIP-449: Reorganization of flink-connector-jdbc

2024-05-15 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846731#comment-17846731 ] João Boto commented on FLINK-35363: --- can anyone assign this to me please > F

[jira] [Created] (FLINK-35370) Create a temp module to test backward compatibility

2024-05-15 Thread Jira
João Boto created FLINK-35370: - Summary: Create a temp module to test backward compatibility Key: FLINK-35370 URL: https://issues.apache.org/jira/browse/FLINK-35370 Project: Flink Issue Type

[jira] [Created] (FLINK-35375) About a question report "Failed to deserialize data of EventHeaderV4" of flink cdc2.4.2

2024-05-16 Thread Jira
田元志 created FLINK-35375: --- Summary: About a question report "Failed to deserialize data of EventHeaderV4" of flink cdc2.4.2 Key: FLINK-35375 URL: https://issues.apache.org/jira/browse/FLINK-35375 Proj

[jira] [Updated] (FLINK-35375) About a question report "Failed to deserialize data of EventHeaderV4" of flink cdc2.4.2

2024-05-16 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 田元志 updated FLINK-35375: Description: This is an error reported by Flink CDC data synchronization because a lot of data was missed during

[jira] [Updated] (FLINK-35375) About a question report "Failed to deserialize data of EventHeaderV4" of flink cdc2.4.2

2024-05-16 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 田元志 updated FLINK-35375: Description: This is an error reported by Flink CDC data synchronization because a lot of data was missed during

[jira] [Created] (FLINK-35376) When flink submits the job by calling the rest api, the dependent jar package generated to the tmp is not removed

2024-05-16 Thread Jira
中国无锡周良 created FLINK-35376: -- Summary: When flink submits the job by calling the rest api, the dependent jar package generated to the tmp is not removed Key: FLINK-35376 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-35388) Flink 1.18.1 get stuck after creating highly available job result storage directory

2024-05-17 Thread Jira
Pedro Mázala created FLINK-35388: Summary: Flink 1.18.1 get stuck after creating highly available job result storage directory Key: FLINK-35388 URL: https://issues.apache.org/jira/browse/FLINK-35388

[jira] [Created] (FLINK-35390) Error reporting in SQL Server connection table structure table in Flink CDC-3.0 version

2024-05-17 Thread Jira
段志民 created FLINK-35390: --- Summary: Error reporting in SQL Server connection table structure table in Flink CDC-3.0 version Key: FLINK-35390 URL: https://issues.apache.org/jira/browse/FLINK-35390 Project: Flink

[jira] [Updated] (FLINK-35388) Flink 1.18.1 get stuck after creating highly available job result storage directory

2024-05-20 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pedro Mázala updated FLINK-35388: - Component/s: Runtime / Checkpointing > Flink 1.18.1 get stuck after creating highly availa

[jira] [Updated] (FLINK-35388) Flink 1.18.1 get stuck after creating highly available job result storage directory

2024-05-20 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pedro Mázala updated FLINK-35388: - Component/s: (was: API / Core) > Flink 1.18.1 get stuck after creating highly available

[jira] [Created] (FLINK-35402) [flink-operator][Deployment] add labels to metadata

2024-05-20 Thread Jira
Luís Costa created FLINK-35402: -- Summary: [flink-operator][Deployment] add labels to metadata Key: FLINK-35402 URL: https://issues.apache.org/jira/browse/FLINK-35402 Project: Flink Issue Type

[jira] [Updated] (FLINK-35402) [flink-operator][Deployment] add labels to metadata

2024-05-20 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luís Costa updated FLINK-35402: --- Description: Greetings dear team, I would like to add labels to flink-operator Deployment metadata

[jira] [Commented] (FLINK-35388) Flink 1.18.1 get stuck after creating highly available job result storage directory

2024-05-21 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848259#comment-17848259 ] Pedro Mázala commented on FLINK-35388: -- I found this https://stackoverflow

[jira] [Created] (FLINK-35422) Flink dynamically adjusts operator-level resource usage without stopping the job

2024-05-22 Thread Jira
尹博星 created FLINK-35422: --- Summary: Flink dynamically adjusts operator-level resource usage without stopping the job Key: FLINK-35422 URL: https://issues.apache.org/jira/browse/FLINK-35422 Project: Flink

[jira] [Commented] (FLINK-34333) Fix FLINK-34007 LeaderElector bug in 1.18

2024-05-23 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-34333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848912#comment-17848912 ] Pedro Mázala commented on FLINK-34333: -- Do you guys know when 1.18.2 will mak

[jira] [Commented] (FLINK-34333) Fix FLINK-34007 LeaderElector bug in 1.18

2024-05-24 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-34333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849337#comment-17849337 ] Pedro Mázala commented on FLINK-34333: -- I've just done it. Thank you fo

[jira] [Assigned] (FLINK-32562) FileSink Compactor Service should not use FileWriter from Sink for OutputStreamBasedFileCompactor

2024-05-28 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-32562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-32562: -- Assignee: Ferenc Csaky > FileSink Compactor Service should not use FileWriter f

[jira] [Updated] (FLINK-35367) Reorganize sinks

2024-05-30 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] João Boto updated FLINK-35367: -- Summary: Reorganize sinks (was: Reorganize datastream sink and source) > Reorganize si

[jira] [Created] (FLINK-35494) Reorganize sources

2024-05-30 Thread Jira
João Boto created FLINK-35494: - Summary: Reorganize sources Key: FLINK-35494 URL: https://issues.apache.org/jira/browse/FLINK-35494 Project: Flink Issue Type: Sub-task Reporter: João

[jira] [Commented] (FLINK-35363) FLIP-449: Reorganization of flink-connector-jdbc

2024-05-31 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850967#comment-17850967 ] João Boto commented on FLINK-35363: --- Thank [~leonard].. could you please assign

[jira] [Commented] (FLINK-31533) CREATE TABLE AS SELECT should support to define partition

2024-06-04 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-31533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17852110#comment-17852110 ] Sergio Peña commented on FLINK-31533: - Hi [~luoyuxia] [~aitozi], I'd lik

[jira] [Commented] (FLINK-35035) Reduce job pause time when cluster resources are expanded in adaptive mode

2024-06-06 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17852668#comment-17852668 ] David Morávek commented on FLINK-35035: --- Yes, we have this on our radar. [~ma

[jira] [Commented] (FLINK-33278) RemotePekkoRpcActorTest.failsRpcResultImmediatelyIfRemoteRpcServiceIsNotAvailable fails on AZP

2024-06-06 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17852691#comment-17852691 ] Pedro Mázala commented on FLINK-33278: -- Is there any updates on this? I&#x

[jira] [Commented] (FLINK-26948) Add SORT_ARRAY supported in SQL & Table API

2023-09-01 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-26948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761316#comment-17761316 ] Jörn Kottmann commented on FLINK-26948: --- Sorry for the delay, I will try to

[jira] [Commented] (FLINK-27146) [JUnit5 Migration] Module: flink-filesystems

2023-09-01 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-27146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761317#comment-17761317 ] Jörn Kottmann commented on FLINK-27146: --- The PR is available and is waiting f

[jira] [Closed] (FLINK-33066) Enable to inject environment variable from secret/configmap to operatorPod

2023-09-13 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-33066. -- Fix Version/s: kubernetes-operator-1.7.0 Resolution: Fixed 1053e26 in main > Ena

[jira] [Commented] (FLINK-33108) Error during error status handling

2023-09-18 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17766355#comment-17766355 ] Márton Balassi commented on FLINK-33108: That value change represents when

[jira] [Comment Edited] (FLINK-33108) Error during error status handling

2023-09-18 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17766355#comment-17766355 ] Márton Balassi edited comment on FLINK-33108 at 9/18/23 12:1

[jira] [Comment Edited] (FLINK-33108) Error during error status handling

2023-09-18 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17766355#comment-17766355 ] Márton Balassi edited comment on FLINK-33108 at 9/18/23 12:2

[jira] [Created] (FLINK-33163) Support Java 21 (LTS)

2023-09-26 Thread Jira
Maciej Bryński created FLINK-33163: -- Summary: Support Java 21 (LTS) Key: FLINK-33163 URL: https://issues.apache.org/jira/browse/FLINK-33163 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-33163) Support Java 21 (LTS)

2023-09-26 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maciej Bryński updated FLINK-33163: --- Issue Type: New Feature (was: Bug) > Support Java 21 (

[jira] [Commented] (FLINK-33155) Flink ResourceManager continuously fails to start TM container on YARN when Kerberos enabled

2023-09-29 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17770648#comment-17770648 ] 袁枫 commented on FLINK-33155: The root cause might be that we are reading the delega

[jira] [Comment Edited] (FLINK-33155) Flink ResourceManager continuously fails to start TM container on YARN when Kerberos enabled

2023-09-29 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17770648#comment-17770648 ] 袁枫 edited comment on FLINK-33155 at 9/30/23 4:22 AM: - The

[jira] [Comment Edited] (FLINK-33155) Flink ResourceManager continuously fails to start TM container on YARN when Kerberos enabled

2023-09-30 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17770648#comment-17770648 ] 袁枫 edited comment on FLINK-33155 at 9/30/23 7:25 AM: - The

[jira] [Commented] (FLINK-30284) Make datadog reporter url configurable

2023-10-03 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-30284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17771507#comment-17771507 ] Dominik Wosiński commented on FLINK-30284: -- This basically makes it imposs

[jira] [Created] (FLINK-33231) Memory leak in KafkaSourceReader if no data in consumed topic

2023-10-10 Thread Jira
Lauri Suurväli created FLINK-33231: -- Summary: Memory leak in KafkaSourceReader if no data in consumed topic Key: FLINK-33231 URL: https://issues.apache.org/jira/browse/FLINK-33231 Project: Flink

[jira] [Commented] (FLINK-33231) Memory leak in KafkaSourceReader if no data in consumed topic

2023-10-10 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773784#comment-17773784 ] Lauri Suurväli commented on FLINK-33231: [~tzulitai] thank you for the com

[jira] [Closed] (FLINK-33030) Add python 3.11 support

2023-10-15 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-33030. -- Resolution: Implemented [{{2da9a96}}|https://github.com/apache/flink/commit

[jira] [Closed] (FLINK-20377) flink-1.11.2 -kerberos config on kafka connector not working

2020-11-30 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-20377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 谢波 closed FLINK-20377. -- Resolution: Fixed > flink-1.11.2 -kerberos config on kafka connector not work

[jira] [Created] (FLINK-20463) flink-1.11.2 -sql cannot ignore exception record

2020-12-02 Thread Jira
谢波 created FLINK-20463: -- Summary: flink-1.11.2 -sql cannot ignore exception record Key: FLINK-20463 URL: https://issues.apache.org/jira/browse/FLINK-20463 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-12532) Upgrade Avro to version 1.10.1

2020-12-03 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-12532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated FLINK-12532: - Summary: Upgrade Avro to version 1.10.1 (was: Upgrade Avro to version 1.10.0) > Upgrade A

[jira] [Created] (FLINK-20542) flink-1.11.2 - stream join stream savepoint fail

2020-12-08 Thread Jira
谢波 created FLINK-20542: -- Summary: flink-1.11.2 - stream join stream savepoint fail Key: FLINK-20542 URL: https://issues.apache.org/jira/browse/FLINK-20542 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-20542) flink-1.11.2 - stream join stream savepoint fail

2020-12-08 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-20542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 谢波 updated FLINK-20542: --- Environment: 1.11.2 2.11   {color:#ff}tEnv.getConfig.setIdleStateRetentionTime(Time.hours(12), Time.hours

[jira] [Updated] (FLINK-20542) flink-1.11.2 - stream join stream savepoint fail

2020-12-08 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-20542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 谢波 updated FLINK-20542: --- Environment: 1.11.2 2.11   {color:#ff}tEnv.getConfig.setIdleStateRetentionTime(Time.hours(12), Time.hours

[jira] [Updated] (FLINK-20542) flink-1.11.2 - stream join stream savepoint fail

2020-12-08 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-20542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 谢波 updated FLINK-20542: --- Description: I have a SQL job that uses stream join stream, but at savepoint, the job fails. I can't man

[jira] [Updated] (FLINK-20542) flink-1.11.2 - stream join stream savepoint fail

2020-12-08 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-20542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 谢波 updated FLINK-20542: --- Description: I have a SQL job that uses stream join stream, but at savepoint, the job fails. I can't man

[jira] [Closed] (FLINK-20542) flink-1.11.2 - stream join stream savepoint fail

2020-12-08 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-20542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 谢波 closed FLINK-20542. -- Resolution: Not A Problem > flink-1.11.2 - stream join stream savepoint f

[jira] [Reopened] (FLINK-20377) flink-1.11.2 -kerberos config on kafka connector not working

2020-12-10 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-20377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 谢波 reopened FLINK-20377: flink 1.12 not show the properties.* options. > flink-1.11.2 -kerberos config on kafka connector not work

[jira] [Comment Edited] (FLINK-20377) flink-1.11.2 -kerberos config on kafka connector not working

2020-12-10 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-20377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17247094#comment-17247094 ] 谢波 edited comment on FLINK-20377 at 12/10/20, 8:52 AM: --- f

[jira] [Closed] (FLINK-20377) flink-1.11.2 -kerberos config on kafka connector not working

2020-12-10 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-20377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 谢波 closed FLINK-20377. -- Resolution: Not A Problem > flink-1.11.2 -kerberos config on kafka connector not work

[jira] [Issue Comment Deleted] (FLINK-20377) flink-1.11.2 -kerberos config on kafka connector not working

2020-12-10 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-20377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 谢波 updated FLINK-20377: --- Comment: was deleted (was: flink 1.12 documents  not show the properties.* options.) > flink-1.11.2 -kerbe

[jira] [Created] (FLINK-20648) Unable to restore job from savepoint when using Kubernetes based HA services

2020-12-17 Thread Jira
David Morávek created FLINK-20648: - Summary: Unable to restore job from savepoint when using Kubernetes based HA services Key: FLINK-20648 URL: https://issues.apache.org/jira/browse/FLINK-20648

[jira] [Updated] (FLINK-20648) Unable to restore job from savepoint when using Kubernetes based HA services

2020-12-17 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-20648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek updated FLINK-20648: -- Description: When restoring job from savepoint, we always end up with following error: {code

[jira] [Commented] (FLINK-20648) Unable to restore job from savepoint when using Kubernetes based HA services

2020-12-17 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-20648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17250945#comment-17250945 ] David Morávek commented on FLINK-20648: --- Possible solution is outlined

[jira] [Commented] (FLINK-20628) Port RabbitMQ Sources to FLIP-27 API

2020-12-17 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-20628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251191#comment-17251191 ] Yannik Schröder commented on FLINK-20628: - Yes. All readers subscribe to

[jira] [Created] (FLINK-20691) flink-1.12.0 job shutdown but metrics group not delete

2020-12-20 Thread Jira
谢波 created FLINK-20691: -- Summary: flink-1.12.0 job shutdown but metrics group not delete Key: FLINK-20691 URL: https://issues.apache.org/jira/browse/FLINK-20691 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-13680) Translate "Code Style - Common Rules" page into Chinese

2020-11-01 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-13680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224441#comment-17224441 ] 白恒 commented on FLINK-13680: Hi guys, It looks like a long time has passed, is this i

[jira] [Created] (FLINK-20092) Multi-thread Flink compilation

2020-11-11 Thread Jira
Maciej Bryński created FLINK-20092: -- Summary: Multi-thread Flink compilation Key: FLINK-20092 URL: https://issues.apache.org/jira/browse/FLINK-20092 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-20092) Multi-thread Flink compilation

2020-11-11 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-20092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230098#comment-17230098 ] Maciej Bryński commented on FLINK-20092: {code:java} maverick@DESKTOP  /m

[jira] [Commented] (FLINK-20092) Multi-thread Flink compilation

2020-11-11 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-20092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230143#comment-17230143 ] Maciej Bryński commented on FLINK-20092: I found some T numbers when buil

[jira] [Updated] (FLINK-20092) [Java 11] Multi-thread Flink compilation not working

2020-11-11 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-20092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maciej Bryński updated FLINK-20092: --- Summary: [Java 11] Multi-thread Flink compilation not working (was: Multi-thread Flink

[jira] [Commented] (FLINK-20092) Multi-thread Flink compilation

2020-11-11 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-20092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230156#comment-17230156 ] Maciej Bryński commented on FLINK-20092: [~dwysakowicz] You're righ

[jira] [Created] (FLINK-20105) Temporary Table does not work when Kafka is used as the versioned side (planner PK problem)

2020-11-12 Thread Jira
Benoît Paris created FLINK-20105: Summary: Temporary Table does not work when Kafka is used as the versioned side (planner PK problem) Key: FLINK-20105 URL: https://issues.apache.org/jira/browse/FLINK-20105

<    4   5   6   7   8   9   10   11   12   13   >