Stefan Richter created FLINK-34693:
--
Summary: Memory leak in KafkaWriter
Key: FLINK-34693
URL: https://issues.apache.org/jira/browse/FLINK-34693
Project: Flink
Issue Type: Bug
Stefan Richter created FLINK-34579:
--
Summary: Introduce metric for time since last completed checkpoint
Key: FLINK-34579
URL: https://issues.apache.org/jira/browse/FLINK-34579
Project: Flink
Stefan Richter created FLINK-34546:
--
Summary: Emit span with failure labels on failure
Key: FLINK-34546
URL: https://issues.apache.org/jira/browse/FLINK-34546
Project: Flink
Issue Type:
Stefan Richter created FLINK-34199:
--
Summary: Add tracing for durations of rescaling/restoring from
local state
Key: FLINK-34199
URL: https://issues.apache.org/jira/browse/FLINK-34199
Project: Flink
Stefan Richter created FLINK-34134:
--
Summary: Add tracing for restored state size and locations
Key: FLINK-34134
URL: https://issues.apache.org/jira/browse/FLINK-34134
Project: Flink
Issue
Stefan Richter created FLINK-33341:
--
Summary: Use available local state for rescaling
Key: FLINK-33341
URL: https://issues.apache.org/jira/browse/FLINK-33341
Project: Flink
Issue Type:
Stefan Richter created FLINK-33246:
--
Summary: Add RescalingIT case that uses checkpoints and resource
requests
Key: FLINK-33246
URL: https://issues.apache.org/jira/browse/FLINK-33246
Project: Flink
Stefan Richter created FLINK-33077:
--
Summary: Minimize the risk of hard back-pressure with buffer
debloating enabled
Key: FLINK-33077
URL: https://issues.apache.org/jira/browse/FLINK-33077
Project:
Stefan Richter created FLINK-32437:
--
Summary: Determine and set correct maxParallelism for operator
chains
Key: FLINK-32437
URL: https://issues.apache.org/jira/browse/FLINK-32437
Project: Flink
Stefan Richter created FLINK-32410:
--
Summary: Allocate hash-based collections with sufficient capacity
for expected size
Key: FLINK-32410
URL: https://issues.apache.org/jira/browse/FLINK-32410
Stefan Richter created FLINK-32345:
--
Summary: Improve parallel download of RocksDB incremental state
Key: FLINK-32345
URL: https://issues.apache.org/jira/browse/FLINK-32345
Project: Flink
Stefan Richter created FLINK-32326:
--
Summary: Disable WAL in RocksDBWriteBatchWrapper by default
Key: FLINK-32326
URL: https://issues.apache.org/jira/browse/FLINK-32326
Project: Flink
Issue
Stefan Richter created FLINK-13325:
--
Summary: Add test case for FLINK-13249
Key: FLINK-13325
URL: https://issues.apache.org/jira/browse/FLINK-13325
Project: Flink
Issue Type: Sub-task
Stefan Richter created FLINK-13248:
--
Summary: Enhance mailbox executor with yield-to-downstream
functionality
Key: FLINK-13248
URL: https://issues.apache.org/jira/browse/FLINK-13248
Project: Flink
Stefan Richter created FLINK-12958:
--
Summary: Integrate AsyncWaitOperator with mailbox
Key: FLINK-12958
URL: https://issues.apache.org/jira/browse/FLINK-12958
Project: Flink
Issue Type:
Stefan Richter created FLINK-12804:
--
Summary: Introduce mailbox-based ExecutorService
Key: FLINK-12804
URL: https://issues.apache.org/jira/browse/FLINK-12804
Project: Flink
Issue Type:
Stefan Richter created FLINK-12591:
--
Summary: StatsDReporterTest is unstable
Key: FLINK-12591
URL: https://issues.apache.org/jira/browse/FLINK-12591
Project: Flink
Issue Type: Bug
Stefan Richter created FLINK-12484:
--
Summary: Drop unnecessary locking for code-paths that now use the
mailbox
Key: FLINK-12484
URL: https://issues.apache.org/jira/browse/FLINK-12484
Project: Flink
Stefan Richter created FLINK-12483:
--
Summary: Support (legacy) SourceFunctions with mailbox
Key: FLINK-12483
URL: https://issues.apache.org/jira/browse/FLINK-12483
Project: Flink
Issue
Stefan Richter created FLINK-12482:
--
Summary: Make checkpoint trigger/notifyComplete run via the
mailbox queue
Key: FLINK-12482
URL: https://issues.apache.org/jira/browse/FLINK-12482
Project: Flink
Stefan Richter created FLINK-12481:
--
Summary: Make processing time timer trigger run via the mailbox
Key: FLINK-12481
URL: https://issues.apache.org/jira/browse/FLINK-12481
Project: Flink
Stefan Richter created FLINK-12480:
--
Summary: Introduce mailbox to StreamTask main-loop
Key: FLINK-12480
URL: https://issues.apache.org/jira/browse/FLINK-12480
Project: Flink
Issue Type:
Stefan Richter created FLINK-12479:
--
Summary: Make InputProcessors and StreamIterationHead non-blocking
Key: FLINK-12479
URL: https://issues.apache.org/jira/browse/FLINK-12479
Project: Flink
Stefan Richter created FLINK-12478:
--
Summary: Decompose monolithic run-loops in StreamTask
implementations into step-wise calls
Key: FLINK-12478
URL: https://issues.apache.org/jira/browse/FLINK-12478
Stefan Richter created FLINK-12477:
--
Summary: Change threading-model in StreamTask to a mailbox-based
approach
Key: FLINK-12477
URL: https://issues.apache.org/jira/browse/FLINK-12477
Project: Flink
Stefan Richter created FLINK-12143:
--
Summary: Mechanism to ship plugin jars in the cluster
Key: FLINK-12143
URL: https://issues.apache.org/jira/browse/FLINK-12143
Project: Flink
Issue Type:
Stefan Richter created FLINK-11980:
--
Summary: Improve efficiency of iterating KeySelectionListener on
notification
Key: FLINK-11980
URL: https://issues.apache.org/jira/browse/FLINK-11980
Project:
Stefan Richter created FLINK-11956:
--
Summary: Remove shading from filesystems build
Key: FLINK-11956
URL: https://issues.apache.org/jira/browse/FLINK-11956
Project: Flink
Issue Type:
Stefan Richter created FLINK-11955:
--
Summary: Modify build to move filesystems from lib to plugins
folder
Key: FLINK-11955
URL: https://issues.apache.org/jira/browse/FLINK-11955
Project: Flink
Stefan Richter created FLINK-11953:
--
Summary: Introduce Plugin/Loading system and integrate it with
FileSystem
Key: FLINK-11953
URL: https://issues.apache.org/jira/browse/FLINK-11953
Project: Flink
Stefan Richter created FLINK-11954:
--
Summary: Provide unit test(s) for new plugin infrastructure
Key: FLINK-11954
URL: https://issues.apache.org/jira/browse/FLINK-11954
Project: Flink
Issue
Stefan Richter created FLINK-11952:
--
Summary: Introduce Plugin Architecture for loading FileSystems
Key: FLINK-11952
URL: https://issues.apache.org/jira/browse/FLINK-11952
Project: Flink
Stefan Richter created FLINK-11744:
--
Summary: Provide stable/final toHexString for AbstractID
Key: FLINK-11744
URL: https://issues.apache.org/jira/browse/FLINK-11744
Project: Flink
Issue
Stefan Richter created FLINK-11417:
--
Summary: Make access to ExecutionGraph single threaded from
JobMaster main thread
Key: FLINK-11417
URL: https://issues.apache.org/jira/browse/FLINK-11417
Stefan Richter created FLINK-11141:
--
Summary: Key generation for RocksDBMapState can theoretically be
ambiguous
Key: FLINK-11141
URL: https://issues.apache.org/jira/browse/FLINK-11141
Project: Flink
Stefan Richter created FLINK-11121:
--
Summary: Check and update licensing notes for Aliyun FS
[FLINK-10865]
Key: FLINK-11121
URL: https://issues.apache.org/jira/browse/FLINK-11121
Project: Flink
Stefan Richter created FLINK-11012:
--
Summary: Introduce abstract superclass for filesystem IT cases
Key: FLINK-11012
URL: https://issues.apache.org/jira/browse/FLINK-11012
Project: Flink
Stefan Richter created FLINK-10863:
--
Summary: Assign uids to all operators
Key: FLINK-10863
URL: https://issues.apache.org/jira/browse/FLINK-10863
Project: Flink
Issue Type: Sub-task
Stefan Richter created FLINK-10839:
--
Summary: Fix implementation of PojoSerializer.duplicate() w.r.t.
subclass serializer
Key: FLINK-10839
URL: https://issues.apache.org/jira/browse/FLINK-10839
Stefan Richter created FLINK-10828:
--
Summary: Enforce that all TypeSerializers are tested through
SerializerTestBase
Key: FLINK-10828
URL: https://issues.apache.org/jira/browse/FLINK-10828
Project:
Stefan Richter created FLINK-10827:
--
Summary: Add test for duplicate() to SerializerTestBase
Key: FLINK-10827
URL: https://issues.apache.org/jira/browse/FLINK-10827
Project: Flink
Issue
Stefan Richter created FLINK-10816:
--
Summary: Fix LockableTypeSerializer.duplicate()
Key: FLINK-10816
URL: https://issues.apache.org/jira/browse/FLINK-10816
Project: Flink
Issue Type: Bug
Stefan Richter created FLINK-10793:
--
Summary: Change visibility of TtlValue and TtlSerializer to public
for external tools
Key: FLINK-10793
URL: https://issues.apache.org/jira/browse/FLINK-10793
Stefan Richter created FLINK-10713:
--
Summary: RestartIndividualStrategy does not restore state
Key: FLINK-10713
URL: https://issues.apache.org/jira/browse/FLINK-10713
Project: Flink
Issue
Stefan Richter created FLINK-10712:
--
Summary: RestartPipelinedRegionStrategy does not restore state
Key: FLINK-10712
URL: https://issues.apache.org/jira/browse/FLINK-10712
Project: Flink
Stefan Richter created FLINK-10652:
--
Summary: Update StatefulJobWBroadcastStateMigrationITCase for 1.6
Key: FLINK-10652
URL: https://issues.apache.org/jira/browse/FLINK-10652
Project: Flink
Stefan Richter created FLINK-10650:
--
Summary: Update BucketingSinkMigrationTest for 1.6
Key: FLINK-10650
URL: https://issues.apache.org/jira/browse/FLINK-10650
Project: Flink
Issue Type:
Stefan Richter created FLINK-10651:
--
Summary: Update CEPMigrationTest for 1.6
Key: FLINK-10651
URL: https://issues.apache.org/jira/browse/FLINK-10651
Project: Flink
Issue Type: Sub-task
Stefan Richter created FLINK-10649:
--
Summary: Update FlinkKafkaConsumerBaseMigrationTest for 1.6
Key: FLINK-10649
URL: https://issues.apache.org/jira/browse/FLINK-10649
Project: Flink
Issue
Stefan Richter created FLINK-10648:
--
Summary: Update ContinuousFileProcessingMigrationTest for 1.6
Key: FLINK-10648
URL: https://issues.apache.org/jira/browse/FLINK-10648
Project: Flink
Stefan Richter created FLINK-10646:
--
Summary: Update AbstractOperatorRestoreTestBase for 1.6
Key: FLINK-10646
URL: https://issues.apache.org/jira/browse/FLINK-10646
Project: Flink
Issue
Stefan Richter created FLINK-10647:
--
Summary: Update WindowOperatorMigrationTest for 1.6
Key: FLINK-10647
URL: https://issues.apache.org/jira/browse/FLINK-10647
Project: Flink
Issue Type:
Stefan Richter created FLINK-10645:
--
Summary: Update StatefulJobSavepointMigrationITCase for 1.6
Key: FLINK-10645
URL: https://issues.apache.org/jira/browse/FLINK-10645
Project: Flink
Issue
Stefan Richter created FLINK-10490:
--
Summary: OperatorSnapshotUtil should probably use
SavepointV2Serializer
Key: FLINK-10490
URL: https://issues.apache.org/jira/browse/FLINK-10490
Project: Flink
Stefan Richter created FLINK-10433:
--
Summary: Stepwise creation of the ExecutionGraph sub-structures
Key: FLINK-10433
URL: https://issues.apache.org/jira/browse/FLINK-10433
Project: Flink
Stefan Richter created FLINK-10432:
--
Summary: Introduce bulk/group-aware scheduling
Key: FLINK-10432
URL: https://issues.apache.org/jira/browse/FLINK-10432
Project: Flink
Issue Type:
Stefan Richter created FLINK-10431:
--
Summary: Extract scheduling-related code from SlotPool
Key: FLINK-10431
URL: https://issues.apache.org/jira/browse/FLINK-10431
Project: Flink
Issue
Stefan Richter created FLINK-10430:
--
Summary: Extract scheduling-related code from Executions
Key: FLINK-10430
URL: https://issues.apache.org/jira/browse/FLINK-10430
Project: Flink
Issue
Stefan Richter created FLINK-10429:
--
Summary: Redesign Flink Scheduling, introducing dedicated
Scheduler component
Key: FLINK-10429
URL: https://issues.apache.org/jira/browse/FLINK-10429
Project:
Stefan Richter created FLINK-10377:
--
Summary: Remove precondition in
TwoPhaseCommitSinkFunction.notifyCheckpointComplete
Key: FLINK-10377
URL: https://issues.apache.org/jira/browse/FLINK-10377
Stefan Richter created FLINK-10297:
--
Summary: PostVersionedIOReadableWritable ignores result of
InputStream.read(...)
Key: FLINK-10297
URL: https://issues.apache.org/jira/browse/FLINK-10297
Project:
Stefan Richter created FLINK-10200:
--
Summary: Consolidate FileBasedStateOutputStream and
FsCheckpointStateOutputStream
Key: FLINK-10200
URL: https://issues.apache.org/jira/browse/FLINK-10200
Stefan Richter created FLINK-10176:
--
Summary: Replace ByteArrayData[Input|Output]View with
Data[Output|InputDe]Serializer
Key: FLINK-10176
URL: https://issues.apache.org/jira/browse/FLINK-10176
Stefan Richter created FLINK-10175:
--
Summary: Fix concurrent access to shared buffer in map state /
querable state
Key: FLINK-10175
URL: https://issues.apache.org/jira/browse/FLINK-10175
Project:
Stefan Richter created FLINK-10124:
--
Summary: Use ByteArrayDataInput/OutputView instead of stream +
wrapper
Key: FLINK-10124
URL: https://issues.apache.org/jira/browse/FLINK-10124
Project: Flink
Stefan Richter created FLINK-10122:
--
Summary: KafkaConsumer should use partitionable state over union
state if partition discovery is not active
Key: FLINK-10122
URL:
Stefan Richter created FLINK-10121:
--
Summary: Introduce methods to remove registered operator states
Key: FLINK-10121
URL: https://issues.apache.org/jira/browse/FLINK-10121
Project: Flink
Stefan Richter created FLINK-10068:
--
Summary: Add documentation for async/RocksDB-based timers
Key: FLINK-10068
URL: https://issues.apache.org/jira/browse/FLINK-10068
Project: Flink
Issue
Stefan Richter created FLINK-10066:
--
Summary: Keep only archived version of previous executions
Key: FLINK-10066
URL: https://issues.apache.org/jira/browse/FLINK-10066
Project: Flink
Issue
Stefan Richter created FLINK-10044:
--
Summary: Check proper RIA style and introduce it where missing
Key: FLINK-10044
URL: https://issues.apache.org/jira/browse/FLINK-10044
Project: Flink
Stefan Richter created FLINK-10043:
--
Summary: Refactor object construction/inititlization/restore code
Key: FLINK-10043
URL: https://issues.apache.org/jira/browse/FLINK-10043
Project: Flink
Stefan Richter created FLINK-10042:
--
Summary: Extract snapshot algorithms from inner classes into full
classes
Key: FLINK-10042
URL: https://issues.apache.org/jira/browse/FLINK-10042
Project: Flink
Stefan Richter created FLINK-10041:
--
Summary: Extract all different iterators (inner or static inner
classes) into full classes
Key: FLINK-10041
URL: https://issues.apache.org/jira/browse/FLINK-10041
Stefan Richter created FLINK-10040:
--
Summary: Decompose RocksDBKeyedStateBackend
Key: FLINK-10040
URL: https://issues.apache.org/jira/browse/FLINK-10040
Project: Flink
Issue Type:
Stefan Richter created FLINK-10028:
--
Summary: Introduce ByteArrayData[Input|Output]View
Key: FLINK-10028
URL: https://issues.apache.org/jira/browse/FLINK-10028
Project: Flink
Issue Type:
Stefan Richter created FLINK-10026:
--
Summary: Integrate heap based timers in RocksDB backend with
incremental checkpoints
Key: FLINK-10026
URL: https://issues.apache.org/jira/browse/FLINK-10026
Stefan Richter created FLINK-9981:
-
Summary: Tune performance of RocksDB implementation
Key: FLINK-9981
URL: https://issues.apache.org/jira/browse/FLINK-9981
Project: Flink
Issue Type:
Stefan Richter created FLINK-9918:
-
Summary: Outsource fastutil dependency to flink-shading.
Key: FLINK-9918
URL: https://issues.apache.org/jira/browse/FLINK-9918
Project: Flink
Issue Type:
Stefan Richter created FLINK-9902:
-
Summary: Improve and refactor window checkpointing IT cases
Key: FLINK-9902
URL: https://issues.apache.org/jira/browse/FLINK-9902
Project: Flink
Issue
Stefan Richter created FLINK-9887:
-
Summary: Ensure serializer upgrades work with timer service remake
Key: FLINK-9887
URL: https://issues.apache.org/jira/browse/FLINK-9887
Project: Flink
Stefan Richter created FLINK-9799:
-
Summary: Generalize/unify state meta info
Key: FLINK-9799
URL: https://issues.apache.org/jira/browse/FLINK-9799
Project: Flink
Issue Type: Sub-task
Stefan Richter created FLINK-9702:
-
Summary: Improvement in (de)serialization of keys and values for
RocksDB state
Key: FLINK-9702
URL: https://issues.apache.org/jira/browse/FLINK-9702
Project: Flink
Stefan Richter created FLINK-9490:
-
Summary: Provide backwards compatibility for timer state of Flink
1.5
Key: FLINK-9490
URL: https://issues.apache.org/jira/browse/FLINK-9490
Project: Flink
Stefan Richter created FLINK-9489:
-
Summary: Checkpoint timers as part of managed keyed state instead
of raw keyed state
Key: FLINK-9489
URL: https://issues.apache.org/jira/browse/FLINK-9489
Project:
Stefan Richter created FLINK-9487:
-
Summary: Prepare InternalTimerHeap for asynchronous snapshots
Key: FLINK-9487
URL: https://issues.apache.org/jira/browse/FLINK-9487
Project: Flink
Issue
Stefan Richter created FLINK-9486:
-
Summary: Introduce TimerState in keyed state backend
Key: FLINK-9486
URL: https://issues.apache.org/jira/browse/FLINK-9486
Project: Flink
Issue Type:
Stefan Richter created FLINK-9485:
-
Summary: Improving Flink’s timer management for large state
Key: FLINK-9485
URL: https://issues.apache.org/jira/browse/FLINK-9485
Project: Flink
Issue
Stefan Richter created FLINK-9436:
-
Summary: Remove generic parameter namespace from
InternalTimeServiceManager
Key: FLINK-9436
URL: https://issues.apache.org/jira/browse/FLINK-9436
Project: Flink
Stefan Richter created FLINK-9390:
-
Summary: Shutdown of KafkaProducer causes confusing log message
Key: FLINK-9390
URL: https://issues.apache.org/jira/browse/FLINK-9390
Project: Flink
Issue
Stefan Richter created FLINK-9388:
-
Summary: Inconsistency in job shutdown produces confusing log
message
Key: FLINK-9388
URL: https://issues.apache.org/jira/browse/FLINK-9388
Project: Flink
Stefan Richter created FLINK-9375:
-
Summary: Introduce AbortCheckpoint message from JM to TMs
Key: FLINK-9375
URL: https://issues.apache.org/jira/browse/FLINK-9375
Project: Flink
Issue Type:
Stefan Richter created FLINK-9355:
-
Summary: Simplify configuration of local recovery to a simple
on/off
Key: FLINK-9355
URL: https://issues.apache.org/jira/browse/FLINK-9355
Project: Flink
Stefan Richter created FLINK-9304:
-
Summary: Timer service shutdown should not be interrupted
Key: FLINK-9304
URL: https://issues.apache.org/jira/browse/FLINK-9304
Project: Flink
Issue Type:
Stefan Richter created FLINK-9003:
-
Summary: Add operators with input type that goes through custom,
stateful serialization
Key: FLINK-9003
URL: https://issues.apache.org/jira/browse/FLINK-9003
Stefan Richter created FLINK-9002:
-
Summary: Add operators with input type that goes through Avro
serialization (with schema/generic)
Key: FLINK-9002
URL: https://issues.apache.org/jira/browse/FLINK-9002
Stefan Richter created FLINK-9001:
-
Summary: Add operators with input type that goes through Kryo
serialization (registered/generic/custom)
Key: FLINK-9001
URL: https://issues.apache.org/jira/browse/FLINK-9001
Stefan Richter created FLINK-8999:
-
Summary: Ensure the job has an operator with operator state.
Key: FLINK-8999
URL: https://issues.apache.org/jira/browse/FLINK-8999
Project: Flink
Issue
Stefan Richter created FLINK-8998:
-
Summary: Add user-defined watermark assigner and timestamp
extractor to the test job
Key: FLINK-8998
URL: https://issues.apache.org/jira/browse/FLINK-8998
Project:
Stefan Richter created FLINK-8997:
-
Summary: Add sliding window aggregation to the job
Key: FLINK-8997
URL: https://issues.apache.org/jira/browse/FLINK-8997
Project: Flink
Issue Type:
Stefan Richter created FLINK-8996:
-
Summary: Include an operator with broadcast and union state
Key: FLINK-8996
URL: https://issues.apache.org/jira/browse/FLINK-8996
Project: Flink
Issue
1 - 100 of 195 matches
Mail list logo
