[jira] [Updated] (FLINK-30852) TaskTest.testCleanupWhenSwitchToInitializationFails reports AssertionError but doesn't fail

2023-04-21 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-30852: -- Fix Version/s: 1.17.1 > TaskTest.testCleanupWhenSwitchToInitializationFails reports

[jira] [Resolved] (FLINK-30852) TaskTest.testCleanupWhenSwitchToInitializationFails reports AssertionError but doesn't fail

2023-04-21 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov resolved FLINK-30852. --- Resolution: Fixed > TaskTest.testCleanupWhenSwitchToInitializationFails reports

[jira] [Commented] (FLINK-30852) TaskTest.testCleanupWhenSwitchToInitializationFails reports AssertionError but doesn't fail

2023-04-21 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714961#comment-17714961 ] Anton Kalashnikov commented on FLINK-30852: --- merged to release-1.17:

[jira] [Commented] (FLINK-30852) TaskTest.testCleanupWhenSwitchToInitializationFails reports AssertionError but doesn't fail

2023-04-20 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714611#comment-17714611 ] Anton Kalashnikov commented on FLINK-30852: --- Yeh, sorry, I missed up with versions. I will

[jira] [Assigned] (FLINK-30852) TaskTest.testCleanupWhenSwitchToInitializationFails reports AssertionError but doesn't fail

2023-04-20 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-30852: - Assignee: Anton Kalashnikov (was: Anton Kalashnikov) >

[jira] [Closed] (FLINK-30852) TaskTest.testCleanupWhenSwitchToInitializationFails reports AssertionError but doesn't fail

2023-04-14 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov closed FLINK-30852. - Fix Version/s: 1.17.1 Resolution: Fixed >

[jira] [Commented] (FLINK-30852) TaskTest.testCleanupWhenSwitchToInitializationFails reports AssertionError but doesn't fail

2023-04-14 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712398#comment-17712398 ] Anton Kalashnikov commented on FLINK-30852: --- merged to master: a6f0165c >

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

2023-04-13 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711950#comment-17711950 ] Anton Kalashnikov commented on FLINK-31655: --- ??I wonder why the implementation in the pull

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

2023-04-11 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17710956#comment-17710956 ] Anton Kalashnikov commented on FLINK-31655: --- Hi [~tartarus] thanks for this discussion. I

[jira] [Commented] (FLINK-30844) TaskTest.testInterruptibleSharedLockInInvokeAndCancel causes a JVM shutdown with exit code 239

2023-04-06 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17709423#comment-17709423 ] Anton Kalashnikov commented on FLINK-30844: --- In conclusion, I haven't found any deadlocks or

[jira] [Closed] (FLINK-30844) TaskTest.testInterruptibleSharedLockInInvokeAndCancel causes a JVM shutdown with exit code 239

2023-04-06 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov closed FLINK-30844. - Resolution: Fixed > TaskTest.testInterruptibleSharedLockInInvokeAndCancel causes a JVM

[jira] [Updated] (FLINK-30844) TaskTest.testInterruptibleSharedLockInInvokeAndCancel causes a JVM shutdown with exit code 239

2023-04-06 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-30844: -- Fix Version/s: 1.17.1 > TaskTest.testInterruptibleSharedLockInInvokeAndCancel causes

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

2023-03-28 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706028#comment-17706028 ] Anton Kalashnikov commented on FLINK-31610: --- ??Consider such a scenario, the CurrentPoolSize =

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

2023-03-24 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17704604#comment-17704604 ] Anton Kalashnikov commented on FLINK-31610: --- [~Weijie Guo], [~fanrui], What do you think about

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

2023-03-24 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-31610: - Summary: Refactoring of LocalBufferPool Key: FLINK-31610 URL: https://issues.apache.org/jira/browse/FLINK-31610 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-13871) Consolidate isRunning, canceled, isFinished fields in StreamTask and SourceStreamTask

2023-02-17 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-13871: - Assignee: Panagiotis Garefalakis > Consolidate isRunning, canceled, isFinished

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

