Piotr Nowojski created FLINK-35420:
--
Summary: WordCountMapredITCase fails to compile in IntelliJ
Key: FLINK-35420
URL: https://issues.apache.org/jira/browse/FLINK-35420
Project: Flink
Issue
Piotr Nowojski created FLINK-35065:
--
Summary: Add numFiredTimers and numFiredTimersPerSecond metrics
Key: FLINK-35065
URL: https://issues.apache.org/jira/browse/FLINK-35065
Project: Flink
Piotr Nowojski created FLINK-35051:
--
Summary: Weird priorities when processing unaligned checkpoints
Key: FLINK-35051
URL: https://issues.apache.org/jira/browse/FLINK-35051
Project: Flink
Piotr Nowojski created FLINK-34913:
--
Summary: ConcurrentModificationException
SubTaskInitializationMetricsBuilder.addDurationMetric
Key: FLINK-34913
URL: https://issues.apache.org/jira/browse/FLINK-34913
Piotr Nowojski created FLINK-34430:
--
Summary: Akka frame size exceeded with many ByteStreamStateHandle
being used
Key: FLINK-34430
URL: https://issues.apache.org/jira/browse/FLINK-34430
Project:
Piotr Nowojski created FLINK-33775:
--
Summary: Report JobInitialization traces
Key: FLINK-33775
URL: https://issues.apache.org/jira/browse/FLINK-33775
Project: Flink
Issue Type: Sub-task
Piotr Nowojski created FLINK-33709:
--
Summary: Report CheckpointStats as Spans
Key: FLINK-33709
URL: https://issues.apache.org/jira/browse/FLINK-33709
Project: Flink
Issue Type: Sub-task
Piotr Nowojski created FLINK-33708:
--
Summary: Add Span and TraceReporter concepts
Key: FLINK-33708
URL: https://issues.apache.org/jira/browse/FLINK-33708
Project: Flink
Issue Type: Sub-task
Piotr Nowojski created FLINK-33696:
--
Summary: FLIP-385: Add OpenTelemetryTraceReporter and
OpenTelemetryMetricReporter
Key: FLINK-33696
URL: https://issues.apache.org/jira/browse/FLINK-33696
Piotr Nowojski created FLINK-33697:
--
Summary: FLIP-386: Support adding custom metrics in Recovery Spans
Key: FLINK-33697
URL: https://issues.apache.org/jira/browse/FLINK-33697
Project: Flink
Piotr Nowojski created FLINK-33695:
--
Summary: FLIP-384: Introduce TraceReporter and use it to create
checkpointing and recovery traces
Key: FLINK-33695
URL: https://issues.apache.org/jira/browse/FLINK-33695
Piotr Nowojski created FLINK-8:
--
Summary: Bump up RocksDB version to 7.x
Key: FLINK-8
URL: https://issues.apache.org/jira/browse/FLINK-8
Project: Flink
Issue Type: Sub-task
Piotr Nowojski created FLINK-7:
--
Summary: Expose IngestDB and ClipDB in the official RocksDB API
Key: FLINK-7
URL: https://issues.apache.org/jira/browse/FLINK-7
Project: Flink
Piotr Nowojski created FLINK-33071:
--
Summary: Log checkpoint statistics
Key: FLINK-33071
URL: https://issues.apache.org/jira/browse/FLINK-33071
Project: Flink
Issue Type: New Feature
Piotr Nowojski created FLINK-32303:
--
Summary: Incorrect error message in KafkaSource
Key: FLINK-32303
URL: https://issues.apache.org/jira/browse/FLINK-32303
Project: Flink
Issue Type: Bug
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
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
Piotr Nowojski created FLINK-30155:
--
Summary: Pretty print MutatedConfigurationException
Key: FLINK-30155
URL: https://issues.apache.org/jira/browse/FLINK-30155
Project: Flink
Issue Type:
Piotr Nowojski created FLINK-30070:
--
Summary: Create savepoints without side effects
Key: FLINK-30070
URL: https://issues.apache.org/jira/browse/FLINK-30070
Project: Flink
Issue Type: New
Piotr Nowojski created FLINK-30068:
--
Summary: Allow users to configure what to do with errors while
committing transactions during recovery in KafkaSink
Key: FLINK-30068
URL:
Piotr Nowojski created FLINK-29888:
--
Summary: Improve MutatedConfigurationException for disallowed
changes in CheckpointConfig and ExecutionConfig
Key: FLINK-29888
URL:
Piotr Nowojski created FLINK-29886:
--
Summary: networkThroughput 1000,100ms,OpenSSL Benchmark is failing
Key: FLINK-29886
URL: https://issues.apache.org/jira/browse/FLINK-29886
Project: Flink
Piotr Nowojski created FLINK-29807:
--
Summary: Drop TypeSerializerConfigSnapshot and savepoint support
from Flink versions < 1.8.0
Key: FLINK-29807
URL: https://issues.apache.org/jira/browse/FLINK-29807
Piotr Nowojski created FLINK-29662:
--
Summary: PojoSerializerSnapshot is using incorrect ExecutionConfig
when restoring serializer
Key: FLINK-29662
URL: https://issues.apache.org/jira/browse/FLINK-29662
Piotr Nowojski created FLINK-29645:
--
Summary: BatchExecutionKeyedStateBackend is using incorrect
ExecutionConfig when creating serializer
Key: FLINK-29645
URL: https://issues.apache.org/jira/browse/FLINK-29645
Piotr Nowojski created FLINK-29584:
--
Summary: Upgrade java 11 version on the microbenchmark worker
Key: FLINK-29584
URL: https://issues.apache.org/jira/browse/FLINK-29584
Project: Flink
Piotr Nowojski created FLINK-28835:
--
Summary: Savepoint and checkpoint capabilities and limitations
table is incorrect
Key: FLINK-28835
URL: https://issues.apache.org/jira/browse/FLINK-28835
Piotr Nowojski created FLINK-27640:
--
Summary: Flink not compiling, flink-connector-hive_2.12 is missing
pentaho-aggdesigner-algorithm:jar:5.1.5-jhyde
Key: FLINK-27640
URL:
Piotr Nowojski created FLINK-27209:
--
Summary: Half the Xmx and double the forkCount for unit tests
Key: FLINK-27209
URL: https://issues.apache.org/jira/browse/FLINK-27209
Project: Flink
Piotr Nowojski created FLINK-27202:
--
Summary: NullPointerException on stop-with-savepoint with
AsyncWaitOperator followed by FlinkKafkaProducer
Key: FLINK-27202
URL:
Piotr Nowojski created FLINK-27133:
--
Summary: Performance regression in serializerHeavyString
Key: FLINK-27133
URL: https://issues.apache.org/jira/browse/FLINK-27133
Project: Flink
Issue
Piotr Nowojski created FLINK-27117:
--
Summary: FLIP-217: Support watermark alignment of source splits
Key: FLINK-27117
URL: https://issues.apache.org/jira/browse/FLINK-27117
Project: Flink
Piotr Nowojski created FLINK-26864:
--
Summary: Performance regression on 25.03.2022
Key: FLINK-26864
URL: https://issues.apache.org/jira/browse/FLINK-26864
Project: Flink
Issue Type: Bug
Piotr Nowojski created FLINK-26682:
--
Summary: Migrate regression check script to python and to main
repository
Key: FLINK-26682
URL: https://issues.apache.org/jira/browse/FLINK-26682
Project: Flink
Piotr Nowojski created FLINK-26147:
--
Summary: Deleting incremental savepoints directory in CLAIM mode
Key: FLINK-26147
URL: https://issues.apache.org/jira/browse/FLINK-26147
Project: Flink
Piotr Nowojski created FLINK-26146:
--
Summary: Add test coverage for native format flink upgrades (minor
versions)
Key: FLINK-26146
URL: https://issues.apache.org/jira/browse/FLINK-26146
Project:
Piotr Nowojski created FLINK-26064:
--
Summary: KinesisFirehoseSinkITCase IllegalStateException: Trying
to access closed classloader
Key: FLINK-26064
URL: https://issues.apache.org/jira/browse/FLINK-26064
Piotr Nowojski created FLINK-25982:
--
Summary: Support idleness with watermark alignment
Key: FLINK-25982
URL: https://issues.apache.org/jira/browse/FLINK-25982
Project: Flink
Issue Type:
Piotr Nowojski created FLINK-25914:
--
Summary: Performance regression in checkpointSingleInput.UNALIGNED
on 31.01.2022
Key: FLINK-25914
URL: https://issues.apache.org/jira/browse/FLINK-25914
Project:
Piotr Nowojski created FLINK-25912:
--
Summary: HashMapStateBackend performance regression on 31.01.2022
Key: FLINK-25912
URL: https://issues.apache.org/jira/browse/FLINK-25912
Project: Flink
Piotr Nowojski created FLINK-25896:
--
Summary: Buffer debloating issues with high parallelism
Key: FLINK-25896
URL: https://issues.apache.org/jira/browse/FLINK-25896
Project: Flink
Issue
Piotr Nowojski created FLINK-25869:
--
Summary: Create a stress test cron build
Key: FLINK-25869
URL: https://issues.apache.org/jira/browse/FLINK-25869
Project: Flink
Issue Type: Improvement
Piotr Nowojski created FLINK-25745:
--
Summary: Support RocksDB incremental native savepoints
Key: FLINK-25745
URL: https://issues.apache.org/jira/browse/FLINK-25745
Project: Flink
Issue
Piotr Nowojski created FLINK-25744:
--
Summary: Support native savepoints (w/o modifying the statebackend
specific snapshot strategies)
Key: FLINK-25744
URL: https://issues.apache.org/jira/browse/FLINK-25744
Piotr Nowojski created FLINK-25704:
--
Summary: Performance regression on 18.01.2022 in batch network
benchmarks
Key: FLINK-25704
URL: https://issues.apache.org/jira/browse/FLINK-25704
Project: Flink
Piotr Nowojski created FLINK-25688:
--
Summary: Resolve performance degradation with high parallelism
when using buffer debloating
Key: FLINK-25688
URL: https://issues.apache.org/jira/browse/FLINK-25688
Piotr Nowojski created FLINK-25414:
--
Summary: Provide metrics to measure how long task has been blocked
Key: FLINK-25414
URL: https://issues.apache.org/jira/browse/FLINK-25414
Project: Flink
Piotr Nowojski created FLINK-25407:
--
Summary: Network stack deadlock when cancellation happens during
initialisation
Key: FLINK-25407
URL: https://issues.apache.org/jira/browse/FLINK-25407
Project:
Piotr Nowojski created FLINK-25382:
--
Summary: Failure in "Upload Logs" task
Key: FLINK-25382
URL: https://issues.apache.org/jira/browse/FLINK-25382
Project: Flink
Issue Type: Bug
Piotr Nowojski created FLINK-25276:
--
Summary: Support native and incremental savepoints
Key: FLINK-25276
URL: https://issues.apache.org/jira/browse/FLINK-25276
Project: Flink
Issue Type:
Piotr Nowojski created FLINK-25275:
--
Summary: Weighted KeyGroup assignment
Key: FLINK-25275
URL: https://issues.apache.org/jira/browse/FLINK-25275
Project: Flink
Issue Type: New Feature
Piotr Nowojski created FLINK-25255:
--
Summary: Consider/design implementing State Processor API (FC)
Key: FLINK-25255
URL: https://issues.apache.org/jira/browse/FLINK-25255
Project: Flink
Piotr Nowojski created FLINK-24919:
--
Summary: UnalignedCheckpointITCase hangs on Azure
Key: FLINK-24919
URL: https://issues.apache.org/jira/browse/FLINK-24919
Project: Flink
Issue Type: Bug
Piotr Nowojski created FLINK-24846:
--
Summary: AsyncWaitOperator fails during stop-with-savepoint
Key: FLINK-24846
URL: https://issues.apache.org/jira/browse/FLINK-24846
Project: Flink
Issue
Piotr Nowojski created FLINK-24696:
--
Summary: Translate how to configure unaligned checkpoints into
Chinese
Key: FLINK-24696
URL: https://issues.apache.org/jira/browse/FLINK-24696
Project: Flink
Piotr Nowojski created FLINK-24695:
--
Summary: Update how to configure unaligned checkpoints in the
documentation
Key: FLINK-24695
URL: https://issues.apache.org/jira/browse/FLINK-24695
Project:
Piotr Nowojski created FLINK-24694:
--
Summary: Translate "Checkpointing under backpressure" page into
Chinese
Key: FLINK-24694
URL: https://issues.apache.org/jira/browse/FLINK-24694
Project: Flink
Piotr Nowojski created FLINK-24693:
--
Summary: Update Chinese version of "Checkpoints" page
Key: FLINK-24693
URL: https://issues.apache.org/jira/browse/FLINK-24693
Project: Flink
Issue Type:
Piotr Nowojski created FLINK-24670:
--
Summary: Restructure unaligned checkpoints documentation page to
"Checkpointing under back pressure"
Key: FLINK-24670
URL: https://issues.apache.org/jira/browse/FLINK-24670
Piotr Nowojski created FLINK-24531:
--
Summary: CheckpointingTimeBenchmark can fail with connection timed
out
Key: FLINK-24531
URL: https://issues.apache.org/jira/browse/FLINK-24531
Project: Flink
Piotr Nowojski created FLINK-24483:
--
Summary: Document what is Public API and what compatibility
guarantees Flink is providing
Key: FLINK-24483
URL: https://issues.apache.org/jira/browse/FLINK-24483
Piotr Nowojski created FLINK-24475:
--
Summary: Remove no longer used NestedMap* classes
Key: FLINK-24475
URL: https://issues.apache.org/jira/browse/FLINK-24475
Project: Flink
Issue Type: Bug
Piotr Nowojski created FLINK-24472:
--
Summary: DispatcherTest is unstable
Key: FLINK-24472
URL: https://issues.apache.org/jira/browse/FLINK-24472
Project: Flink
Issue Type: Bug
Piotr Nowojski created FLINK-24471:
--
Summary: Add microbenchmark for throughput with debloating enabled
Key: FLINK-24471
URL: https://issues.apache.org/jira/browse/FLINK-24471
Project: Flink
Piotr Nowojski created FLINK-24439:
--
Summary: Introduce a CoordinatorStore
Key: FLINK-24439
URL: https://issues.apache.org/jira/browse/FLINK-24439
Project: Flink
Issue Type: Sub-task
Piotr Nowojski created FLINK-24441:
--
Summary: Block SourceReader when watermarks are out of alignment
Key: FLINK-24441
URL: https://issues.apache.org/jira/browse/FLINK-24441
Project: Flink
Piotr Nowojski created FLINK-24440:
--
Summary: Announce and combine latest watermarks across
SourceReaders
Key: FLINK-24440
URL: https://issues.apache.org/jira/browse/FLINK-24440
Project: Flink
Piotr Nowojski created FLINK-24357:
--
Summary:
ZooKeeperLeaderElectionConnectionHandlingTest#testLoseLeadershipOnLostConnectionIfTolerateSuspendedConnectionsIsEnabled
fails with an Unhandled error
Key: FLINK-24357
Piotr Nowojski created FLINK-24344:
--
Summary: Handling of IOExceptions when triggering checkpoints
doesn't cause job failover
Key: FLINK-24344
URL: https://issues.apache.org/jira/browse/FLINK-24344
Piotr Nowojski created FLINK-24328:
--
Summary: Long term fix for receiving new buffer size before
network reader configured
Key: FLINK-24328
URL: https://issues.apache.org/jira/browse/FLINK-24328
Piotr Nowojski created FLINK-24184:
--
Summary: Potential race condition leading to incorrectly issued
interruptions
Key: FLINK-24184
URL: https://issues.apache.org/jira/browse/FLINK-24184
Project:
Piotr Nowojski created FLINK-24155:
--
Summary: Translate documentation for how to configure the
CheckpointFailureManager
Key: FLINK-24155
URL: https://issues.apache.org/jira/browse/FLINK-24155
Piotr Nowojski created FLINK-24154:
--
Summary: Translate documentation for how to configure the
CheckpointFailureManager
Key: FLINK-24154
URL: https://issues.apache.org/jira/browse/FLINK-24154
Piotr Nowojski created FLINK-24030:
--
Summary: PulsarSourceITCase>SourceTestSuiteBase.testMultipleSplits
failed
Key: FLINK-24030
URL: https://issues.apache.org/jira/browse/FLINK-24030
Project: Flink
Piotr Nowojski created FLINK-23988:
--
Summary: Test corner cases
Key: FLINK-23988
URL: https://issues.apache.org/jira/browse/FLINK-23988
Project: Flink
Issue Type: Sub-task
Piotr Nowojski created FLINK-23776:
--
Summary: Performance regression on 14.08.2021 in FLIP-27
Key: FLINK-23776
URL: https://issues.apache.org/jira/browse/FLINK-23776
Project: Flink
Issue
Piotr Nowojski created FLINK-23772:
--
Summary: Double check if non-keyed FullyFinishedOperatorState can
be mixed up with non finished OperatorState on recovery
Key: FLINK-23772
URL:
Piotr Nowojski created FLINK-23771:
--
Summary: FLIP-147 Checkpoint N has not been started at all
Key: FLINK-23771
URL: https://issues.apache.org/jira/browse/FLINK-23771
Project: Flink
Issue
Piotr Nowojski created FLINK-23741:
--
Summary: Waiting for final checkpoint can deadlock job
Key: FLINK-23741
URL: https://issues.apache.org/jira/browse/FLINK-23741
Project: Flink
Issue
Piotr Nowojski created FLINK-23708:
--
Summary: When task is finishedOnRestore Operators shouldn't be used
Key: FLINK-23708
URL: https://issues.apache.org/jira/browse/FLINK-23708
Project: Flink
Piotr Nowojski created FLINK-23704:
--
Summary: FLIP-27 sources are not generating LatencyMarkers
Key: FLINK-23704
URL: https://issues.apache.org/jira/browse/FLINK-23704
Project: Flink
Issue
Piotr Nowojski created FLINK-23698:
--
Summary: Pass watermarks in finished on restore operators
Key: FLINK-23698
URL: https://issues.apache.org/jira/browse/FLINK-23698
Project: Flink
Issue
Piotr Nowojski created FLINK-23648:
--
Summary: Drop StreamTwoInputProcessor in favour of
StreamMultipleInputProcessor
Key: FLINK-23648
URL: https://issues.apache.org/jira/browse/FLINK-23648
Project:
Piotr Nowojski created FLINK-23593:
--
Summary: Performance regression on 15.07.2021
Key: FLINK-23593
URL: https://issues.apache.org/jira/browse/FLINK-23593
Project: Flink
Issue Type: Bug
Piotr Nowojski created FLINK-23560:
--
Summary: Performance regression on 29.07.2021
Key: FLINK-23560
URL: https://issues.apache.org/jira/browse/FLINK-23560
Project: Flink
Issue Type: Bug
Piotr Nowojski created FLINK-23559:
--
Summary: Enable periodic materialisation in tests
Key: FLINK-23559
URL: https://issues.apache.org/jira/browse/FLINK-23559
Project: Flink
Issue Type:
Piotr Nowojski created FLINK-23528:
--
Summary: stop-with-savepoint can fail with FlinkKinesisConsumer
Key: FLINK-23528
URL: https://issues.apache.org/jira/browse/FLINK-23528
Project: Flink
Piotr Nowojski created FLINK-23527:
--
Summary: Clarify `SourceFunction#cancel()` contract about
interrupting
Key: FLINK-23527
URL: https://issues.apache.org/jira/browse/FLINK-23527
Project: Flink
Piotr Nowojski created FLINK-23398:
--
Summary: State backend benchmarks are failing
Key: FLINK-23398
URL: https://issues.apache.org/jira/browse/FLINK-23398
Project: Flink
Issue Type: Bug
Piotr Nowojski created FLINK-23382:
--
Summary: Performance regression on 13.07.2021
Key: FLINK-23382
URL: https://issues.apache.org/jira/browse/FLINK-23382
Project: Flink
Issue Type: Bug
Piotr Nowojski created FLINK-23078:
--
Summary: Scheduler Benchmarks not compiling
Key: FLINK-23078
URL: https://issues.apache.org/jira/browse/FLINK-23078
Project: Flink
Issue Type: Bug
Piotr Nowojski created FLINK-23011:
--
Summary: FLIP-27 sources are generating non-deterministic results
when using event time
Key: FLINK-23011
URL: https://issues.apache.org/jira/browse/FLINK-23011
Piotr Nowojski created FLINK-22973:
--
Summary: Provide benchmark for unaligned checkpoints performance
Key: FLINK-22973
URL: https://issues.apache.org/jira/browse/FLINK-22973
Project: Flink
Piotr Nowojski created FLINK-22904:
--
Summary: Performance regression on 25.05.2020 in
mapRebalanceMapSink
Key: FLINK-22904
URL: https://issues.apache.org/jira/browse/FLINK-22904
Project: Flink
Piotr Nowojski created FLINK-22882:
--
Summary: Tasks are blocked while emitting records
Key: FLINK-22882
URL: https://issues.apache.org/jira/browse/FLINK-22882
Project: Flink
Issue Type: Bug
Piotr Nowojski created FLINK-22881:
--
Summary: Tasks are blocked while emitting stream status
Key: FLINK-22881
URL: https://issues.apache.org/jira/browse/FLINK-22881
Project: Flink
Issue
Piotr Nowojski created FLINK-22833:
--
Summary: Source tasks (both old and new) are not reporting
checkpointStartDelay via CheckpointMetrics
Key: FLINK-22833
URL: https://issues.apache.org/jira/browse/FLINK-22833
Piotr Nowojski created FLINK-22814:
--
Summary: New sources are not defining/exposing
checkpointStartDelayNanos metric
Key: FLINK-22814
URL: https://issues.apache.org/jira/browse/FLINK-22814
Project:
Piotr Nowojski created FLINK-22592:
--
Summary: numBuffersInLocal is always zero when using unaligned
checkpoints
Key: FLINK-22592
URL: https://issues.apache.org/jira/browse/FLINK-22592
Project: Flink
Piotr Nowojski created FLINK-22562:
--
Summary: Translate recent updates to backpressure and
checkpointing docs
Key: FLINK-22562
URL: https://issues.apache.org/jira/browse/FLINK-22562
Project: Flink
1 - 100 of 347 matches
Mail list logo
