[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] [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] [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] [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] [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] [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] [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] [Created] (FLINK-26134) Document checkpoint/savepoint guarantees

2022-02-14 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-26134: - Summary: Document checkpoint/savepoint guarantees Key: FLINK-26134 URL: https://issues.apache.org/jira/browse/FLINK-26134 Project: Flink Issue

[jira] [Created] (FLINK-26130) Document why and when user would like to increase network buffer size

2022-02-14 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-26130: - Summary: Document why and when user would like to increase network buffer size Key: FLINK-26130 URL: https://issues.apache.org/jira/browse/FLINK-26130

[jira] [Created] (FLINK-26002) Add test coverage for native format job upgrades

2022-02-08 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-26002: - Summary: Add test coverage for native format job upgrades Key: FLINK-26002 URL: https://issues.apache.org/jira/browse/FLINK-26002 Project: Flink

[jira] [Created] (FLINK-25891) NoClassDefFoundError AsyncSSLPrivateKeyMethod in benchmark

2022-01-31 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-25891: - Summary: NoClassDefFoundError AsyncSSLPrivateKeyMethod in benchmark Key: FLINK-25891 URL: https://issues.apache.org/jira/browse/FLINK-25891 Project: Flink

[jira] [Created] (FLINK-25650) Document unaligned checkpoints performance limitations (larger records/flat map/timers/...)

2022-01-13 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-25650: - Summary: Document unaligned checkpoints performance limitations (larger records/flat map/timers/...) Key: FLINK-25650 URL:

[jira] [Created] (FLINK-25646) Document buffer debloating issues with high parallelism

2022-01-13 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-25646: - Summary: Document buffer debloating issues with high parallelism Key: FLINK-25646 URL: https://issues.apache.org/jira/browse/FLINK-25646 Project: Flink

[jira] [Created] (FLINK-25590) Logging warning of insufficient memory for all configured buffers

2022-01-10 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-25590: - Summary: Logging warning of insufficient memory for all configured buffers Key: FLINK-25590 URL: https://issues.apache.org/jira/browse/FLINK-25590 Project:

[jira] [Created] (FLINK-25556) Extra waiting of final checkpoint in benchmarks

2022-01-06 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-25556: - Summary: Extra waiting of final checkpoint in benchmarks Key: FLINK-25556 URL: https://issues.apache.org/jira/browse/FLINK-25556 Project: Flink

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

2021-12-27 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-25454: - Summary: Negative time in throughput calculator Key: FLINK-25454 URL: https://issues.apache.org/jira/browse/FLINK-25454 Project: Flink Issue Type:

[jira] [Created] (FLINK-24738) Fail during announcing buffer size to released local channel

2021-11-02 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24738: - Summary: Fail during announcing buffer size to released local channel Key: FLINK-24738 URL: https://issues.apache.org/jira/browse/FLINK-24738 Project:

[jira] [Created] (FLINK-24734) testSecretOption fails due to missing required options

2021-11-02 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24734: - Summary: testSecretOption fails due to missing required options Key: FLINK-24734 URL: https://issues.apache.org/jira/browse/FLINK-24734 Project: Flink

[jira] [Created] (FLINK-24690) Clarification of buffer size threshold calculation in BufferDebloater

2021-10-29 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24690: - Summary: Clarification of buffer size threshold calculation in BufferDebloater Key: FLINK-24690 URL: https://issues.apache.org/jira/browse/FLINK-24690

[jira] [Created] (FLINK-24671) Possible NPE in LocalInputChannel#getBuffersInUseCount before initialization of subpartitionView

2021-10-27 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24671: - Summary: Possible NPE in LocalInputChannel#getBuffersInUseCount before initialization of subpartitionView Key: FLINK-24671 URL:

[jira] [Created] (FLINK-24659) Two active miniCluster in RemoteBenchmarkBase

2021-10-26 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24659: - Summary: Two active miniCluster in RemoteBenchmarkBase Key: FLINK-24659 URL: https://issues.apache.org/jira/browse/FLINK-24659 Project: Flink

[jira] [Created] (FLINK-24658) Debug logs for buffer size calculation

2021-10-26 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24658: - Summary: Debug logs for buffer size calculation Key: FLINK-24658 URL: https://issues.apache.org/jira/browse/FLINK-24658 Project: Flink Issue Type:

[jira] [Created] (FLINK-24657) Add metric of the total real size of input/output buffers queue

2021-10-26 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24657: - Summary: Add metric of the total real size of input/output buffers queue Key: FLINK-24657 URL: https://issues.apache.org/jira/browse/FLINK-24657 Project:

[jira] [Created] (FLINK-24589) FLIP-183: Buffer debloating 1.2

2021-10-19 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24589: - Summary: FLIP-183: Buffer debloating 1.2 Key: FLINK-24589 URL: https://issues.apache.org/jira/browse/FLINK-24589 Project: Flink Issue Type: New

