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
Piotr Nowojski created FLINK-22424:
--
Summary: Writing to already released buffers potentially causing
data corruption
Key: FLINK-22424
URL: https://issues.apache.org/jira/browse/FLINK-22424
Project:
Piotr Nowojski created FLINK-22132:
--
Summary: Test unaligned checkpoints rescaling manually on a real
cluster
Key: FLINK-22132
URL: https://issues.apache.org/jira/browse/FLINK-22132
Project: Flink
Piotr Nowojski created FLINK-22007:
--
Summary: PartitionReleaseInBatchJobBenchmarkExecutor seems to be
failing
Key: FLINK-22007
URL: https://issues.apache.org/jira/browse/FLINK-22007
Project: Flink
Piotr Nowojski created FLINK-21875:
--
Summary: GSRKinesisPubsubClient is not compiling in IntelliJ
Key: FLINK-21875
URL: https://issues.apache.org/jira/browse/FLINK-21875
Project: Flink
Piotr Nowojski created FLINK-21625:
--
Summary: 5.03.2021 Benchmarks are not compiling
Key: FLINK-21625
URL: https://issues.apache.org/jira/browse/FLINK-21625
Project: Flink
Issue Type: Bug
Piotr Nowojski created FLINK-21517:
--
Summary: Test harnesses are bypassing serialization stack for
events
Key: FLINK-21517
URL: https://issues.apache.org/jira/browse/FLINK-21517
Project: Flink
Piotr Nowojski created FLINK-21514:
--
Summary: 26.02.2021 Benchmarks are not compiling
Key: FLINK-21514
URL: https://issues.apache.org/jira/browse/FLINK-21514
Project: Flink
Issue Type: Bug
Piotr Nowojski created FLINK-21484:
--
Summary: Internal enum CheckpointType is exposed via REST API,
making it part of Public API
Key: FLINK-21484
URL: https://issues.apache.org/jira/browse/FLINK-21484
Piotr Nowojski created FLINK-21469:
--
Summary: stop-with-savepoint --drain doesn't advance watermark for
sources chained to MultipleInputStreamTask
Key: FLINK-21469
URL:
Piotr Nowojski created FLINK-21453:
--
Summary: BoundedOneInput.endInput is NOT called when doing stop
with savepoint WITH drain
Key: FLINK-21453
URL: https://issues.apache.org/jira/browse/FLINK-21453
Piotr Nowojski created FLINK-21334:
--
Summary: Run kubernetes pyflink application test fails with
Connection reset by peer on setup
Key: FLINK-21334
URL: https://issues.apache.org/jira/browse/FLINK-21334
Piotr Nowojski created FLINK-20934:
--
Summary: CsvFileCompactionITCase.testSingleParallelism test failure
Key: FLINK-20934
URL: https://issues.apache.org/jira/browse/FLINK-20934
Project: Flink
Piotr Nowojski created FLINK-20868:
--
Summary: Pause the idle/back pressure timers during processing
mailbox actions
Key: FLINK-20868
URL: https://issues.apache.org/jira/browse/FLINK-20868
Project:
Piotr Nowojski created FLINK-20852:
--
Summary: Enrich back pressure stats per subtask in the WebUI
Key: FLINK-20852
URL: https://issues.apache.org/jira/browse/FLINK-20852
Project: Flink
Piotr Nowojski created FLINK-20724:
--
Summary: Create a http handler for aggregating metrics from whole
job
Key: FLINK-20724
URL: https://issues.apache.org/jira/browse/FLINK-20724
Project: Flink
Piotr Nowojski created FLINK-20718:
--
Summary: Create isCausingBackPressureRatio and
isCausingBackPressure metrics
Key: FLINK-20718
URL: https://issues.apache.org/jira/browse/FLINK-20718
Project:
Piotr Nowojski created FLINK-20717:
--
Summary: Create isBackPressuredRatio metric
Key: FLINK-20717
URL: https://issues.apache.org/jira/browse/FLINK-20717
Project: Flink
Issue Type: Sub-task
Piotr Nowojski created FLINK-19683:
--
Summary: Actively timeout aligned checkpoints on the output
Key: FLINK-19683
URL: https://issues.apache.org/jira/browse/FLINK-19683
Project: Flink
Issue
Piotr Nowojski created FLINK-19682:
--
Summary: Actively timeout checkpoint barriers on the inputs
Key: FLINK-19682
URL: https://issues.apache.org/jira/browse/FLINK-19682
Project: Flink
Issue
Piotr Nowojski created FLINK-19681:
--
Summary: Passively timeout alignment on the inputs
Key: FLINK-19681
URL: https://issues.apache.org/jira/browse/FLINK-19681
Project: Flink
Issue Type:
Piotr Nowojski created FLINK-19680:
--
Summary: Add CheckpointBarrierAnnouncement priority message
Key: FLINK-19680
URL: https://issues.apache.org/jira/browse/FLINK-19680
Project: Flink
Issue
Piotr Nowojski created FLINK-19679:
--
Summary: Deduplicate code between CheckpointBarrierUnaligner and
CheckpointBarrierAligner
Key: FLINK-19679
URL: https://issues.apache.org/jira/browse/FLINK-19679
Piotr Nowojski created FLINK-19616:
--
Summary: Flink : Formats : Parquet compilation failure
Key: FLINK-19616
URL: https://issues.apache.org/jira/browse/FLINK-19616
Project: Flink
Issue
Piotr Nowojski created FLINK-19537:
--
Summary: Processed in-flight bytes metric is not accurate
Key: FLINK-19537
URL: https://issues.apache.org/jira/browse/FLINK-19537
Project: Flink
Issue
Piotr Nowojski created FLINK-19487:
--
Summary: Checkpoint start delay is always zero for single channel
tasks
Key: FLINK-19487
URL: https://issues.apache.org/jira/browse/FLINK-19487
Project: Flink
Piotr Nowojski created FLINK-19440:
--
Summary: Performance regression on 15.09.2020
Key: FLINK-19440
URL: https://issues.apache.org/jira/browse/FLINK-19440
Project: Flink
Issue Type: Bug
Piotr Nowojski created FLINK-19439:
--
Summary: Performance regression on 24.09.2020
Key: FLINK-19439
URL: https://issues.apache.org/jira/browse/FLINK-19439
Project: Flink
Issue Type: Bug
Piotr Nowojski created FLINK-19174:
--
Summary: idleTimeMsPerSecond can report incorrect values if task
is blocked for more then 60 seconds
Key: FLINK-19174
URL: https://issues.apache.org/jira/browse/FLINK-19174
Piotr Nowojski created FLINK-19040:
--
Summary: SourceOperator is not closing SourceReader
Key: FLINK-19040
URL: https://issues.apache.org/jira/browse/FLINK-19040
Project: Flink
Issue Type:
Piotr Nowojski created FLINK-18907:
--
Summary: Add watermarks and metrics tests for
MultipleSourceOperatorStreamTask
Key: FLINK-18907
URL: https://issues.apache.org/jira/browse/FLINK-18907
Project:
Piotr Nowojski created FLINK-18906:
--
Summary: Support checkpointing with multiple input operator
chained with sources
Key: FLINK-18906
URL: https://issues.apache.org/jira/browse/FLINK-18906
Project:
Piotr Nowojski created FLINK-18905:
--
Summary: Add runtime support for multiple input operator chained
with sources
Key: FLINK-18905
URL: https://issues.apache.org/jira/browse/FLINK-18905
Project:
Piotr Nowojski created FLINK-18904:
--
Summary: Support multiple source operators chaining in StreamConfig
Key: FLINK-18904
URL: https://issues.apache.org/jira/browse/FLINK-18904
Project: Flink
Piotr Nowojski created FLINK-18736:
--
Summary: Source chaining with N-Ary Stream Operator in Flink
Key: FLINK-18736
URL: https://issues.apache.org/jira/browse/FLINK-18736
Project: Flink
Piotr Nowojski created FLINK-18671:
--
Summary: Update upgrade compatibility table
(docs/ops/upgrading.md) for 1.11.0
Key: FLINK-18671
URL: https://issues.apache.org/jira/browse/FLINK-18671
Project:
Piotr Nowojski created FLINK-18662:
--
Summary: Provide more detailed metrics why unaligned checkpoint is
taking long time
Key: FLINK-18662
URL: https://issues.apache.org/jira/browse/FLINK-18662
Piotr Nowojski created FLINK-18656:
--
Summary: Start Delay metric is always zero for unaligned
checkpoints
Key: FLINK-18656
URL: https://issues.apache.org/jira/browse/FLINK-18656
Project: Flink
Piotr Nowojski created FLINK-18647:
--
Summary: How to handle processing time timers with bounded input
Key: FLINK-18647
URL: https://issues.apache.org/jira/browse/FLINK-18647
Project: Flink
Piotr Nowojski created FLINK-18497:
--
Summary: Publish Docerfiles for release 1.11.0
Key: FLINK-18497
URL: https://issues.apache.org/jira/browse/FLINK-18497
Project: Flink
Issue Type: Task
Piotr Nowojski created FLINK-18431:
--
Summary: Provide default empty implementation of
notifyCheckpointAborted
Key: FLINK-18431
URL: https://issues.apache.org/jira/browse/FLINK-18431
Project: Flink
Piotr Nowojski created FLINK-18374:
--
Summary:
HadoopS3RecoverableWriterITCase.testRecoverAfterMultiplePersistsStateWithMultiPart
produced no output for 900 seconds
Key: FLINK-18374
URL:
Piotr Nowojski created FLINK-18369:
--
Summary:
TableEnvironmentITCase.testStatementSetWithSameSinkTableNames failed on azure
Key: FLINK-18369
URL: https://issues.apache.org/jira/browse/FLINK-18369
Piotr Nowojski created FLINK-18356:
--
Summary: Exit code 137 returned from process when testing pyflink
Key: FLINK-18356
URL: https://issues.apache.org/jira/browse/FLINK-18356
Project: Flink
Piotr Nowojski created FLINK-18349:
--
Summary: Add Flink 1.11 release notes to documentation
Key: FLINK-18349
URL: https://issues.apache.org/jira/browse/FLINK-18349
Project: Flink
Issue
Piotr Nowojski created FLINK-18341:
--
Summary: Building Flink Walkthrough Table Java 0.1 COMPILATION
ERROR
Key: FLINK-18341
URL: https://issues.apache.org/jira/browse/FLINK-18341
Project: Flink
Piotr Nowojski created FLINK-18335:
--
Summary:
NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted time outs
Key: FLINK-18335
URL: https://issues.apache.org/jira/browse/FLINK-18335
Project:
Piotr Nowojski created FLINK-18317:
--
Summary: Verify dependencies licencses in Flink 1.11
Key: FLINK-18317
URL: https://issues.apache.org/jira/browse/FLINK-18317
Project: Flink
Issue Type:
Piotr Nowojski created FLINK-18238:
--
Summary: RemoteChannelThroughputBenchmark deadlocks
Key: FLINK-18238
URL: https://issues.apache.org/jira/browse/FLINK-18238
Project: Flink
Issue Type:
Piotr Nowojski created FLINK-18064:
--
Summary: Update documentation taking unaligned checkpoints into
the account
Key: FLINK-18064
URL: https://issues.apache.org/jira/browse/FLINK-18064
Project:
Piotr Nowojski created FLINK-17928:
--
Summary: Incorrect state size reported when using unaligned
checkpoints
Key: FLINK-17928
URL: https://issues.apache.org/jira/browse/FLINK-17928
Project: Flink
Piotr Nowojski created FLINK-17918:
--
Summary: Jobs with two input operators are loosing data in
unaligned checkpoints
Key: FLINK-17918
URL: https://issues.apache.org/jira/browse/FLINK-17918
Project:
Piotr Nowojski created FLINK-17842:
--
Summary: Performance regression on 19.05.2020
Key: FLINK-17842
URL: https://issues.apache.org/jira/browse/FLINK-17842
Project: Flink
Issue Type: Bug
Piotr Nowojski created FLINK-17813:
--
Summary: Manually test unaligned checkpoints on a cluster
Key: FLINK-17813
URL: https://issues.apache.org/jira/browse/FLINK-17813
Project: Flink
Issue
Piotr Nowojski created FLINK-17805:
--
Summary: InputProcessorUtil doesn't handle indexes for multiple
inputs operators correctly
Key: FLINK-17805
URL: https://issues.apache.org/jira/browse/FLINK-17805
Piotr Nowojski created FLINK-17799:
--
Summary: Performance regression in all network benchmarks
Key: FLINK-17799
URL: https://issues.apache.org/jira/browse/FLINK-17799
Project: Flink
Issue
Piotr Nowojski created FLINK-17754:
--
Summary: Walkthrough Table Java nightly end-to-end test failed to
compile
Key: FLINK-17754
URL: https://issues.apache.org/jira/browse/FLINK-17754
Project: Flink
Piotr Nowojski created FLINK-17739:
--
Summary: ResultPartitionTest.testInitializeMoreStateThanBuffer is
unstable
Key: FLINK-17739
URL: https://issues.apache.org/jira/browse/FLINK-17739
Project: Flink
Piotr Nowojski created FLINK-17682:
--
Summary: HiveModuleTest.testConstantReturnValue didn't finish
Key: FLINK-17682
URL: https://issues.apache.org/jira/browse/FLINK-17682
Project: Flink
Piotr Nowojski created FLINK-17663:
--
Summary: CheckpointBarrierUnaligner.getFlattenedChannelIndex can
throw ArrayIndexOutOfBoundsException
Key: FLINK-17663
URL: https://issues.apache.org/jira/browse/FLINK-17663
Piotr Nowojski created FLINK-17607:
--
Summary: TableEnvironmentITCase.testStatementSet fails on azure
Key: FLINK-17607
URL: https://issues.apache.org/jira/browse/FLINK-17607
Project: Flink
Piotr Nowojski created FLINK-17555:
--
Summary: docstring of
pyflink.table.descriptors.FileSystem:1:duplicate object description of
pyflink.table.descriptors.FileSystem
Key: FLINK-17555
URL:
Piotr Nowojski created FLINK-17552:
--
Summary: UnionInputGate shouldn't be caching InputChannels
Key: FLINK-17552
URL: https://issues.apache.org/jira/browse/FLINK-17552
Project: Flink
Piotr Nowojski created FLINK-17505:
--
Summary: Merge small files produced by StreamingFileSink
Key: FLINK-17505
URL: https://issues.apache.org/jira/browse/FLINK-17505
Project: Flink
Issue
Piotr Nowojski created FLINK-17477:
--
Summary: resumeConsumption call should happen as quickly as
possible to minimise latency
Key: FLINK-17477
URL: https://issues.apache.org/jira/browse/FLINK-17477
Piotr Nowojski created FLINK-17468:
--
Summary: Provide more detailed metrics why asynchronous part of
checkpoint is taking long time
Key: FLINK-17468
URL: https://issues.apache.org/jira/browse/FLINK-17468
Piotr Nowojski created FLINK-17454:
--
Summary: test_configuration.py ConfigurationTests::test_add_all
failed on travis
Key: FLINK-17454
URL: https://issues.apache.org/jira/browse/FLINK-17454
Project:
Piotr Nowojski created FLINK-17440:
--
Summary: Potential Buffer leak in output unspilling for unaligned
checkpoints
Key: FLINK-17440
URL: https://issues.apache.org/jira/browse/FLINK-17440
Project:
Piotr Nowojski created FLINK-17421:
--
Summary: Backpressure new checkpoints if previous were not managed
to be cleaned up yet
Key: FLINK-17421
URL: https://issues.apache.org/jira/browse/FLINK-17421
Piotr Nowojski created FLINK-17351:
--
Summary: CheckpointCoordinator and CheckpointFailureManager
ignores checkpoint timeouts
Key: FLINK-17351
URL: https://issues.apache.org/jira/browse/FLINK-17351
Piotr Nowojski created FLINK-17350:
--
Summary: StreamTask should always fail immediately on failures in
synchronous part of a checkpoint
Key: FLINK-17350
URL: https://issues.apache.org/jira/browse/FLINK-17350
Piotr Nowojski created FLINK-17207:
--
Summary: Lots of test_ci Python tests failing with OSError: [Errno
9] Bad file descriptor
Key: FLINK-17207
URL: https://issues.apache.org/jira/browse/FLINK-17207
Piotr Nowojski created FLINK-17205:
--
Summary: test_ci Python fails with unable to execute 'gcc': No
such file or directory
Key: FLINK-17205
URL: https://issues.apache.org/jira/browse/FLINK-17205
Piotr Nowojski created FLINK-17138:
--
Summary: LocalExecutorITCase.testParameterizedTypes failed on
travis
Key: FLINK-17138
URL: https://issues.apache.org/jira/browse/FLINK-17138
Project: Flink
Piotr Nowojski created FLINK-17122:
--
Summary: Support InputSelectable and BoundedMultiInput operators
with checkpointing
Key: FLINK-17122
URL: https://issues.apache.org/jira/browse/FLINK-17122
Piotr Nowojski created FLINK-17051:
--
Summary: Persist spilled records of
SpillingAdaptiveSpanningRecordDeserializer
Key: FLINK-17051
URL: https://issues.apache.org/jira/browse/FLINK-17051
Project:
Piotr Nowojski created FLINK-16974:
--
Summary: Azure build failed with OutOfMemoryError: unable to
create new native thread
Key: FLINK-16974
URL: https://issues.apache.org/jira/browse/FLINK-16974
Piotr Nowojski created FLINK-16973:
--
Summary: Various builds failing with "Corrupted STDOUT by directly
writing"
Key: FLINK-16973
URL: https://issues.apache.org/jira/browse/FLINK-16973
Project:
Piotr Nowojski created FLINK-16959:
--
Summary: 'Walkthrough Table Java nightly end-to-end test' [FAIL]
Test script contains errors
Key: FLINK-16959
URL: https://issues.apache.org/jira/browse/FLINK-16959
Piotr Nowojski created FLINK-16956:
--
Summary: Git fetch failed with exit code 128
Key: FLINK-16956
URL: https://issues.apache.org/jira/browse/FLINK-16956
Project: Flink
Issue Type: Bug
Piotr Nowojski created FLINK-16947:
--
Summary: ArtifactResolutionException: Could not transfer artifact.
Entry [...] has not been leased from this poo
Key: FLINK-16947
URL:
Piotr Nowojski created FLINK-16944:
--
Summary: Compile error in. DumpCompiledPlanTest and
PreviewPlanDumpTest
Key: FLINK-16944
URL: https://issues.apache.org/jira/browse/FLINK-16944
Project: Flink
Piotr Nowojski created FLINK-16911:
--
Summary: PrestoS3FileSystemITCase#testSimpleFileWriteAndRead fails
on checkPathExistence
Key: FLINK-16911
URL: https://issues.apache.org/jira/browse/FLINK-16911
Piotr Nowojski created FLINK-16910:
--
Summary: The job running on agent Hosted Agent ran longer than the
maximum time of 240 minutes
Key: FLINK-16910
URL: https://issues.apache.org/jira/browse/FLINK-16910
Piotr Nowojski created FLINK-16908:
--
Summary: FlinkKafkaProducerITCase testScaleUpAfterScalingDown
Timeout expired while initializing transactional state in 6ms.
Key: FLINK-16908
URL:
Piotr Nowojski created FLINK-16906:
--
Summary: TPC-DS end-to-end test (Blink planner) failed after 80
minutes
Key: FLINK-16906
URL: https://issues.apache.org/jira/browse/FLINK-16906
Project: Flink
Piotr Nowojski created FLINK-16806:
--
Summary: Implement Input selection for MultipleInputStreamOperator
Key: FLINK-16806
URL: https://issues.apache.org/jira/browse/FLINK-16806
Project: Flink
Piotr Nowojski created FLINK-16695:
--
Summary: PrometheusReporterEndToEndITCase failed on travis
Key: FLINK-16695
URL: https://issues.apache.org/jira/browse/FLINK-16695
Project: Flink
Issue
Piotr Nowojski created FLINK-16694:
--
Summary: Resuming Externalized Checkpoint end-to-end test failed
on travis
Key: FLINK-16694
URL: https://issues.apache.org/jira/browse/FLINK-16694
Project: Flink
Piotr Nowojski created FLINK-16676:
--
Summary: test_pipeline_from_invalid_json failed on Azure
Key: FLINK-16676
URL: https://issues.apache.org/jira/browse/FLINK-16676
Project: Flink
Issue
101 - 200 of 358 matches
Mail list logo