2023-02-17 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov closed FLINK-15550. - Fix Version/s: 1.16.2 Resolution: Fixed >

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

2023-02-17 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690444#comment-17690444 ] Anton Kalashnikov commented on FLINK-15550: --- Merged to release-1.16: 658ba8eb, a3c9eb40,

[jira] [Assigned] (FLINK-30844) TaskTest.testInterruptibleSharedLockInInvokeAndCancel causes a JVM shutdown with exit code 239

2023-02-07 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-30844: - Assignee: Anton Kalashnikov >

[jira] [Commented] (FLINK-30844) TaskTest.testInterruptibleSharedLockInInvokeAndCancel causes a JVM shutdown with exit code 239

2023-01-31 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17682686#comment-17682686 ] Anton Kalashnikov commented on FLINK-30844: --- I don't see a problem here. I just see that the

[jira] [Commented] (FLINK-30852) TaskTest.testCleanupWhenSwitchToInitializationFails reports AssertionError but doesn't fail

2023-01-31 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17682595#comment-17682595 ] Anton Kalashnikov commented on FLINK-30852: --- Oh, It is not the correct test. It actually

[jira] [Assigned] (FLINK-30852) TaskTest.testCleanupWhenSwitchToInitializationFails reports AssertionError but doesn't fail

2023-01-31 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-30852: - Assignee: Anton Kalashnikov >

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

2023-01-26 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-15550: - Assignee: Anton Kalashnikov > testCancelTaskExceptionAfterTaskMarkedFailed

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

2023-01-25 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-26082: - Assignee: Anton Kalashnikov > CancelPartitionRequestTest.testDuplicateCancel

[jira] [Commented] (FLINK-22137) Execute unaligned checkpoint test on a cluster

2023-01-24 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17680263#comment-17680263 ] Anton Kalashnikov commented on FLINK-22137: --- I don't remember why we didn't close this ticket.

[jira] [Commented] (FLINK-28766) UnalignedCheckpointStressITCase.runStressTest failed with NoSuchFileException

2022-12-07 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644232#comment-17644232 ] Anton Kalashnikov commented on FLINK-28766: --- [~mapohl] , thanks for creating the backport.

[jira] [Updated] (FLINK-30278) Unexpected config mutation in SinkTransformationTranslator

2022-12-02 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-30278: -- Description: If we forbid changing configuration

[jira] [Created] (FLINK-30278) Unexpected config mutation in SinkTransformationTranslator

2022-12-02 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-30278: - Summary: Unexpected config mutation in SinkTransformationTranslator Key: FLINK-30278 URL: https://issues.apache.org/jira/browse/FLINK-30278 Project: Flink

[jira] [Assigned] (FLINK-28766) UnalignedCheckpointStressITCase.runStressTest failed with NoSuchFileException

2022-09-19 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-28766: - Assignee: Anton Kalashnikov > UnalignedCheckpointStressITCase.runStressTest

[jira] [Commented] (FLINK-28766) UnalignedCheckpointStressITCase.runStressTest failed with NoSuchFileException

2022-09-19 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606586#comment-17606586 ] Anton Kalashnikov commented on FLINK-28766: --- [~martijnvisser], I will take a look >

[jira] [Assigned] (FLINK-28468) Creating benchmark channel in Apache Flink slack

2022-07-08 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-28468: - Assignee: Anton Kalashnikov > Creating benchmark channel in Apache Flink slack

[jira] [Created] (FLINK-28468) Creating benchmark channel in Apache Flink slack

2022-07-08 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-28468: - Summary: Creating benchmark channel in Apache Flink slack Key: FLINK-28468 URL: https://issues.apache.org/jira/browse/FLINK-28468 Project: Flink

[jira] [Assigned] (FLINK-28407) Make Jenkins benchmark script more autonomous

2022-07-05 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-28407: - Assignee: Anton Kalashnikov > Make Jenkins benchmark script more autonomous >

[jira] [Created] (FLINK-28407) Make Jenkins benchmark script more autonomous

2022-07-05 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-28407: - Summary: Make Jenkins benchmark script more autonomous Key: FLINK-28407 URL: https://issues.apache.org/jira/browse/FLINK-28407 Project: Flink