[jira] [Created] (FLINK-24578) Unexpected erratic load shape for channel skew load profile

2021-10-18 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24578: - Summary: Unexpected erratic load shape for channel skew load profile Key: FLINK-24578 URL: https://issues.apache.org/jira/browse/FLINK-24578 Project: Flink

[jira] [Created] (FLINK-24553) Change buffer debloating default configuration values

2021-10-14 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24553: - Summary: Change buffer debloating default configuration values Key: FLINK-24553 URL: https://issues.apache.org/jira/browse/FLINK-24553 Project: Flink

[jira] [Created] (FLINK-24551) BUFFER_DEBLOAT_SAMPLES property is taken from the wrong configuration

2021-10-14 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24551: - Summary: BUFFER_DEBLOAT_SAMPLES property is taken from the wrong configuration Key: FLINK-24551 URL: https://issues.apache.org/jira/browse/FLINK-24551

[jira] [Created] (FLINK-24481) Translit buffer debloater documenation to chinese

2021-10-08 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24481: - Summary: Translit buffer debloater documenation to chinese Key: FLINK-24481 URL: https://issues.apache.org/jira/browse/FLINK-24481 Project: Flink

[jira] [Created] (FLINK-24470) EMA for buffer debloat level

2021-10-07 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24470: - Summary: EMA for buffer debloat level Key: FLINK-24470 URL: https://issues.apache.org/jira/browse/FLINK-24470 Project: Flink Issue Type:

[jira] [Created] (FLINK-24469) Incorrect calcualtion of the buffer size in case of channel data skew

2021-10-07 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24469: - Summary: Incorrect calcualtion of the buffer size in case of channel data skew Key: FLINK-24469 URL: https://issues.apache.org/jira/browse/FLINK-24469

[jira] [Created] (FLINK-24468) NPE when notifyNewBufferSize

2021-10-07 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24468: - Summary: NPE when notifyNewBufferSize Key: FLINK-24468 URL: https://issues.apache.org/jira/browse/FLINK-24468 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-24467) Set min and max buffer size even if the difference less than threshold

2021-10-07 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24467: - Summary: Set min and max buffer size even if the difference less than threshold Key: FLINK-24467 URL: https://issues.apache.org/jira/browse/FLINK-24467

[jira] [Created] (FLINK-24294) Resources leak in the StreamTask constructor

2021-09-15 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24294: - Summary: Resources leak in the StreamTask constructor Key: FLINK-24294 URL: https://issues.apache.org/jira/browse/FLINK-24294 Project: Flink Issue

[jira] [Created] (FLINK-24233) Receiving new buffer size before network reader configured

2021-09-09 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24233: - Summary: Receiving new buffer size before network reader configured Key: FLINK-24233 URL: https://issues.apache.org/jira/browse/FLINK-24233 Project: Flink

[jira] [Created] (FLINK-24231) Buffer debloating microbenchmark for multiply gate

2021-09-09 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24231: - Summary: Buffer debloating microbenchmark for multiply gate Key: FLINK-24231 URL: https://issues.apache.org/jira/browse/FLINK-24231 Project: Flink

[jira] [Created] (FLINK-24230) Buffer debloating microbenchmark for single gate

2021-09-09 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24230: - Summary: Buffer debloating microbenchmark for single gate Key: FLINK-24230 URL: https://issues.apache.org/jira/browse/FLINK-24230 Project: Flink

[jira] [Created] (FLINK-24191) Adjusting number of buffers besides buffer size

2021-09-07 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24191: - Summary: Adjusting number of buffers besides buffer size Key: FLINK-24191 URL: https://issues.apache.org/jira/browse/FLINK-24191 Project: Flink

[jira] [Created] (FLINK-24190) Handling large record with buffer debloat

2021-09-07 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24190: - Summary: Handling large record with buffer debloat Key: FLINK-24190 URL: https://issues.apache.org/jira/browse/FLINK-24190 Project: Flink Issue

[jira] [Created] (FLINK-24189) Debloating buffer for multiply gates

2021-09-07 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24189: - Summary: Debloating buffer for multiply gates Key: FLINK-24189 URL: https://issues.apache.org/jira/browse/FLINK-24189 Project: Flink Issue Type:

[jira] [Created] (FLINK-23975) High checkpoint time for unaligned checkpoint when throthling in source

2021-08-25 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-23975: - Summary: High checkpoint time for unaligned checkpoint when throthling in source Key: FLINK-23975 URL: https://issues.apache.org/jira/browse/FLINK-23975

[jira] [Created] (FLINK-23974) Low throughput for buffer debloat in case of different load profile

2021-08-25 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-23974: - Summary: Low throughput for buffer debloat in case of different load profile Key: FLINK-23974 URL: https://issues.apache.org/jira/browse/FLINK-23974

[jira] [Created] (FLINK-23973) FLIP-183: Buffer debloat 1.1

