[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

[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=17711909#comment-17711909 ] Piotr Nowojski commented on FLINK-31655: I think there are ways to address problems with

[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=17709783#comment-17709783 ] Piotr Nowojski commented on FLINK-31588: Sorry for late response, I've just found an old tab

[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

[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

[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 >

[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

[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 >

[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=17707203#comment-17707203 ] Piotr Nowojski commented on FLINK-31681: Which version does this issue affect? Why doesn't

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

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

[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=17706898#comment-17706898 ] Piotr Nowojski commented on FLINK-30890: Codespeed WebUI, the database and Jenkins are hosted on

[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

[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=17706027#comment-17706027 ] Piotr Nowojski commented on FLINK-30890: That's neat!. As an alternative or complementary

[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

[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

[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

[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=17704039#comment-17704039 ] Piotr Nowojski commented on FLINK-30585: [~fanrui] do I understand this correctly? Is this just

[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

[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

[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

[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

[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

[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

[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

[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

[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) >

[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 >

[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

[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

[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=17700154#comment-17700154 ] Piotr Nowojski commented on FLINK-28758: +1 to what [~dwysakowicz] wrote. This might be caused

[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

[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:

[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

[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=17700024#comment-17700024 ] Piotr Nowojski commented on FLINK-31414: Ah thanks for the explanation, I understand the problem

[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=17699776#comment-17699776 ] Piotr Nowojski commented on FLINK-31414: [~Feifan Wang], can you elaborate a bit more what's the

[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=17693055#comment-17693055 ] Piotr Nowojski commented on FLINK-30583: Thanks for this improvement! I've just found it in the

[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=17692056#comment-17692056 ] Piotr Nowojski commented on FLINK-31138: First about the lack of space on the device. Hasn't

[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=17690217#comment-17690217 ] Piotr Nowojski commented on FLINK-31036: {quote} So should we use the

[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

[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=17689834#comment-17689834 ] Piotr Nowojski edited comment on FLINK-31036 at 2/16/23 4:51 PM: - In

[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=17689834#comment-17689834 ] Piotr Nowojski commented on FLINK-31036: In this recent log I see three issues 1. {{checkpoint

[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=17689697#comment-17689697 ] Piotr Nowojski edited comment on FLINK-31036 at 2/16/23 11:13 AM: -- I

[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=17689697#comment-17689697 ] Piotr Nowojski commented on FLINK-31036: I will take a look. When trying to reproduce it

[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=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=17689636#comment-17689636 ] Piotr Nowojski commented on FLINK-18235: {quote} The question here is that it's difficult for

[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=17688934#comment-17688934 ] Piotr Nowojski edited comment on FLINK-30251 at 2/15/23 8:43 AM: - Note,

[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 >

[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=17688420#comment-17688420 ] Piotr Nowojski commented on FLINK-18235: Could you elaborate why would it be impossible? For

[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=17687936#comment-17687936 ] Piotr Nowojski commented on FLINK-18235: Thanks for the explanation [~dian.fu]. I haven't

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

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

[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

[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

[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=17687102#comment-17687102 ] Piotr Nowojski commented on FLINK-18235: [~dianfu], may I ask if you have considered

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

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

[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=17686629#comment-17686629 ] Piotr Nowojski commented on FLINK-30238: [~gaoyunhaii], thanks for the explanation, but I'm

[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

[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 >

[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=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=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=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=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=17685367#comment-17685367 ] Piotr Nowojski commented on FLINK-29825: Thanks for the investigation [~Yanfei Lei]. As I said,

[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=17684677#comment-17684677 ] Piotr Nowojski edited comment on FLINK-29825 at 2/6/23 1:29 PM: I have

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

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

[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

[jira] [Closed] (FLINK-30623) Performance regression in checkpointSingleInput.UNALIGNED on 04.01.2023

[ https://issues.apache.org/jira/browse/FLINK-30623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-30623. -- Resolution: Fixed Ok, let's keep it as it is. Thanks [~fanrui]  > Performance regression in

[jira] [Comment Edited] (FLINK-30623) Performance regression in checkpointSingleInput.UNALIGNED on 04.01.2023

[ https://issues.apache.org/jira/browse/FLINK-30623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17682121#comment-17682121 ] Piotr Nowojski edited comment on FLINK-30623 at 1/30/23 2:38 PM: - Thanks

[jira] [Comment Edited] (FLINK-30623) Performance regression in checkpointSingleInput.UNALIGNED on 04.01.2023

[ https://issues.apache.org/jira/browse/FLINK-30623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17682121#comment-17682121 ] Piotr Nowojski edited comment on FLINK-30623 at 1/30/23 2:38 PM: - Thanks

[jira] [Commented] (FLINK-30623) Performance regression in checkpointSingleInput.UNALIGNED on 04.01.2023

[ https://issues.apache.org/jira/browse/FLINK-30623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17682121#comment-17682121 ] Piotr Nowojski commented on FLINK-30623: Thanks for the analysis [~fanrui] ! {quote}  It means

[jira] [Commented] (FLINK-30709) NetworkInput#emitNext() should push records to DataOutput in a while loop

[ https://issues.apache.org/jira/browse/FLINK-30709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17681280#comment-17681280 ] Piotr Nowojski commented on FLINK-30709: [~lindong] , good reminder about "This closes", but

[jira] [Closed] (FLINK-15550) testCancelTaskExceptionAfterTaskMarkedFailed failed on azure

[ https://issues.apache.org/jira/browse/FLINK-15550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-15550. -- Fix Version/s: 1.17.0 Resolution: Fixed Another fix merged to master as

[jira] [Closed] (FLINK-26082) CancelPartitionRequestTest.testDuplicateCancel failed on azure due to bind failed

[ https://issues.apache.org/jira/browse/FLINK-26082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-26082. -- Fix Version/s: 1.17.0 Resolution: Fixed Merged to master as 2b5fe306114..952c7831e74

[jira] [Commented] (FLINK-30727) JoinReorderITCase.testBushyTreeJoinReorder failed due to IOException

[ https://issues.apache.org/jira/browse/FLINK-30727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17681248#comment-17681248 ] Piotr Nowojski commented on FLINK-30727:

[jira] [Commented] (FLINK-30709) NetworkInput#emitNext() should push records to DataOutput in a while loop

[ https://issues.apache.org/jira/browse/FLINK-30709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17681247#comment-17681247 ] Piotr Nowojski commented on FLINK-30709: Merged to master as f6c7c30118e^ and f6c7c30118e

[jira] [Commented] (FLINK-30623) Performance regression in checkpointSingleInput.UNALIGNED on 04.01.2023

[ https://issues.apache.org/jira/browse/FLINK-30623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17681237#comment-17681237 ] Piotr Nowojski commented on FLINK-30623: Thanks! > Performance regression in

[jira] [Assigned] (FLINK-30623) Performance regression in checkpointSingleInput.UNALIGNED on 04.01.2023

[ https://issues.apache.org/jira/browse/FLINK-30623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-30623: -- Assignee: Rui Fan > Performance regression in checkpointSingleInput.UNALIGNED on

[jira] [Comment Edited] (FLINK-30623) Performance regression in checkpointSingleInput.UNALIGNED on 04.01.2023

[ https://issues.apache.org/jira/browse/FLINK-30623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17681102#comment-17681102 ] Piotr Nowojski edited comment on FLINK-30623 at 1/26/23 8:00 PM: - It

[jira] [Reopened] (FLINK-30623) Performance regression in checkpointSingleInput.UNALIGNED on 04.01.2023

[ https://issues.apache.org/jira/browse/FLINK-30623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reopened FLINK-30623: Assignee: (was: Rui Fan) > Performance regression in

[jira] [Commented] (FLINK-30623) Performance regression in checkpointSingleInput.UNALIGNED on 04.01.2023

[ https://issues.apache.org/jira/browse/FLINK-30623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17681102#comment-17681102 ] Piotr Nowojski commented on FLINK-30623: It seems like everything has been fixed?

[jira] [Closed] (FLINK-30791) Codespeed machine is not responding

[ https://issues.apache.org/jira/browse/FLINK-30791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-30791. -- Thanks! > Codespeed machine is not responding > --- > >

[jira] [Updated] (FLINK-30791) Codespeed machine is not responding

[ https://issues.apache.org/jira/browse/FLINK-30791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-30791: --- Description: Neither speedcenter: [http://codespeed.dak8s.net:8000/] nor jenkins:

[jira] [Created] (FLINK-30791) Codespeed machine is not responding

Piotr Nowojski created FLINK-30791: -- Summary: Codespeed machine is not responding Key: FLINK-30791 URL: https://issues.apache.org/jira/browse/FLINK-30791 Project: Flink Issue Type: Bug

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