[jira] [Commented] (FLINK-27162) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed on azure

2022-07-01 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561400#comment-17561400 ] Anton Kalashnikov commented on FLINK-27162: --- >From FLINK-28328:

[jira] [Closed] (FLINK-28328) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed with IllegalStateException

2022-07-01 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov closed FLINK-28328. - Resolution: Duplicate [~martijnvisser] thanks to ask me. It is indeed the same problem

[jira] [Commented] (FLINK-28243) Considering only time of targeted operation for calculation benchmarks performance

2022-06-24 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17558494#comment-17558494 ] Anton Kalashnikov commented on FLINK-28243: --- FLINK-28241should be reverted as soon as this

[jira] [Commented] (FLINK-27921) Introduce the checkResourceRequirementsWithDelay in DeclarativeSlotManager

2022-06-24 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17558429#comment-17558429 ] Anton Kalashnikov commented on FLINK-27921: --- I have created the following tickets:

[jira] [Updated] (FLINK-28241) Massive regression on 20.06.2021

2022-06-24 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-28241: -- Component/s: Benchmarks > Massive regression on 20.06.2021 >

[jira] [Created] (FLINK-28243) Considering only time of targeted operation for calculation benchmarks performance

2022-06-24 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-28243: - Summary: Considering only time of targeted operation for calculation benchmarks performance Key: FLINK-28243 URL: https://issues.apache.org/jira/browse/FLINK-28243

[jira] [Assigned] (FLINK-28241) Massive regression on 20.06.2021

2022-06-24 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-28241: - Assignee: Anton Kalashnikov > Massive regression on 20.06.2021 >

[jira] [Created] (FLINK-28241) Massive regression on 20.06.2021

2022-06-24 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-28241: - Summary: Massive regression on 20.06.2021 Key: FLINK-28241 URL: https://issues.apache.org/jira/browse/FLINK-28241 Project: Flink Issue Type: Bug

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

2022-06-23 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-15550: - Assignee: Anton Kalashnikov > testCancelTaskExceptionAfterTaskMarkedFailed

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

2022-06-23 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-15550: - Assignee: (was: Anton Kalashnikov) >

[jira] [Commented] (FLINK-27921) Introduce the checkResourceRequirementsWithDelay in DeclarativeSlotManager

2022-06-23 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557990#comment-17557990 ] Anton Kalashnikov commented on FLINK-27921: --- As I see at least in asyncWait benchmark, it

[jira] [Commented] (FLINK-27921) Introduce the checkResourceRequirementsWithDelay in DeclarativeSlotManager

2022-06-23 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557893#comment-17557893 ] Anton Kalashnikov commented on FLINK-27921: --- [~aitozi], [~guoyangze], This task caused a huge

[jira] [Commented] (FLINK-25454) Negative time in throughput calculator

2022-06-16 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17555095#comment-17555095 ] Anton Kalashnikov commented on FLINK-25454: --- I will take a look > Negative time in throughput

[jira] [Updated] (FLINK-26993) CheckpointCoordinatorTest#testMinCheckpointPause

2022-06-01 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-26993: -- Affects Version/s: 1.15.0 > CheckpointCoordinatorTest#testMinCheckpointPause >

[jira] [Closed] (FLINK-27216) CheckpointCoordinatorTest.testMinCheckpointPause failed on azure

2022-06-01 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov closed FLINK-27216. - Resolution: Duplicate > CheckpointCoordinatorTest.testMinCheckpointPause failed on

[jira] [Commented] (FLINK-26993) CheckpointCoordinatorTest#testMinCheckpointPause

2022-06-01 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17544930#comment-17544930 ] Anton Kalashnikov commented on FLINK-26993: --- [~chesnay]. The release-1.15 is also affected by

[jira] [Assigned] (FLINK-27216) CheckpointCoordinatorTest.testMinCheckpointPause failed on azure

2022-06-01 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-27216: - Assignee: Anton Kalashnikov > CheckpointCoordinatorTest.testMinCheckpointPause

