[jira] [Commented] (FLINK-31963) java.lang.ArrayIndexOutOfBoundsException when scaling down with unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718610#comment-17718610 ] Piotr Nowojski commented on FLINK-31963: Thanks for the answers [~tanee.kim] {q

[jira] [Comment Edited] (FLINK-31963) java.lang.ArrayIndexOutOfBoundsException when scale down via autoscaler

[ https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717586#comment-17717586 ] Piotr Nowojski edited comment on FLINK-31963 at 4/28/23 9:51 AM: -

[jira] [Commented] (FLINK-31963) java.lang.ArrayIndexOutOfBoundsException when scale down via autoscaler

[ https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717586#comment-17717586 ] Piotr Nowojski commented on FLINK-31963: Yes, I agree it looks like a problem wi

[jira] [Updated] (FLINK-31963) java.lang.ArrayIndexOutOfBoundsException when scale down via autoscaler

[ https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-31963: --- Component/s: (was: Kubernetes Operator) > java.lang.ArrayIndexOutOfBoundsException when

[jira] [Closed] (FLINK-26910) flink-benchmarks build fails on Apple M1 silicon

[ https://issues.apache.org/jira/browse/FLINK-26910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-26910. -- Fix Version/s: 1.18.0 Assignee: Martijn Visser Resolution: Fixed Merged to fli

[jira] [Closed] (FLINK-31925) Sync benchmark dependency versions with the version used in Flink

[ https://issues.apache.org/jira/browse/FLINK-31925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-31925. -- Resolution: Fixed Merged to flink-benchmarks master as 87c425f > Sync benchmark dependency ve

[jira] [Assigned] (FLINK-19010) Add a system metric to show the checkpoint restore time

[ https://issues.apache.org/jira/browse/FLINK-19010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-19010: -- Assignee: Yanfei Lei > Add a system metric to show the checkpoint restore time >

[jira] [Commented] (FLINK-19010) Add a system metric to show the checkpoint restore time

[ https://issues.apache.org/jira/browse/FLINK-19010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715700#comment-17715700 ] Piotr Nowojski commented on FLINK-19010: [~zncheng], are you planning to add onl

[jira] [Commented] (FLINK-28386) Trigger an immediate checkpoint after all sources finished

[ https://issues.apache.org/jira/browse/FLINK-28386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17714956#comment-17714956 ] Piotr Nowojski commented on FLINK-28386: [~zlzhang0122] Checkpoint could be used

[jira] [Closed] (FLINK-31846) Support cancel final checkpoint when all tasks are finished

[ https://issues.apache.org/jira/browse/FLINK-31846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-31846. -- Resolution: Duplicate I will close this ticket, as I think it just duplicates FLINK-28386, fee

[jira] [Comment Edited] (FLINK-31846) Support cancel final checkpoint when all tasks are finished

[ https://issues.apache.org/jira/browse/FLINK-31846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17714946#comment-17714946 ] Piotr Nowojski edited comment on FLINK-31846 at 4/21/23 11:33 AM:

[jira] [Comment Edited] (FLINK-31846) Support cancel final checkpoint when all tasks are finished

[ https://issues.apache.org/jira/browse/FLINK-31846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17714946#comment-17714946 ] Piotr Nowojski edited comment on FLINK-31846 at 4/21/23 11:32 AM:

[jira] [Comment Edited] (FLINK-31846) Support cancel final checkpoint when all tasks are finished

[ https://issues.apache.org/jira/browse/FLINK-31846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17714946#comment-17714946 ] Piotr Nowojski edited comment on FLINK-31846 at 4/21/23 11:08 AM:

[jira] [Commented] (FLINK-31846) Support cancel final checkpoint when all tasks are finished

[ https://issues.apache.org/jira/browse/FLINK-31846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17714946#comment-17714946 ] Piotr Nowojski commented on FLINK-31846: {quote} f the final checkpoint cannot b

[jira] [Comment Edited] (FLINK-31846) Support cancel final checkpoint when all tasks are finished

[ https://issues.apache.org/jira/browse/FLINK-31846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17714562#comment-17714562 ] Piotr Nowojski edited comment on FLINK-31846 at 4/20/23 11:47 AM:

[jira] [Commented] (FLINK-31846) Support cancel final checkpoint when all tasks are finished

[ https://issues.apache.org/jira/browse/FLINK-31846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17714562#comment-17714562 ] Piotr Nowojski commented on FLINK-31846: Hey, [~hongfanxo], your feature request

[jira] [Closed] (FLINK-31745) Performance regression on serializerHeavyString since April 3rd

[ https://issues.apache.org/jira/browse/FLINK-31745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-31745. -- Resolution: Not A Problem It just restored performance back to the level from ~12th Jan probab

[jira] [Updated] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-31757: --- Component/s: Runtime / Coordination (was: Runtime / Task) > Optimize Fl

[jira] [Commented] (FLINK-31655) Adaptive Channel selection for partitioner

[ https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711909#comment-17711909 ] Piotr Nowojski commented on FLINK-31655: I think there are ways to address probl

[jira] [Commented] (FLINK-31588) The unaligned checkpoint type is wrong at subtask level

[ https://issues.apache.org/jira/browse/FLINK-31588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709783#comment-17709783 ] Piotr Nowojski commented on FLINK-31588: Sorry for late response, I've just foun

[jira] [Updated] (FLINK-31681) Network connection timeout between operators should trigger either network re-connection or job failover

[ https://issues.apache.org/jira/browse/FLINK-31681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-31681: --- Component/s: Runtime / Network > Network connection timeout between operators should trigger

[jira] [Updated] (FLINK-31681) Network connection timeout between operators should trigger either network re-connection or job failover

[ https://issues.apache.org/jira/browse/FLINK-31681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-31681: --- Affects Version/s: 1.15.1 > Network connection timeout between operators should trigger eith

[jira] [Updated] (FLINK-29822) Fix wrong description in comments of StreamExecutionEnvironment#setMaxParallelism()

[ https://issues.apache.org/jira/browse/FLINK-29822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-29822: --- Affects Version/s: 1.18.0 > Fix wrong description in comments of > StreamExecutionEnvironme

[jira] [Closed] (FLINK-29822) Fix wrong description in comments of StreamExecutionEnvironment#setMaxParallelism()

[ https://issues.apache.org/jira/browse/FLINK-29822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-29822. -- Resolution: Fixed merged commit ea9c9d9 into apache:master Thanks [~Feifan Wang]! > Fix wron

[jira] [Updated] (FLINK-29822) Fix wrong description in comments of StreamExecutionEnvironment#setMaxParallelism()

[ https://issues.apache.org/jira/browse/FLINK-29822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-29822: --- Fix Version/s: 1.18.0 > Fix wrong description in comments of > StreamExecutionEnvironment#s

[jira] [Commented] (FLINK-31681) Network connection timeout between operators should trigger either network re-connection or job failover

[ https://issues.apache.org/jira/browse/FLINK-31681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17707203#comment-17707203 ] Piotr Nowojski commented on FLINK-31681: Which version does this issue affect? W

[jira] [Commented] (FLINK-31610) Refactoring of LocalBufferPool

[ https://issues.apache.org/jira/browse/FLINK-31610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17706904#comment-17706904 ] Piotr Nowojski commented on FLINK-31610: {{LocalBufferPool}} size can change eve

[jira] [Commented] (FLINK-30890) Backup codespeed‘s data regularly

[ https://issues.apache.org/jira/browse/FLINK-30890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17706898#comment-17706898 ] Piotr Nowojski commented on FLINK-30890: Codespeed WebUI, the database and Jenki

[jira] [Assigned] (FLINK-31660) flink-connectors-kafka ITCases are not runnable in the IDE

[ https://issues.apache.org/jira/browse/FLINK-31660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-31660: -- Assignee: Natea Eshetu Beshada > flink-connectors-kafka ITCases are not runnable in t

[jira] [Updated] (FLINK-31660) flink-connectors-kafka ITCases are not runnable in the IDE

[ https://issues.apache.org/jira/browse/FLINK-31660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-31660: --- Affects Version/s: 1.18.0 > flink-connectors-kafka ITCases are not runnable in the IDE > ---

[jira] [Commented] (FLINK-30890) Backup codespeed‘s data regularly

[ https://issues.apache.org/jira/browse/FLINK-30890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17706027#comment-17706027 ] Piotr Nowojski commented on FLINK-30890: That's neat!. As an alternative or comp

[jira] [Closed] (FLINK-31561) flink-master-regression-check is failing since March 15, 2023

[ https://issues.apache.org/jira/browse/FLINK-31561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-31561. -- Fix Version/s: 1.18.0 Resolution: Fixed Hopefully fixed by commit d797583 into flink-be

[jira] [Updated] (FLINK-30585) Improve flame graph performance at subtask level

[ https://issues.apache.org/jira/browse/FLINK-30585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-30585: --- Affects Version/s: 1.17.0 > Improve flame graph performance at subtask level > -

[jira] [Updated] (FLINK-30585) Improve flame graph performance at subtask level

[ https://issues.apache.org/jira/browse/FLINK-30585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-30585: --- Component/s: Runtime / Task Runtime / Web Frontend > Improve flame graph pe

[jira] [Updated] (FLINK-30583) Provide the flame graph to the subtask level

[ https://issues.apache.org/jira/browse/FLINK-30583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-30583: --- Fix Version/s: 1.17.0 (was: 1.18.0) > Provide the flame graph to the

[jira] [Closed] (FLINK-30583) Provide the flame graph to the subtask level

[ https://issues.apache.org/jira/browse/FLINK-30583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-30583. -- Resolution: Fixed > Provide the flame graph to the subtask level > ---

[jira] [Updated] (FLINK-30585) Improve flame graph performance at subtask level

[ https://issues.apache.org/jira/browse/FLINK-30585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-30585: --- Parent: (was: FLINK-30583) Issue Type: Improvement (was: Sub-task) > Improve fl

[jira] [Commented] (FLINK-30585) Improve flame graph performance at subtask level

[ https://issues.apache.org/jira/browse/FLINK-30585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17704039#comment-17704039 ] Piotr Nowojski commented on FLINK-30585: [~fanrui] do I understand this correctl

[jira] [Updated] (FLINK-13876) Remove ExecutionConfig field from PojoSerializer

[ https://issues.apache.org/jira/browse/FLINK-13876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-13876: --- Fix Version/s: (was: 1.18.0) > Remove ExecutionConfig field from PojoSerializer > --

[jira] [Updated] (FLINK-21871) Support watermark for Hive and Filesystem streaming source

[ https://issues.apache.org/jira/browse/FLINK-21871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-21871: --- Fix Version/s: (was: 1.18.0) > Support watermark for Hive and Filesystem streaming sourc

[jira] [Updated] (FLINK-22209) Make StreamTask#triggerCheckpointAsync return void

[ https://issues.apache.org/jira/browse/FLINK-22209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-22209: --- Fix Version/s: (was: 1.18.0) > Make StreamTask#triggerCheckpointAsync return void >

[jira] [Updated] (FLINK-25318) Improvement of scheduler and execution for Flink OLAP

[ https://issues.apache.org/jira/browse/FLINK-25318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25318: --- Fix Version/s: (was: 1.18.0) > Improvement of scheduler and execution for Flink OLAP > -

[jira] [Updated] (FLINK-22209) Make StreamTask#triggerCheckpointAsync return void

[ https://issues.apache.org/jira/browse/FLINK-22209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-22209: --- Priority: Not a Priority (was: Minor) > Make StreamTask#triggerCheckpointAsync return void

[jira] [Updated] (FLINK-24402) Add a metric for back-pressure from the ChangelogStateBackend

[ https://issues.apache.org/jira/browse/FLINK-24402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-24402: --- Priority: Not a Priority (was: Major) > Add a metric for back-pressure from the ChangelogSt

[jira] [Updated] (FLINK-24402) Add a metric for back-pressure from the ChangelogStateBackend

[ https://issues.apache.org/jira/browse/FLINK-24402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-24402: --- Fix Version/s: (was: 1.18.0) > Add a metric for back-pressure from the ChangelogStateBac

[jira] [Updated] (FLINK-24696) Translate how to configure unaligned checkpoints into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-24696: --- Fix Version/s: (was: 1.18.0) > Translate how to configure unaligned checkpoints into Chi

[jira] [Updated] (FLINK-24696) Translate how to configure unaligned checkpoints into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-24696: --- Priority: Not a Priority (was: Major) > Translate how to configure unaligned checkpoints in

[jira] [Assigned] (FLINK-24696) Translate how to configure unaligned checkpoints into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-24696: -- Assignee: (was: ZhuoYu Chen) > Translate how to configure unaligned checkpoints i

[jira] [Updated] (FLINK-25255) Expose Changelog checkpoints via State Processor API

[ https://issues.apache.org/jira/browse/FLINK-25255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25255: --- Priority: Not a Priority (was: Minor) > Expose Changelog checkpoints via State Processor AP

[jira] [Updated] (FLINK-25255) Expose Changelog checkpoints via State Processor API

[ https://issues.apache.org/jira/browse/FLINK-25255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25255: --- Fix Version/s: (was: 1.18.0) > Expose Changelog checkpoints via State Processor API > --

[jira] [Updated] (FLINK-30068) Allow users to configure what to do with errors while committing transactions during recovery in KafkaSink

[ https://issues.apache.org/jira/browse/FLINK-30068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-30068: --- Fix Version/s: (was: 1.18.0) > Allow users to configure what to do with errors while com

[jira] [Updated] (FLINK-31561) flink-master-regression-check is failing since March 15, 2023

[ https://issues.apache.org/jira/browse/FLINK-31561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-31561: --- Component/s: Benchmarks (was: Test Infrastructure) > flink-master-regre

[jira] [Updated] (FLINK-29822) Fix wrong description in comments of StreamExecutionEnvironment#setMaxParallelism()

[ https://issues.apache.org/jira/browse/FLINK-29822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-29822: --- Component/s: API / DataStream > Fix wrong description in comments of > StreamExecutionEnvir

[jira] [Assigned] (FLINK-10356) Add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

[ https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-10356: -- Assignee: Natea Eshetu Beshada > Add sanity checks to SpillingAdaptiveSpanningRecordD

[jira] [Updated] (FLINK-31414) exceptions in the alignment timer are ignored

[ https://issues.apache.org/jira/browse/FLINK-31414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-31414: --- Priority: Major (was: Critical) > exceptions in the alignment timer are ignored > -

[jira] [Closed] (FLINK-31414) exceptions in the alignment timer are ignored

[ https://issues.apache.org/jira/browse/FLINK-31414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-31414. -- Resolution: Fixed merged commit cbfeef6 to master 0dfb5abf038 to release-1.17 f2f9104dc46 to r

[jira] [Updated] (FLINK-31414) exceptions in the alignment timer are ignored

[ https://issues.apache.org/jira/browse/FLINK-31414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-31414: --- Fix Version/s: 1.18.0 > exceptions in the alignment timer are ignored >

[jira] [Assigned] (FLINK-28758) FlinkKafkaConsumer fails to stop with savepoint

[ https://issues.apache.org/jira/browse/FLINK-28758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-28758: -- Assignee: Mark Cho > FlinkKafkaConsumer fails to stop with savepoint > -

[jira] [Commented] (FLINK-28758) FlinkKafkaConsumer fails to stop with savepoint

[ https://issues.apache.org/jira/browse/FLINK-28758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17700154#comment-17700154 ] Piotr Nowojski commented on FLINK-28758: +1 to what [~dwysakowicz] wrote. This

[jira] [Updated] (FLINK-28758) FlinkKafkaConsumer fails to stop with savepoint

[ https://issues.apache.org/jira/browse/FLINK-28758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-28758: --- Component/s: (was: Runtime / Checkpointing) (was: Runtime / Task) >

[jira] [Updated] (FLINK-28758) FlinkKafkaConsumer fails to stop with savepoint

[ https://issues.apache.org/jira/browse/FLINK-28758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-28758: --- Affects Version/s: 1.16.1 1.17.0 Priority: Critical (was

[jira] [Reopened] (FLINK-28758) Failed to stop with savepoint

[ https://issues.apache.org/jira/browse/FLINK-28758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reopened FLINK-28758: > Failed to stop with savepoint > -- > > Key: FLI

[jira] [Updated] (FLINK-31414) exceptions in the alignment timer are ignored

[ https://issues.apache.org/jira/browse/FLINK-31414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-31414: --- Fix Version/s: 1.17.0 1.16.2 > exceptions in the alignment timer are igno

[jira] [Updated] (FLINK-31414) exceptions in the alignment timer are ignored

[ https://issues.apache.org/jira/browse/FLINK-31414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-31414: --- Affects Version/s: 1.16.1 1.15.3 1.14.6

[jira] [Commented] (FLINK-31414) exceptions in the alignment timer are ignored

[ https://issues.apache.org/jira/browse/FLINK-31414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17700024#comment-17700024 ] Piotr Nowojski commented on FLINK-31414: Ah thanks for the explanation, I unders

[jira] [Updated] (FLINK-31414) exceptions in the alignment timer are ignored

[ https://issues.apache.org/jira/browse/FLINK-31414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-31414: --- Priority: Critical (was: Major) > exceptions in the alignment timer are ignored > -

[jira] [Commented] (FLINK-31414) exceptions in the alignment timer are ignored

[ https://issues.apache.org/jira/browse/FLINK-31414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17699776#comment-17699776 ] Piotr Nowojski commented on FLINK-31414: [~Feifan Wang], can you elaborate a bit

[jira] [Commented] (FLINK-30583) Provide the flame graph to the subtask level

[ https://issues.apache.org/jira/browse/FLINK-30583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17693055#comment-17693055 ] Piotr Nowojski commented on FLINK-30583: Thanks for this improvement! I've just

[jira] [Commented] (FLINK-31138) Either StreamCheckpointingITCase/StreamFaultToleranceTestBase or EventTimeWindowCheckpointingITCase are timinng out

[ https://issues.apache.org/jira/browse/FLINK-31138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692056#comment-17692056 ] Piotr Nowojski commented on FLINK-31138: First about the lack of space on the de

[jira] [Updated] (FLINK-31036) StateCheckpointedITCase timed out

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-31036: --- Fix Version/s: 1.17.0 1.18.0 > StateCheckpointedITCase timed out > --

[jira] [Commented] (FLINK-31036) StateCheckpointedITCase timed out

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17690217#comment-17690217 ] Piotr Nowojski commented on FLINK-31036: {quote} So should we use the `FileSyste

[jira] [Updated] (FLINK-31036) StateCheckpointedITCase timed out

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-31036: --- Summary: StateCheckpointedITCase timed out (was: StateCheckpointedITCase timed out due to d

[jira] [Updated] (FLINK-31036) StateCheckpointedITCase timed out due to deadlock

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-31036: --- Priority: Major (was: Blocker) > StateCheckpointedITCase timed out due to deadlock > --

[jira] [Comment Edited] (FLINK-31036) StateCheckpointedITCase timed out due to deadlock

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689834#comment-17689834 ] Piotr Nowojski edited comment on FLINK-31036 at 2/16/23 4:51 PM: -

[jira] [Commented] (FLINK-31036) StateCheckpointedITCase timed out due to deadlock

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689834#comment-17689834 ] Piotr Nowojski commented on FLINK-31036: In this recent log I see three issues

[jira] [Comment Edited] (FLINK-31036) StateCheckpointedITCase timed out due to deadlock

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689697#comment-17689697 ] Piotr Nowojski edited comment on FLINK-31036 at 2/16/23 11:13 AM:

[jira] [Commented] (FLINK-31036) StateCheckpointedITCase timed out due to deadlock

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689697#comment-17689697 ] Piotr Nowojski commented on FLINK-31036: I will take a look. When trying to re

[jira] [Comment Edited] (FLINK-18235) Improve the checkpoint strategy for Python UDF execution

[ https://issues.apache.org/jira/browse/FLINK-18235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689636#comment-17689636 ] Piotr Nowojski edited comment on FLINK-18235 at 2/16/23 9:27 AM: -

[jira] [Commented] (FLINK-18235) Improve the checkpoint strategy for Python UDF execution

[ https://issues.apache.org/jira/browse/FLINK-18235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689636#comment-17689636 ] Piotr Nowojski commented on FLINK-18235: {quote} The question here is that it's

[jira] [Comment Edited] (FLINK-30251) Move the IO with DFS during abort checkpoint to an asynchronous thread.

[ https://issues.apache.org/jira/browse/FLINK-30251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688934#comment-17688934 ] Piotr Nowojski edited comment on FLINK-30251 at 2/15/23 8:43 AM: -

[jira] [Closed] (FLINK-30251) Move the IO with DFS during abort checkpoint to an asynchronous thread.

[ https://issues.apache.org/jira/browse/FLINK-30251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-30251. -- Fix Version/s: 1.18.0 Resolution: Fixed merged commit d24760b into apache:master > Mov

[jira] [Commented] (FLINK-18235) Improve the checkpoint strategy for Python UDF execution

[ https://issues.apache.org/jira/browse/FLINK-18235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688420#comment-17688420 ] Piotr Nowojski commented on FLINK-18235: Could you elaborate why would it be imp

[jira] [Created] (FLINK-31045) In IntelliJ: flink-clients cannot find symbol symbol: class TestUserClassLoaderJobLib

Piotr Nowojski created FLINK-31045: -- Summary: In IntelliJ: flink-clients cannot find symbol symbol: class TestUserClassLoaderJobLib Key: FLINK-31045 URL: https://issues.apache.org/jira/browse/FLINK-31045

[jira] [Commented] (FLINK-18235) Improve the checkpoint strategy for Python UDF execution

[ https://issues.apache.org/jira/browse/FLINK-18235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687936#comment-17687936 ] Piotr Nowojski commented on FLINK-18235: Thanks for the explanation [~dian.fu].

[jira] [Commented] (FLINK-29825) Improve benchmark stability

[ https://issues.apache.org/jira/browse/FLINK-29825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687143#comment-17687143 ] Piotr Nowojski commented on FLINK-29825: Yes, that's a good idea :) > Improve b

[jira] [Assigned] (FLINK-18235) Improve the checkpoint strategy for Python UDF execution

[ https://issues.apache.org/jira/browse/FLINK-18235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-18235: -- Assignee: (was: Dian Fu) > Improve the checkpoint strategy for Python UDF executi

[jira] [Updated] (FLINK-18235) Improve the checkpoint strategy for Python UDF execution

[ https://issues.apache.org/jira/browse/FLINK-18235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-18235: --- Priority: Not a Priority (was: Major) > Improve the checkpoint strategy for Python UDF exec

[jira] [Commented] (FLINK-18235) Improve the checkpoint strategy for Python UDF execution

[ https://issues.apache.org/jira/browse/FLINK-18235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687102#comment-17687102 ] Piotr Nowojski commented on FLINK-18235: [~dianfu], may I ask if you have consid

[jira] [Commented] (FLINK-29825) Improve benchmark stability

[ https://issues.apache.org/jira/browse/FLINK-29825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687098#comment-17687098 ] Piotr Nowojski commented on FLINK-29825: Thanks a lot for the very detailed comp

[jira] [Commented] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint

[ https://issues.apache.org/jira/browse/FLINK-30238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17686629#comment-17686629 ] Piotr Nowojski commented on FLINK-30238: [~gaoyunhaii], thanks for the explanati

[jira] [Closed] (FLINK-29856) Triggering savepoint does not trigger operator notifyCheckpointComplete

[ https://issues.apache.org/jira/browse/FLINK-29856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-29856. -- Resolution: Not A Bug > Triggering savepoint does not trigger operator notifyCheckpointComplet

[jira] [Closed] (FLINK-27571) Recognize "less is better" benchmarks in regression detection script

[ https://issues.apache.org/jira/browse/FLINK-27571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-27571. -- Fix Version/s: 1.17.0 Resolution: Fixed merged commit b21a946 into apache:master > Rec

[jira] [Comment Edited] (FLINK-29825) Improve benchmark stability

[ https://issues.apache.org/jira/browse/FLINK-29825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17685367#comment-17685367 ] Piotr Nowojski edited comment on FLINK-29825 at 2/7/23 4:06 PM: --

[jira] [Comment Edited] (FLINK-29825) Improve benchmark stability

[ https://issues.apache.org/jira/browse/FLINK-29825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17685367#comment-17685367 ] Piotr Nowojski edited comment on FLINK-29825 at 2/7/23 4:05 PM: --

[jira] [Comment Edited] (FLINK-29825) Improve benchmark stability

[ https://issues.apache.org/jira/browse/FLINK-29825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17685367#comment-17685367 ] Piotr Nowojski edited comment on FLINK-29825 at 2/7/23 3:59 PM: --

[jira] [Comment Edited] (FLINK-29825) Improve benchmark stability

[ https://issues.apache.org/jira/browse/FLINK-29825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17685367#comment-17685367 ] Piotr Nowojski edited comment on FLINK-29825 at 2/7/23 3:58 PM: --

[jira] [Commented] (FLINK-29825) Improve benchmark stability

[ https://issues.apache.org/jira/browse/FLINK-29825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17685367#comment-17685367 ] Piotr Nowojski commented on FLINK-29825: Thanks for the investigation [~Yanfei L

[jira] [Comment Edited] (FLINK-29825) Improve benchmark stability

[ https://issues.apache.org/jira/browse/FLINK-29825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17684677#comment-17684677 ] Piotr Nowojski edited comment on FLINK-29825 at 2/6/23 1:29 PM: --

[jira] [Commented] (FLINK-29825) Improve benchmark stability

[ https://issues.apache.org/jira/browse/FLINK-29825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17684677#comment-17684677 ] Piotr Nowojski commented on FLINK-29825: I have responded on the dev mailing lis

[jira] [Closed] (FLINK-30625) Performance regression in tumblingWindow on 06.01.2023

[ https://issues.apache.org/jira/browse/FLINK-30625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-30625. -- Resolution: Duplicate It looks like the performance regression has been fixed after merging F

<    1   2   3   4   5   6   7   8   9   10   >