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: Improvem
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
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
Is
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
Issue
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
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
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
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
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 Type
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
Proje
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
Is
Anton Kalashnikov created FLINK-25891:
-
Summary: NoClassDefFoundError AsyncSSLPrivateKeyMethod in benchmark
Key: FLINK-25891
URL: https://issues.apache.org/jira/browse/FLINK-25891
Project: Flink
Anton Kalashnikov created FLINK-25650:
-
Summary: Document unaligned checkpoints performance limitations
(larger records/flat map/timers/...)
Key: FLINK-25650
URL: https://issues.apache.org/jira/browse/FLINK-25
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
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:
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
Iss
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:
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: Flink
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
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
Proj
Anton Kalashnikov created FLINK-24671:
-
Summary: Possible NPE in LocalInputChannel#getBuffersInUseCount
before initialization of subpartitionView
Key: FLINK-24671
URL: https://issues.apache.org/jira/browse/FL
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
Issue
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:
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: F
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 Fea
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
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
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
Proje
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
I
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: Improvemen
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
Proje
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
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
Proj
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
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
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
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
Is
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
Iss
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 Typ
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: Su
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
Pro
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
Project
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 Featur
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
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
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
Project:
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: Sub
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
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
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
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
Is
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:
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
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 Type
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
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
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: F
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
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
Project:
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: Im
60 matches
Mail list logo