[jira] [Commented] (FLINK-27556) Performance regression in checkpointSingleInput.UNALIGNED on 29.04.2022

2022-05-19 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17539482#comment-17539482 ] Anton Kalashnikov commented on FLINK-27556: --- [~roman], as I can see the cause of this

[jira] [Commented] (FLINK-27031) ChangelogRescalingITCase.test failed due to IllegalStateException

2022-05-19 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17539477#comment-17539477 ] Anton Kalashnikov commented on FLINK-27031: --- As I can see we setup Virtual Channels inside

[jira] [Assigned] (FLINK-27162) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed on azure

2022-05-18 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-27162: - Assignee: Anton Kalashnikov >

[jira] [Commented] (FLINK-27556) Performance regression in checkpointSingleInput.UNALIGNED on 29.04.2022

2022-05-09 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17533795#comment-17533795 ] Anton Kalashnikov commented on FLINK-27556: --- I will take a look > Performance regression in

[jira] [Commented] (FLINK-26762) Add the overdraft buffer in BufferPool to reduce unaligned checkpoint being blocked

2022-04-26 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17528210#comment-17528210 ] Anton Kalashnikov commented on FLINK-26762: --- [~fanrui], thanks for your PR. I took a look at

[jira] [Commented] (FLINK-27165) Benchmark test SerializationFrameworkMiniBenchmarks#serializerHeavyString became unstable

2022-04-26 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17528147#comment-17528147 ] Anton Kalashnikov commented on FLINK-27165: --- I have checked this. As I see, FLINK-25402

[jira] [Commented] (FLINK-26970) Fix comment style error

2022-04-25 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527571#comment-17527571 ] Anton Kalashnikov commented on FLINK-26970: --- [~codingcaproni] , Can we close this ticket? (as

[jira] [Commented] (FLINK-26586) FileSystem uses unbuffered read I/O

2022-04-21 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17525783#comment-17525783 ] Anton Kalashnikov commented on FLINK-26586: --- [~Matthias Schwalbe] , Why do you think buffering

[jira] [Commented] (FLINK-26762) Add the overdraft buffer in BufferPool to reduce unaligned checkpoint being blocked

2022-04-20 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524922#comment-17524922 ] Anton Kalashnikov commented on FLINK-26762: --- ??Does this mean that the effective size is only

[jira] [Commented] (FLINK-26762) Add the overdraft buffer in BufferPool to reduce unaligned checkpoint being blocked

2022-04-19 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524271#comment-17524271 ] Anton Kalashnikov commented on FLINK-26762: --- First of all, no rush is needed to implement this

[jira] [Commented] (FLINK-26762) Add the overdraft buffer in BufferPool to reduce unaligned checkpoint being blocked

2022-04-19 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524228#comment-17524228 ] Anton Kalashnikov commented on FLINK-26762: --- Thanks for such a fast job. I will take a look at

[jira] [Commented] (FLINK-26586) FileSystem uses unbuffered read I/O

2022-04-19 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524217#comment-17524217 ] Anton Kalashnikov commented on FLINK-26586: --- According to the test, it is not a problem you

[jira] [Commented] (FLINK-26803) Merge small ChannelState file for Unaligned Checkpoint

2022-04-14 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522333#comment-17522333 ] Anton Kalashnikov commented on FLINK-26803: --- Yep, I know that

[jira] [Commented] (FLINK-26803) Merge small ChannelState file for Unaligned Checkpoint

2022-04-14 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522261#comment-17522261 ] Anton Kalashnikov commented on FLINK-26803: --- [~fanrui], thanks for this idea. I did some

[jira] [Commented] (FLINK-26586) FileSystem uses unbuffered read I/O

2022-04-13 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521637#comment-17521637 ] Anton Kalashnikov commented on FLINK-26586: --- [~Matthias Schwalbe], big thanks for reporting

[jira] [Commented] (FLINK-26762) Add the overdraft buffer in BufferPool to reduce unaligned checkpoint being blocked

2022-04-12 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521184#comment-17521184 ] Anton Kalashnikov commented on FLINK-26762: --- We definitely can ignore buffer debloating for