2021-08-25 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-23973: - Summary: FLIP-183: Buffer debloat 1.1 Key: FLINK-23973 URL: https://issues.apache.org/jira/browse/FLINK-23973 Project: Flink Issue Type: New

[jira] [Created] (FLINK-23928) Test the buffer debloating

2021-08-23 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-23928: - Summary: Test the buffer debloating Key: FLINK-23928 URL: https://issues.apache.org/jira/browse/FLINK-23928 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-23870) Test the ability for ignoring in-flight data on recovery

2021-08-19 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-23870: - Summary: Test the ability for ignoring in-flight data on recovery Key: FLINK-23870 URL: https://issues.apache.org/jira/browse/FLINK-23870 Project: Flink

[jira] [Created] (FLINK-23726) Buffer debloat configuration is taken from the wrong configuration

2021-08-11 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-23726: - Summary: Buffer debloat configuration is taken from the wrong configuration Key: FLINK-23726 URL: https://issues.apache.org/jira/browse/FLINK-23726

[jira] [Created] (FLINK-23459) New metrics for dynamic buffer size

2021-07-21 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-23459: - Summary: New metrics for dynamic buffer size Key: FLINK-23459 URL: https://issues.apache.org/jira/browse/FLINK-23459 Project: Flink Issue Type:

[jira] [Created] (FLINK-23458) Document required number of buffers in the network stack

2021-07-21 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-23458: - Summary: Document required number of buffers in the network stack Key: FLINK-23458 URL: https://issues.apache.org/jira/browse/FLINK-23458 Project: Flink

[jira] [Created] (FLINK-23457) Sending the buffer of the right size for broadcast

2021-07-21 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-23457: - Summary: Sending the buffer of the right size for broadcast Key: FLINK-23457 URL: https://issues.apache.org/jira/browse/FLINK-23457 Project: Flink

[jira] [Created] (FLINK-23456) Manually test on cluster

2021-07-21 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-23456: - Summary: Manually test on cluster Key: FLINK-23456 URL: https://issues.apache.org/jira/browse/FLINK-23456 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-23454) Sending the buffer of the right size for unicast

2021-07-21 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-23454: - Summary: Sending the buffer of the right size for unicast Key: FLINK-23454 URL: https://issues.apache.org/jira/browse/FLINK-23454 Project: Flink

[jira] [Created] (FLINK-23453) Dynamic calculation of the buffer size

2021-07-21 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-23453: - Summary: Dynamic calculation of the buffer size Key: FLINK-23453 URL: https://issues.apache.org/jira/browse/FLINK-23453 Project: Flink Issue Type:

[jira] [Created] (FLINK-23452) Measuring subtask throughput

2021-07-21 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-23452: - Summary: Measuring subtask throughput Key: FLINK-23452 URL: https://issues.apache.org/jira/browse/FLINK-23452 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-23451) FLIP-183: Dynamic buffer size adjustment

2021-07-21 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-23451: - Summary: FLIP-183: Dynamic buffer size adjustment Key: FLINK-23451 URL: https://issues.apache.org/jira/browse/FLINK-23451 Project: Flink Issue

[jira] [Created] (FLINK-23041) Change local alignment timeout back to the global time out

2021-06-18 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-23041: - Summary: Change local alignment timeout back to the global time out Key: FLINK-23041 URL: https://issues.apache.org/jira/browse/FLINK-23041 Project: Flink

[jira] [Created] (FLINK-23034) NPE in JobDetailsDeserializer during the reading old version of ExecutionState

2021-06-18 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-23034: - Summary: NPE in JobDetailsDeserializer during the reading old version of ExecutionState Key: FLINK-23034 URL: https://issues.apache.org/jira/browse/FLINK-23034

[jira] [Created] (FLINK-22961) Incorrect calculation of alignment timeout for LocalInputChannel

2021-06-10 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-22961: - Summary: Incorrect calculation of alignment timeout for LocalInputChannel Key: FLINK-22961 URL: https://issues.apache.org/jira/browse/FLINK-22961 Project:

[jira] [Created] (FLINK-22684) Add the ability to ignore in-flight data on recovery

2021-05-17 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-22684: - Summary: Add the ability to ignore in-flight data on recovery Key: FLINK-22684 URL: https://issues.apache.org/jira/browse/FLINK-22684 Project: Flink

[jira] [Created] (FLINK-22379) Introduce a new JobStatus to avoid premature checkpoint triggering

2021-04-20 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-22379: - Summary: Introduce a new JobStatus to avoid premature checkpoint triggering Key: FLINK-22379 URL: https://issues.apache.org/jira/browse/FLINK-22379

[jira] [Created] (FLINK-22215) Rename RECOVERING state to RESTORING

2021-04-12 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-22215: - Summary: Rename RECOVERING state to RESTORING Key: FLINK-22215 URL: https://issues.apache.org/jira/browse/FLINK-22215 Project: Flink Issue Type: