Piotr Nowojski created FLINK-37280:
--
Summary: Inconsistent content of TableConfig in planner when mini
batch is enabled
Key: FLINK-37280
URL: https://issues.apache.org/jira/browse/FLINK-37280
Project
Piotr Nowojski created FLINK-37256:
--
Summary: Firing timers can block recovery process
Key: FLINK-37256
URL: https://issues.apache.org/jira/browse/FLINK-37256
Project: Flink
Issue Type: Impr
Piotr Nowojski created FLINK-37213:
--
Summary: Improve performance of unbounded OVER aggregations
Key: FLINK-37213
URL: https://issues.apache.org/jira/browse/FLINK-37213
Project: Flink
Issue
Piotr Nowojski created FLINK-37005:
--
Summary: Make StreamExecDeduplicate ouput insert only where
possible
Key: FLINK-37005
URL: https://issues.apache.org/jira/browse/FLINK-37005
Project: Flink
Piotr Nowojski created FLINK-36764:
--
Summary: Add checkpoint type to checkpoint trace
Key: FLINK-36764
URL: https://issues.apache.org/jira/browse/FLINK-36764
Project: Flink
Issue Type: Impro
Piotr Nowojski created FLINK-36624:
--
Summary: Log JobID in SourceCoordinator
Key: FLINK-36624
URL: https://issues.apache.org/jira/browse/FLINK-36624
Project: Flink
Issue Type: Improvement
Piotr Nowojski created FLINK-36621:
--
Summary: Build failure: StatefulSink not found
Key: FLINK-36621
URL: https://issues.apache.org/jira/browse/FLINK-36621
Project: Flink
Issue Type: Improve
Piotr Nowojski created FLINK-36556:
--
Summary: Allow to configure starting buffer size when using buffer
debloating
Key: FLINK-36556
URL: https://issues.apache.org/jira/browse/FLINK-36556
Project: Fli
Piotr Nowojski created FLINK-36555:
--
Summary: Guarantee debloated buffer size grows even with very
small alpha
Key: FLINK-36555
URL: https://issues.apache.org/jira/browse/FLINK-36555
Project: Flink
Piotr Nowojski created FLINK-36416:
--
Summary: Enable splittable timers for temporal join, temporal sort
and windowed aggregation in SQL/Table API
Key: FLINK-36416
URL: https://issues.apache.org/jira/browse/FLINK-
Piotr Nowojski created FLINK-36260:
--
Summary: numBytesInLocal and numBuffersInLocal being reported as
remote
Key: FLINK-36260
URL: https://issues.apache.org/jira/browse/FLINK-36260
Project: Flink
Piotr Nowojski created FLINK-36108:
--
Summary: Wait for state download on cancellation to enforce cleanup
Key: FLINK-36108
URL: https://issues.apache.org/jira/browse/FLINK-36108
Project: Flink
Piotr Nowojski created FLINK-35886:
--
Summary: Incorrect watermark idleness timeout accounting when
subtask is backpressured/blocked
Key: FLINK-35886
URL: https://issues.apache.org/jira/browse/FLINK-35886
Piotr Nowojski created FLINK-35821:
--
Summary: ResumeCheckpointManuallyITCase failed with File X does
not exist or the user running Flink C has insufficient permissions to access it
Key: FLINK-35821
URL: https://i
Piotr Nowojski created FLINK-35773:
--
Summary: Document s5cmd
Key: FLINK-35773
URL: https://issues.apache.org/jira/browse/FLINK-35773
Project: Flink
Issue Type: Sub-task
Reporter:
Piotr Nowojski created FLINK-35772:
--
Summary: Deprecate/remove DuplicatingFileSystem
Key: FLINK-35772
URL: https://issues.apache.org/jira/browse/FLINK-35772
Project: Flink
Issue Type: Sub-ta
Piotr Nowojski created FLINK-35771:
--
Summary: Limit s5cmd resource usage
Key: FLINK-35771
URL: https://issues.apache.org/jira/browse/FLINK-35771
Project: Flink
Issue Type: Sub-task
Piotr Nowojski created FLINK-35770:
--
Summary: Interrupt s5cmd call on cancellation
Key: FLINK-35770
URL: https://issues.apache.org/jira/browse/FLINK-35770
Project: Flink
Issue Type: Sub-tas
Piotr Nowojski created FLINK-35768:
--
Summary: Use native file copy in RocksDBStateDownloader
Key: FLINK-35768
URL: https://issues.apache.org/jira/browse/FLINK-35768
Project: Flink
Issue Type
Piotr Nowojski created FLINK-35767:
--
Summary: Provide native file copy support for S3 using s5cmd
Key: FLINK-35767
URL: https://issues.apache.org/jira/browse/FLINK-35767
Project: Flink
Issue
Piotr Nowojski created FLINK-35739:
--
Summary: FLIP-444: Native file copy support
Key: FLINK-35739
URL: https://issues.apache.org/jira/browse/FLINK-35739
Project: Flink
Issue Type: New Featur
Piotr Nowojski created FLINK-35528:
--
Summary: Skip execution of interruptible mails when yielding
Key: FLINK-35528
URL: https://issues.apache.org/jira/browse/FLINK-35528
Project: Flink
Issue
Piotr Nowojski created FLINK-35518:
--
Summary: CI Bot doesn't run on PRs
Key: FLINK-35518
URL: https://issues.apache.org/jira/browse/FLINK-35518
Project: Flink
Issue Type: Bug
Compo
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
Is
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
Is
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: Flin
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
Project:
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
Is
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: Ne
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 Fe
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: https://issues.apache.org/jira/browse
Piotr Nowojski created FLINK-29888:
--
Summary: Improve MutatedConfigurationException for disallowed
changes in CheckpointConfig and ExecutionConfig
Key: FLINK-29888
URL: https://issues.apache.org/jira/browse/FLINK
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
Issu
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
Project:
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: https://issues.apache.org/jira/browse/F
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
Issu
Piotr Nowojski created FLINK-27202:
--
Summary: NullPointerException on stop-with-savepoint with
AsyncWaitOperator followed by FlinkKafkaProducer
Key: FLINK-27202
URL: https://issues.apache.org/jira/browse/FLINK-2
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 Typ
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
Is
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
I
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: Flin
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: Sub
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 Type
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 Type:
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: F
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
C
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: New
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
Iss
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: Flink
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
Com
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
I
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
P
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
Proj
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: Fli
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
Project
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
Project
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
Componen
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 Typ
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: https://issues.apache.org/jira/
1 - 100 of 373 matches
Mail list logo