[jira] [Assigned] (FLINK-26762) Add the overdraft buffer in BufferPool to reduce unaligned checkpoint being blocked

2022-04-12 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-26762: - Assignee: fanrui > Add the overdraft buffer in BufferPool to reduce unaligned

[jira] [Commented] (FLINK-27165) Benchmark test SerializationFrameworkMiniBenchmarks#serializerHeavyString became unstable

2022-04-11 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520914#comment-17520914 ] Anton Kalashnikov commented on FLINK-27165: --- I can try to take a look. But I don't see that it

[jira] [Commented] (FLINK-26762) Add the overdraft buffer in BufferPool to reduce unaligned checkpoint being blocked

2022-04-07 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17518862#comment-17518862 ] Anton Kalashnikov commented on FLINK-26762: --- [~fanrui], Thanks for your proposal. It looks

[jira] [Updated] (FLINK-27042) StreamTaskTest#testMailboxMetricsScheduling is unstable

2022-04-04 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-27042: -- Fix Version/s: (was: 1.15.1) > StreamTaskTest#testMailboxMetricsScheduling is

[jira] [Updated] (FLINK-27042) StreamTaskTest#testMailboxMetricsScheduling is unstable

2022-04-04 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-27042: -- Affects Version/s: 1.16.0 (was: 1.15.0) >

[jira] [Assigned] (FLINK-27042) StreamTaskTest#testMailboxMetricsScheduling is unstable

2022-04-04 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-27042: - Assignee: Sebastian Mattheis > StreamTaskTest#testMailboxMetricsScheduling is

[jira] [Commented] (FLINK-26882) Unaligned checkpoint with 0s timeout would fail RescaleCheckpointManuallyITCase

2022-03-30 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17514576#comment-17514576 ] Anton Kalashnikov commented on FLINK-26882: --- Thanks for the feedback, as a result, I think I

[jira] [Assigned] (FLINK-26882) Unaligned checkpoint with 0s timeout would fail RescaleCheckpointManuallyITCase

2022-03-30 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-26882: - Assignee: Yun Tang (was: Anton Kalashnikov) > Unaligned checkpoint with 0s

[jira] [Commented] (FLINK-26882) Unaligned checkpoint with 0s timeout would fail RescaleCheckpointManuallyITCase

2022-03-30 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17514513#comment-17514513 ] Anton Kalashnikov commented on FLINK-26882: --- My bad. You are right about states in

[jira] [Commented] (FLINK-26882) Unaligned checkpoint with 0s timeout would fail RescaleCheckpointManuallyITCase

2022-03-29 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17514214#comment-17514214 ] Anton Kalashnikov commented on FLINK-26882: --- Some conclusions: First of all, this test didn't

[jira] [Assigned] (FLINK-26882) Unaligned checkpoint with 0s timeout would fail RescaleCheckpointManuallyITCase

2022-03-29 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-26882: - Assignee: Anton Kalashnikov > Unaligned checkpoint with 0s timeout would fail

[jira] [Closed] (FLINK-25246) Make benchmarks runnable on Java 11

2022-03-21 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov closed FLINK-25246. - Resolution: Fixed > Make benchmarks runnable on Java 11 >

[jira] [Commented] (FLINK-25246) Make benchmarks runnable on Java 11

2022-03-21 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509890#comment-17509890 ] Anton Kalashnikov commented on FLINK-25246: --- I forgot to leave the feedback. I compared java8

[jira] [Updated] (FLINK-25246) Make benchmarks runnable on Java 11

2022-03-21 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-25246: -- Attachment: Benchamrks Java8 vs Java11 - benchmarks.csv > Make benchmarks runnable on

[jira] [Commented] (FLINK-26106) BoundedSourceITCase failed due to JVM exits with code 239

2022-03-10 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504397#comment-17504397 ] Anton Kalashnikov commented on FLINK-26106: --- The cause: {noformat} 03:50:15,237

[jira] [Assigned] (FLINK-26106) BoundedSourceITCase failed due to JVM exits with code 239

