Stephan Ewen created FLINK-24852:
Summary: Cleanup of Orphaned Incremental State Artifacts
Key: FLINK-24852
URL: https://issues.apache.org/jira/browse/FLINK-24852
Project: Flink
Issue Type:
Stephan Ewen created FLINK-24366:
Summary: Unnecessary/misleading error message about failing
restores when tasks are already canceled.
Key: FLINK-24366
URL: https://issues.apache.org/jira/browse/FLINK-24366
Stephan Ewen created FLINK-24343:
Summary: Revisit Scheduler and Coordinator Startup Procedure
Key: FLINK-24343
URL: https://issues.apache.org/jira/browse/FLINK-24343
Project: Flink
Issue
Stephan Ewen created FLINK-24255:
Summary: Test Environment / Mini Cluster do not forward
configuration.
Key: FLINK-24255
URL: https://issues.apache.org/jira/browse/FLINK-24255
Project: Flink
Stephan Ewen created FLINK-23843:
Summary: Exceptions during
"SplitEnumeratorContext.runInCoordinatorThread()" should cause Global Failure
instead of Process Kill
Key: FLINK-23843
URL:
Stephan Ewen created FLINK-23842:
Summary: Add log messages for reader registrations and split
requests.
Key: FLINK-23842
URL: https://issues.apache.org/jira/browse/FLINK-23842
Project: Flink
Stephan Ewen created FLINK-23649:
Summary: Add RocksDB packages to parent-first classloading
patterns.
Key: FLINK-23649
URL: https://issues.apache.org/jira/browse/FLINK-23649
Project: Flink
Stephan Ewen created FLINK-23630:
Summary: Make EventTimeWindowCheckpointingITCase and
LocalRecoveryITCase run on Windows.
Key: FLINK-23630
URL: https://issues.apache.org/jira/browse/FLINK-23630
Stephan Ewen created FLINK-23629:
Summary: Remove redundant test cases in
EventTimeWindowCheckpointingITCase
Key: FLINK-23629
URL: https://issues.apache.org/jira/browse/FLINK-23629
Project: Flink
Stephan Ewen created FLINK-23301:
Summary: StateFun HTTP Ingress
Key: FLINK-23301
URL: https://issues.apache.org/jira/browse/FLINK-23301
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-23281:
Summary: StateFun - Simplify Getting Stared Experience with HTTP
Ingresses and Egresses
Key: FLINK-23281
URL: https://issues.apache.org/jira/browse/FLINK-23281
Stephan Ewen created FLINK-23261:
Summary: StateFun - HTTP State Access Interface
Key: FLINK-23261
URL: https://issues.apache.org/jira/browse/FLINK-23261
Project: Flink
Issue Type:
Stephan Ewen created FLINK-23093:
Summary: Limit number of I/O pool and Future threads in Mini
Cluster
Key: FLINK-23093
URL: https://issues.apache.org/jira/browse/FLINK-23093
Project: Flink
Stephan Ewen created FLINK-22753:
Summary: Activate log-based Checkpoints for StateFun
Key: FLINK-22753
URL: https://issues.apache.org/jira/browse/FLINK-22753
Project: Flink
Issue Type:
Stephan Ewen created FLINK-22752:
Summary: Add robust default state configuration to StateFun
Key: FLINK-22752
URL: https://issues.apache.org/jira/browse/FLINK-22752
Project: Flink
Issue
Stephan Ewen created FLINK-22751:
Summary: Reduce JVM Metaspace memory for StateFun
Key: FLINK-22751
URL: https://issues.apache.org/jira/browse/FLINK-22751
Project: Flink
Issue Type:
Stephan Ewen created FLINK-22749:
Summary: Apply a robust default State Backend Configuration
Key: FLINK-22749
URL: https://issues.apache.org/jira/browse/FLINK-22749
Project: Flink
Issue
Stephan Ewen created FLINK-22741:
Summary: Hide Flink complexity from Stateful Functions
Key: FLINK-22741
URL: https://issues.apache.org/jira/browse/FLINK-22741
Project: Flink
Issue Type:
Stephan Ewen created FLINK-22729:
Summary: Truncated Messages in Python workers
Key: FLINK-22729
URL: https://issues.apache.org/jira/browse/FLINK-22729
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-22433:
Summary: CoordinatorEventsExactlyOnceITCase stalls on Adaptive
Scheduler
Key: FLINK-22433
URL: https://issues.apache.org/jira/browse/FLINK-22433
Project: Flink
Stephan Ewen created FLINK-22406:
Summary: ReactiveModeITCase.testScaleDownOnTaskManagerLoss()
Key: FLINK-22406
URL: https://issues.apache.org/jira/browse/FLINK-22406
Project: Flink
Issue
Stephan Ewen created FLINK-22358:
Summary: Add missing stability annotation to Split Reader API
classes
Key: FLINK-22358
URL: https://issues.apache.org/jira/browse/FLINK-22358
Project: Flink
Stephan Ewen created FLINK-22357:
Summary: Mark FLIP-27 Source API as stable
Key: FLINK-22357
URL: https://issues.apache.org/jira/browse/FLINK-22357
Project: Flink
Issue Type: Task
Stephan Ewen created FLINK-22324:
Summary: Backport FLINK-18071 for 1.12.x
Key: FLINK-22324
URL: https://issues.apache.org/jira/browse/FLINK-22324
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-22093:
Summary: Unstable test
"ThreadInfoSampleServiceTest.testShouldThrowExceptionIfTaskIsNotRunningBeforeSampling"
Key: FLINK-22093
URL:
Stephan Ewen created FLINK-22069:
Summary: Check Log Pollution for 1.13 release
Key: FLINK-22069
URL: https://issues.apache.org/jira/browse/FLINK-22069
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-21996:
Summary: Transient RPC failure without TaskManager failure can
lead to split assignment loss
Key: FLINK-21996
URL: https://issues.apache.org/jira/browse/FLINK-21996
Stephan Ewen created FLINK-21935:
Summary: Remove "state.backend.async" option.
Key: FLINK-21935
URL: https://issues.apache.org/jira/browse/FLINK-21935
Project: Flink
Issue Type: Improvement
Stephan Ewen created FLINK-21695:
Summary: Increase default value for number of KeyGroups
Key: FLINK-21695
URL: https://issues.apache.org/jira/browse/FLINK-21695
Project: Flink
Issue Type:
Stephan Ewen created FLINK-21694:
Summary: Increase default value of
"state.backend.rocksdb.checkpoint.transfer.thread.num"
Key: FLINK-21694
URL: https://issues.apache.org/jira/browse/FLINK-21694
Stephan Ewen created FLINK-20472:
Summary: Change quickstarts to have a dependency on "flink-dist"
Key: FLINK-20472
URL: https://issues.apache.org/jira/browse/FLINK-20472
Project: Flink
Stephan Ewen created FLINK-20413:
Summary: Sources should add splits back in "resetSubtask()",
rather than in "subtaskFailed()".
Key: FLINK-20413
URL: https://issues.apache.org/jira/browse/FLINK-20413
Stephan Ewen created FLINK-20412:
Summary: Collect Result Fetching occasionally fails after a
JobManager Failover
Key: FLINK-20412
URL: https://issues.apache.org/jira/browse/FLINK-20412
Project:
Stephan Ewen created FLINK-20406:
Summary: Return the Checkpoint ID of the restored Checkpoint in
CheckpointCoordinator.restoreLatestCheckpointedStateToSubtasks()
Key: FLINK-20406
URL:
Stephan Ewen created FLINK-20397:
Summary: Pass checkpointId to
OperatorCoordinator.resetToCheckpoint().
Key: FLINK-20397
URL: https://issues.apache.org/jira/browse/FLINK-20397
Project: Flink
Stephan Ewen created FLINK-20396:
Summary: Replace "OperatorCoordinator.subtaskFailed()" with
"subtaskRestored()"
Key: FLINK-20396
URL: https://issues.apache.org/jira/browse/FLINK-20396
Project:
Stephan Ewen created FLINK-20379:
Summary: New Kafka Connector does not support DeserializationSchema
Key: FLINK-20379
URL: https://issues.apache.org/jira/browse/FLINK-20379
Project: Flink
Stephan Ewen created FLINK-20276:
Summary: Transparent DeCompression of streams missing on new File
Source
Key: FLINK-20276
URL: https://issues.apache.org/jira/browse/FLINK-20276
Project: Flink
Stephan Ewen created FLINK-20188:
Summary: Add Documentation for new File Source
Key: FLINK-20188
URL: https://issues.apache.org/jira/browse/FLINK-20188
Project: Flink
Issue Type: Task
Stephan Ewen created FLINK-20063:
Summary: File Source requests an additional split on every restore.
Key: FLINK-20063
URL: https://issues.apache.org/jira/browse/FLINK-20063
Project: Flink
Stephan Ewen created FLINK-20049:
Summary: Simplify handling of "request split".
Key: FLINK-20049
URL: https://issues.apache.org/jira/browse/FLINK-20049
Project: Flink
Issue Type:
Stephan Ewen created FLINK-20028:
Summary: FileCompactionITCase is unstable
Key: FLINK-20028
URL: https://issues.apache.org/jira/browse/FLINK-20028
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-20008:
Summary: Java Deadlock in
ZooKeeperLeaderElectionTest.testZooKeeperReelectionWithReplacement()
Key: FLINK-20008
URL: https://issues.apache.org/jira/browse/FLINK-20008
Stephan Ewen created FLINK-19804:
Summary: Make FileSource class generic with respect to split types
Key: FLINK-19804
URL: https://issues.apache.org/jira/browse/FLINK-19804
Project: Flink
Stephan Ewen created FLINK-19803:
Summary: Make File Source Checkpoint Serializer extensible
Key: FLINK-19803
URL: https://issues.apache.org/jira/browse/FLINK-19803
Project: Flink
Issue
Stephan Ewen created FLINK-19802:
Summary: Let BulkFormat createReader and restoreReader methods
accept Splits directly
Key: FLINK-19802
URL: https://issues.apache.org/jira/browse/FLINK-19802
Stephan Ewen created FLINK-19800:
Summary: Make FileSourceSplit / FileSourceSplitState interaction
extensible.
Key: FLINK-19800
URL: https://issues.apache.org/jira/browse/FLINK-19800
Project: Flink
Stephan Ewen created FLINK-19799:
Summary: Make FileSource extensible
Key: FLINK-19799
URL: https://issues.apache.org/jira/browse/FLINK-19799
Project: Flink
Issue Type: Improvement
Stephan Ewen created FLINK-19516:
Summary: PerJobMiniClusterFactoryTest. testJobClient()
Key: FLINK-19516
URL: https://issues.apache.org/jira/browse/FLINK-19516
Project: Flink
Issue Type:
Stephan Ewen created FLINK-19514:
Summary:
ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange times
out
Key: FLINK-19514
URL: https://issues.apache.org/jira/browse/FLINK-19514
Stephan Ewen created FLINK-19499:
Summary: Expose Metric Groups to Split Assigners
Key: FLINK-19499
URL: https://issues.apache.org/jira/browse/FLINK-19499
Project: Flink
Issue Type:
Stephan Ewen created FLINK-19498:
Summary: Port LocatableInputSplitAssigner to new File Source API
Key: FLINK-19498
URL: https://issues.apache.org/jira/browse/FLINK-19498
Project: Flink
Stephan Ewen created FLINK-19494:
Summary: Adjust "StreamExecutionEnvironment.generateSequence()" to
new API Sources
Key: FLINK-19494
URL: https://issues.apache.org/jira/browse/FLINK-19494
Project:
Stephan Ewen created FLINK-19492:
Summary: Consolidate Source Events between Source API and Split
Reader API
Key: FLINK-19492
URL: https://issues.apache.org/jira/browse/FLINK-19492
Project: Flink
Stephan Ewen created FLINK-19457:
Summary: Port NumberSequenceSource to FLIP-27 source interface
Key: FLINK-19457
URL: https://issues.apache.org/jira/browse/FLINK-19457
Project: Flink
Issue
Stephan Ewen created FLINK-19384:
Summary: Source API exception signatures are inconsistent
Key: FLINK-19384
URL: https://issues.apache.org/jira/browse/FLINK-19384
Project: Flink
Issue Type:
Stephan Ewen created FLINK-19278:
Summary: Bump Scala Macros Version to 2.1.1
Key: FLINK-19278
URL: https://issues.apache.org/jira/browse/FLINK-19278
Project: Flink
Issue Type: Improvement
Stephan Ewen created FLINK-19265:
Summary: Simplify handling of 'NoMoreSplitsEvent'
Key: FLINK-19265
URL: https://issues.apache.org/jira/browse/FLINK-19265
Project: Flink
Issue Type:
Stephan Ewen created FLINK-19251:
Summary: Avoid confusing queue handling in
"SplitReader.handleSplitsChanges()"
Key: FLINK-19251
URL: https://issues.apache.org/jira/browse/FLINK-19251
Project: Flink
Stephan Ewen created FLINK-19250:
Summary: SplitFetcherManager does not propagate errors correctly
Key: FLINK-19250
URL: https://issues.apache.org/jira/browse/FLINK-19250
Project: Flink
Stephan Ewen created FLINK-19245:
Summary: Set default queue capacity for FLIP-27 source handover
queue to 2
Key: FLINK-19245
URL: https://issues.apache.org/jira/browse/FLINK-19245
Project: Flink
Stephan Ewen created FLINK-19225:
Summary: Improve code and logging in SourceReaderBase
Key: FLINK-19225
URL: https://issues.apache.org/jira/browse/FLINK-19225
Project: Flink
Issue Type:
Stephan Ewen created FLINK-19223:
Summary: Simplify Availability Future Model in Base Connector
Key: FLINK-19223
URL: https://issues.apache.org/jira/browse/FLINK-19223
Project: Flink
Issue
Stephan Ewen created FLINK-19221:
Summary: Exploit LocatableFileStatus from Hadoop
Key: FLINK-19221
URL: https://issues.apache.org/jira/browse/FLINK-19221
Project: Flink
Issue Type:
Stephan Ewen created FLINK-19218:
Summary: Remove inconsistent host logic for LocalFileSystem
Key: FLINK-19218
URL: https://issues.apache.org/jira/browse/FLINK-19218
Project: Flink
Issue
Stephan Ewen created FLINK-19205:
Summary: SourceReaderContext should give access to Configuration
and Hostbame
Key: FLINK-19205
URL: https://issues.apache.org/jira/browse/FLINK-19205
Project: Flink
Stephan Ewen created FLINK-19162:
Summary: Allow Split Reader based sources to reuse record batches
Key: FLINK-19162
URL: https://issues.apache.org/jira/browse/FLINK-19162
Project: Flink
Stephan Ewen created FLINK-19161:
Summary: Port File Sources to FLIP-27 API
Key: FLINK-19161
URL: https://issues.apache.org/jira/browse/FLINK-19161
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-19087:
Summary: ReaultPartitionWriter should not expose subpartition but
only subpartition-readers
Key: FLINK-19087
URL: https://issues.apache.org/jira/browse/FLINK-19087
Stephan Ewen created FLINK-19047:
Summary: Move unaligned checkpoint methods from ResultPartition to
separate interface.
Key: FLINK-19047
URL: https://issues.apache.org/jira/browse/FLINK-19047
Stephan Ewen created FLINK-19046:
Summary: Introduce separate classes for PipelinedResultPartition
and BoundedBlockingResultPartition
Key: FLINK-19046
URL: https://issues.apache.org/jira/browse/FLINK-19046
Stephan Ewen created FLINK-19045:
Summary: Remove obsolete option
'taskmanager.network.partition.force-release-on-consumption'
Key: FLINK-19045
URL: https://issues.apache.org/jira/browse/FLINK-19045
Stephan Ewen created FLINK-19024:
Summary: Remove unused "releaseMemory" from ResultSubpartition
Key: FLINK-19024
URL: https://issues.apache.org/jira/browse/FLINK-19024
Project: Flink
Issue
Stephan Ewen created FLINK-19023:
Summary: Remove pruning of Record Serializer Buffer
Key: FLINK-19023
URL: https://issues.apache.org/jira/browse/FLINK-19023
Project: Flink
Issue Type:
Stephan Ewen created FLINK-19021:
Summary: Cleanups of the ResultPartition components
Key: FLINK-19021
URL: https://issues.apache.org/jira/browse/FLINK-19021
Project: Flink
Issue Type:
Stephan Ewen created FLINK-18447:
Summary: Add 'flink-connector-base' to 'flink-dist'
Key: FLINK-18447
URL: https://issues.apache.org/jira/browse/FLINK-18447
Project: Flink
Issue Type:
Stephan Ewen created FLINK-18430:
Summary: Upgrade stability to @Public for CheckpointedFunction and
CheckpointListener
Key: FLINK-18430
URL: https://issues.apache.org/jira/browse/FLINK-18430
Stephan Ewen created FLINK-18429:
Summary: Add default method for
CheckpointListener.notifyCheckpointAborted(checkpointId)
Key: FLINK-18429
URL: https://issues.apache.org/jira/browse/FLINK-18429
Stephan Ewen created FLINK-18307:
Summary: Replace "slave" file name with "workers"
Key: FLINK-18307
URL: https://issues.apache.org/jira/browse/FLINK-18307
Project: Flink
Issue Type:
Stephan Ewen created FLINK-18124:
Summary: Add documentation for new FLIP-27 source interface
Key: FLINK-18124
URL: https://issues.apache.org/jira/browse/FLINK-18124
Project: Flink
Issue
Stephan Ewen created FLINK-18091:
Summary: Test Relocatable Savepoints
Key: FLINK-18091
URL: https://issues.apache.org/jira/browse/FLINK-18091
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-17950:
Summary: Broken Scala env.countinuousSource method
Key: FLINK-17950
URL: https://issues.apache.org/jira/browse/FLINK-17950
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-17906:
Summary: Fix performance issues in WatermarkOutputMultiplexer
Key: FLINK-17906
URL: https://issues.apache.org/jira/browse/FLINK-17906
Project: Flink
Issue
Stephan Ewen created FLINK-17904:
Summary: Add "scheduleWithFixedDelay" to ProcessingTimeService
Key: FLINK-17904
URL: https://issues.apache.org/jira/browse/FLINK-17904
Project: Flink
Issue
Stephan Ewen created FLINK-17903:
Summary: Evolve WatermarkOutputMultiplexer to make it reusable in
FLIP-27 Sources
Key: FLINK-17903
URL: https://issues.apache.org/jira/browse/FLINK-17903
Project:
Stephan Ewen created FLINK-17899:
Summary: Integrate FLIP-126 Timestamps and Watermarking with
FLIP-27 sources
Key: FLINK-17899
URL: https://issues.apache.org/jira/browse/FLINK-17899
Project: Flink
Stephan Ewen created FLINK-17898:
Summary: Remove Exceptions from signatures of SourceOutput methods
Key: FLINK-17898
URL: https://issues.apache.org/jira/browse/FLINK-17898
Project: Flink
Stephan Ewen created FLINK-17897:
Summary: Resolve stability annotations discussion for FLIP-27 in
1.11
Key: FLINK-17897
URL: https://issues.apache.org/jira/browse/FLINK-17897
Project: Flink
Stephan Ewen created FLINK-17854:
Summary: Use InputStatus directly in user-facing async input APIs
(like source readers)
Key: FLINK-17854
URL: https://issues.apache.org/jira/browse/FLINK-17854
Stephan Ewen created FLINK-17850:
Summary: PostgresCatalogITCase . testGroupByInsert() fails on CI
Key: FLINK-17850
URL: https://issues.apache.org/jira/browse/FLINK-17850
Project: Flink
Stephan Ewen created FLINK-17849:
Summary: YARNHighAvailabilityITCase hangs in Azure Pipelines CI
Key: FLINK-17849
URL: https://issues.apache.org/jira/browse/FLINK-17849
Project: Flink
Issue
Stephan Ewen created FLINK-17816:
Summary: Change Latency Marker to work with "scheduleAtFixedDelay"
instead of "scheduleAtFixedRate"
Key: FLINK-17816
URL: https://issues.apache.org/jira/browse/FLINK-17816
Stephan Ewen created FLINK-17781:
Summary: OperatorCoordinator Context must support calls from
thread other than JobMaster Main Thread
Key: FLINK-17781
URL: https://issues.apache.org/jira/browse/FLINK-17781
Stephan Ewen created FLINK-17702:
Summary: OperatorCoordinators must be notified of tasks cancelled
as part of failover
Key: FLINK-17702
URL: https://issues.apache.org/jira/browse/FLINK-17702
Stephan Ewen created FLINK-17701:
Summary: Exclude jdk:tools dependency from all Hadoop dependencies
for Java 9+ compatibility
Key: FLINK-17701
URL: https://issues.apache.org/jira/browse/FLINK-17701
Stephan Ewen created FLINK-17699:
Summary: Reduce scope for SourceOperator arguments and initialize
more eagerly
Key: FLINK-17699
URL: https://issues.apache.org/jira/browse/FLINK-17699
Project: Flink
Stephan Ewen created FLINK-17696:
Summary: Support eager initialization of operators with
OperatorEventDispatcher
Key: FLINK-17696
URL: https://issues.apache.org/jira/browse/FLINK-17696
Project:
Stephan Ewen created FLINK-17695:
Summary: Simplify SourceOperator by using a utility
SimpleVersionedListState
Key: FLINK-17695
URL: https://issues.apache.org/jira/browse/FLINK-17695
Project: Flink
Stephan Ewen created FLINK-17694:
Summary: Wrong min-length check in SimpleVersionedSerialization
Key: FLINK-17694
URL: https://issues.apache.org/jira/browse/FLINK-17694
Project: Flink
Issue
Stephan Ewen created FLINK-17674:
Summary: OperatorCoordinator state in checkpoints should always be
a ByteStreamStateHandle
Key: FLINK-17674
URL: https://issues.apache.org/jira/browse/FLINK-17674
1 - 100 of 711 matches
Mail list logo