2022-03-10 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-26106: - Assignee: Anton Kalashnikov > BoundedSourceITCase failed due to JVM exits with

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

2022-03-10 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504321#comment-17504321 ] Anton Kalashnikov commented on FLINK-15550: --- Extra logs were added to all branches since the

[jira] [Commented] (FLINK-25819) NetworkBufferPoolTest.testIsAvailableOrNotAfterRequestAndRecycleMultiSegments fails on AZP

2022-03-09 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503435#comment-17503435 ] Anton Kalashnikov commented on FLINK-25819: --- [~dwysakowicz] , yes, sure. PR -

[jira] [Assigned] (FLINK-26501) Quickstarts Scala nightly end-to-end test failed on azure due to checkponts failed and logs contains exceptions

2022-03-07 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-26501: - Assignee: Anton Kalashnikov > Quickstarts Scala nightly end-to-end test failed

[jira] [Commented] (FLINK-25958) OOME Checkpoints & Savepoints were shown as COMPLETE in Flink UI

2022-03-03 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500914#comment-17500914 ] Anton Kalashnikov commented on FLINK-25958: --- merge to master between:

[jira] [Closed] (FLINK-25958) OOME Checkpoints & Savepoints were shown as COMPLETE in Flink UI

2022-03-03 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov closed FLINK-25958. - Resolution: Fixed > OOME Checkpoints & Savepoints were shown as COMPLETE in Flink UI >

[jira] [Updated] (FLINK-25958) OOME Checkpoints & Savepoints were shown as COMPLETE in Flink UI

2022-03-03 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-25958: -- Fix Version/s: 1.15.0 > OOME Checkpoints & Savepoints were shown as COMPLETE in Flink

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

2022-03-01 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-15550: -- Affects Version/s: 1.13.6 > testCancelTaskExceptionAfterTaskMarkedFailed failed on

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

2022-03-01 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499634#comment-17499634 ] Anton Kalashnikov commented on FLINK-15550: --- from FLINK-26271

[jira] [Closed] (FLINK-26271) TaskTest.testCancelTaskExceptionAfterTaskMarkedFailed

2022-03-01 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov closed FLINK-26271. - Resolution: Duplicate > TaskTest.testCancelTaskExceptionAfterTaskMarkedFailed >

[jira] [Assigned] (FLINK-26271) TaskTest.testCancelTaskExceptionAfterTaskMarkedFailed

2022-03-01 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-26271: - Assignee: Anton Kalashnikov >

[jira] [Updated] (FLINK-26325) Add test coverage for native format State Processor API

2022-02-23 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-26325: -- Parent: FLINK-26326 Issue Type: Sub-task (was: Improvement) > Add test

[jira] [Updated] (FLINK-26325) Add test coverage for native format State Processor API

2022-02-23 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-26325: -- Parent: (was: FLINK-25276) Issue Type: Improvement (was: Sub-task) > Add

[jira] [Created] (FLINK-26326) FLIP-203: Support native and incremental savepoints 1.1

2022-02-23 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-26326: - Summary: FLIP-203: Support native and incremental savepoints 1.1 Key: FLINK-26326 URL: https://issues.apache.org/jira/browse/FLINK-26326 Project: Flink

[jira] [Created] (FLINK-26325) Add test coverage for native format State Processor API

2022-02-23 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-26325: - Summary: Add test coverage for native format State Processor API Key: FLINK-26325 URL: https://issues.apache.org/jira/browse/FLINK-26325 Project: Flink

[jira] [Commented] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist"

2022-02-22 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496036#comment-17496036 ] Anton Kalashnikov commented on FLINK-24119: --- The same problem for

[jira] [Assigned] (FLINK-25833) FlinkUserCodeClassLoader is not registered as parallel capable

2022-02-21 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-25833: - Assignee: Anton Kalashnikov > FlinkUserCodeClassLoader is not registered as

[jira] [Assigned] (FLINK-25819) NetworkBufferPoolTest.testIsAvailableOrNotAfterRequestAndRecycleMultiSegments fails on AZP

2022-02-21 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-25819: - Assignee: Anton Kalashnikov >

  1   2   3   4   >