Andrey Zagrebin created FLINK-9360:
--
Summary: HA end-to-end nightly test takes more than 15 min in
Travis CI
Key: FLINK-9360
URL: https://issues.apache.org/jira/browse/FLINK-9360
Project: Flink
Andrey Zagrebin created FLINK-9571:
--
Summary: Switch to internal states in StateBinder
Key: FLINK-9571
URL: https://issues.apache.org/jira/browse/FLINK-9571
Project: Flink
Issue Type:
Andrey Zagrebin created FLINK-9572:
--
Summary: Extend InternalAppendingState with internal stored state
access
Key: FLINK-9572
URL: https://issues.apache.org/jira/browse/FLINK-9572
Project: Flink
Andrey Zagrebin created FLINK-9510:
--
Summary: State TTL API with cleanup on explicit access
Key: FLINK-9510
URL: https://issues.apache.org/jira/browse/FLINK-9510
Project: Flink
Issue Type:
Andrey Zagrebin created FLINK-9512:
--
Summary: StateDescriptor TTL config should be part of versioned
meta info snapshot
Key: FLINK-9512
URL: https://issues.apache.org/jira/browse/FLINK-9512
Project:
Andrey Zagrebin created FLINK-9511:
--
Summary: Make StateDescriptor configurable with optional TTL
Key: FLINK-9511
URL: https://issues.apache.org/jira/browse/FLINK-9511
Project: Flink
Issue
Andrey Zagrebin created FLINK-9516:
--
Summary: Create wrapper with TTL logic for map state
Key: FLINK-9516
URL: https://issues.apache.org/jira/browse/FLINK-9516
Project: Flink
Issue Type:
Andrey Zagrebin created FLINK-9515:
--
Summary: Create wrapper with TTL logic for list state
Key: FLINK-9515
URL: https://issues.apache.org/jira/browse/FLINK-9515
Project: Flink
Issue Type:
Andrey Zagrebin created FLINK-9513:
--
Summary: Wrap state binder with TTL logic
Key: FLINK-9513
URL: https://issues.apache.org/jira/browse/FLINK-9513
Project: Flink
Issue Type: Sub-task
Andrey Zagrebin created FLINK-9514:
--
Summary: Create wrapper with TTL logic for value state
Key: FLINK-9514
URL: https://issues.apache.org/jira/browse/FLINK-9514
Project: Flink
Issue Type:
Andrey Zagrebin created FLINK-9701:
--
Summary: Activate TTL in state descriptors
Key: FLINK-9701
URL: https://issues.apache.org/jira/browse/FLINK-9701
Project: Flink
Issue Type: Sub-task
Andrey Zagrebin created FLINK-9637:
--
Summary: Add public user documentation for TTL feature
Key: FLINK-9637
URL: https://issues.apache.org/jira/browse/FLINK-9637
Project: Flink
Issue Type:
Andrey Zagrebin created FLINK-10151:
---
Summary: [State TTL] Fix false recursion call in
TransformingStateTableKeyGroupPartitioner.tryAddToSource
Key: FLINK-10151
URL:
Andrey Zagrebin created FLINK-10095:
---
Summary: Change the serialisation order in TTL value wrapper
Key: FLINK-10095
URL: https://issues.apache.org/jira/browse/FLINK-10095
Project: Flink
Andrey Zagrebin created FLINK-10132:
---
Summary: Incremental cleanup of local expired state with TTL
discovered in full snapshot
Key: FLINK-10132
URL: https://issues.apache.org/jira/browse/FLINK-10132
Andrey Zagrebin created FLINK-10249:
---
Summary: Document hadoop/presto s3 file system configuration
forwarding
Key: FLINK-10249
URL: https://issues.apache.org/jira/browse/FLINK-10249
Project: Flink
Andrey Zagrebin created FLINK-9858:
--
Summary: State TTL End-to-End Test
Key: FLINK-9858
URL: https://issues.apache.org/jira/browse/FLINK-9858
Project: Flink
Issue Type: Sub-task
Andrey Zagrebin created FLINK-9938:
--
Summary: State TTL cleanup during full state scan upon
checkpointing
Key: FLINK-9938
URL: https://issues.apache.org/jira/browse/FLINK-9938
Project: Flink
Andrey Zagrebin created FLINK-9254:
--
Summary: Move NotSoMiniClusterIterations to be an end-to-end test
Key: FLINK-9254
URL: https://issues.apache.org/jira/browse/FLINK-9254
Project: Flink
Andrey Zagrebin created FLINK-10515:
---
Summary: Improve tokenisation of program args passed as string
Key: FLINK-10515
URL: https://issues.apache.org/jira/browse/FLINK-10515
Project: Flink
Andrey Zagrebin created FLINK-10724:
---
Summary: Refactor failure handling in check point coordinator
Key: FLINK-10724
URL: https://issues.apache.org/jira/browse/FLINK-10724
Project: Flink
Andrey Zagrebin created FLINK-10830:
---
Summary: Consider making processing time provider pluggable
Key: FLINK-10830
URL: https://issues.apache.org/jira/browse/FLINK-10830
Project: Flink
Andrey Zagrebin created FLINK-10831:
---
Summary: Consider making processing time monotonically increasing
by default
Key: FLINK-10831
URL: https://issues.apache.org/jira/browse/FLINK-10831
Project:
Andrey Zagrebin created FLINK-10876:
---
Summary: Deadlock if closing firstly pending transactions in
FlinkKafkaProducer(011).close()
Key: FLINK-10876
URL: https://issues.apache.org/jira/browse/FLINK-10876
Andrey Zagrebin created FLINK-10833:
---
Summary:
FlinkKafkaProducerITCase.testFlinkKafkaProducerFailTransactionCoordinatorBeforeNotify
failed on Travis
Key: FLINK-10833
URL:
Andrey Zagrebin created FLINK-10842:
---
Summary: Waiting loops are broken in e2e/common.sh
Key: FLINK-10842
URL: https://issues.apache.org/jira/browse/FLINK-10842
Project: Flink
Issue Type:
Andrey Zagrebin created FLINK-10471:
---
Summary: State TTL cleanup using RocksDb compaction filter
Key: FLINK-10471
URL: https://issues.apache.org/jira/browse/FLINK-10471
Project: Flink
Andrey Zagrebin created FLINK-10473:
---
Summary: State TTL incremental cleanup using Heap backend key
iterator
Key: FLINK-10473
URL: https://issues.apache.org/jira/browse/FLINK-10473
Project: Flink
Andrey Zagrebin created FLINK-10374:
---
Summary: [Map State] Let user value serializer handle null values
Key: FLINK-10374
URL: https://issues.apache.org/jira/browse/FLINK-10374
Project: Flink
Andrey Zagrebin created FLINK-11393:
---
Summary: Activate default shuffle implementation and remove legacy
code
Key: FLINK-11393
URL: https://issues.apache.org/jira/browse/FLINK-11393
Project: Flink
Andrey Zagrebin created FLINK-11392:
---
Summary: Introduce ShuffleService in Task Executor
Key: FLINK-11392
URL: https://issues.apache.org/jira/browse/FLINK-11392
Project: Flink
Issue Type:
Andrey Zagrebin created FLINK-11391:
---
Summary: Introduce ShuffleMaster in Job Master
Key: FLINK-11391
URL: https://issues.apache.org/jira/browse/FLINK-11391
Project: Flink
Issue Type:
Andrey Zagrebin created FLINK-10946:
---
Summary: Resuming Externalized Checkpoint (rocks, incremental,
scale up) end-to-end test failed on Travis
Key: FLINK-10946
URL:
Andrey Zagrebin created FLINK-10325:
---
Summary: [State TTL] Refactor TtlListState to use only loops, no
java stream API for performance
Key: FLINK-10325
URL: https://issues.apache.org/jira/browse/FLINK-10325
Andrey Zagrebin created FLINK-12039:
---
Summary: Remove ASSIGNED_SLOT_UPDATER in
Execution.tryAssignResource
Key: FLINK-12039
URL: https://issues.apache.org/jira/browse/FLINK-12039
Project: Flink
Andrey Zagrebin created FLINK-12005:
---
Summary: [State TTL] Event time support
Key: FLINK-12005
URL: https://issues.apache.org/jira/browse/FLINK-12005
Project: Flink
Issue Type: New Feature
Andrey Zagrebin created FLINK-12110:
---
Summary: Introduce API point for ShuffleService to get estimation
of locally required memory
Key: FLINK-12110
URL: https://issues.apache.org/jira/browse/FLINK-12110
Andrey Zagrebin created FLINK-11745:
---
Summary: [State TTL][E2E] Restore from the savepoint after the job
cancelation
Key: FLINK-11745
URL: https://issues.apache.org/jira/browse/FLINK-11745
Project:
Andrey Zagrebin created FLINK-11828:
---
Summary: [HA] Test instability:
ZooKeeperHADispatcherTest.testStandbyDispatcherJobRecovery
Key: FLINK-11828
URL: https://issues.apache.org/jira/browse/FLINK-11828
Andrey Zagrebin created FLINK-11553:
---
Summary: DispatcherHATest.testFailingRecoveryIsAFatalError fails
locally with @Nonnull check
Key: FLINK-11553
URL: https://issues.apache.org/jira/browse/FLINK-11553
Andrey Zagrebin created FLINK-12193:
---
Summary: [Distributed Coordination] Send TM "can be released
status" with RM heartbeat
Key: FLINK-12193
URL: https://issues.apache.org/jira/browse/FLINK-12193
Andrey Zagrebin created FLINK-12199:
---
Summary: Refactor IOMetrics to not distinguish between
local/remote
Key: FLINK-12199
URL: https://issues.apache.org/jira/browse/FLINK-12199
Project: Flink
Andrey Zagrebin created FLINK-12201:
---
Summary: Introduce InputGateWithMetrics in Task to increment
in/out byte metrics
Key: FLINK-12201
URL: https://issues.apache.org/jira/browse/FLINK-12201
Andrey Zagrebin created FLINK-12202:
---
Summary: Consider introducing batch metric register in
NetworkEnviroment
Key: FLINK-12202
URL: https://issues.apache.org/jira/browse/FLINK-12202
Project: Flink
Andrey Zagrebin created FLINK-12203:
---
Summary: Refactor ResultPartitionManager to break tie with Task
Key: FLINK-12203
URL: https://issues.apache.org/jira/browse/FLINK-12203
Project: Flink
Andrey Zagrebin created FLINK-12543:
---
Summary: Consider naming convention for config options of shuffle
services
Key: FLINK-12543
URL: https://issues.apache.org/jira/browse/FLINK-12543
Project:
Andrey Zagrebin created FLINK-12628:
---
Summary: Check test failure if partition has no consumers in
Execution.getPartitionMaxParallelism
Key: FLINK-12628
URL: https://issues.apache.org/jira/browse/FLINK-12628
Andrey Zagrebin created FLINK-12731:
---
Summary: Load shuffle service implementations from plugin manager
Key: FLINK-12731
URL: https://issues.apache.org/jira/browse/FLINK-12731
Project: Flink
Andrey Zagrebin created FLINK-12706:
---
Summary: Introduce ShuffleManager interface and its configuration
Key: FLINK-12706
URL: https://issues.apache.org/jira/browse/FLINK-12706
Project: Flink
Andrey Zagrebin created FLINK-12673:
---
Summary: Introduce NetworkEnvironment.getUnreleasedPartitions
instead of using getResultPartitionManager
Key: FLINK-12673
URL:
Andrey Zagrebin created FLINK-12672:
---
Summary: Use SingleInputGate.closeFuture in
triggerPartitionStateCheck instead of consumer state in
RemoteChannelStateChecker
Key: FLINK-12672
URL:
Andrey Zagrebin created FLINK-12873:
---
Summary: Create a separate maven module for Shuffle API
Key: FLINK-12873
URL: https://issues.apache.org/jira/browse/FLINK-12873
Project: Flink
Issue
Andrey Zagrebin created FLINK-12890:
---
Summary: Add partition lifecycle related Shuffle API
Key: FLINK-12890
URL: https://issues.apache.org/jira/browse/FLINK-12890
Project: Flink
Issue
Andrey Zagrebin created FLINK-12960:
---
Summary: Move
ResultPartitionDeploymentDescriptor#releasedOnConsumption to
PartitionDescriptor#releasedOnConsumption
Key: FLINK-12960
URL:
Andrey Zagrebin created FLINK-12555:
---
Summary: Introduce an incapsulated metric group layout for shuffle
API and deprecate old one
Key: FLINK-12555
URL: https://issues.apache.org/jira/browse/FLINK-12555
Andrey Zagrebin created FLINK-12476:
---
Summary: [State TTL] Consider setting a default background cleanup
strategy in StateTtlConfig
Key: FLINK-12476
URL: https://issues.apache.org/jira/browse/FLINK-12476
Andrey Zagrebin created FLINK-12570:
---
Summary: Switch Task from ResultPartition to ResultPartitionWriter
interface
Key: FLINK-12570
URL: https://issues.apache.org/jira/browse/FLINK-12570
Project:
Andrey Zagrebin created FLINK-12530:
---
Summary: Move Task.inputGatesById to NetworkEnvironment
Key: FLINK-12530
URL: https://issues.apache.org/jira/browse/FLINK-12530
Project: Flink
Issue
Andrey Zagrebin created FLINK-13169:
---
Summary: IT test for fine-grained recovery (task executor failures)
Key: FLINK-13169
URL: https://issues.apache.org/jira/browse/FLINK-13169
Project: Flink
Andrey Zagrebin created FLINK-13019:
---
Summary: IT test for fine-grained recovery
Key: FLINK-13019
URL: https://issues.apache.org/jira/browse/FLINK-13019
Project: Flink
Issue Type: Sub-task
Andrey Zagrebin created FLINK-13819:
---
Summary: Introduce RpcEndpoint State
Key: FLINK-13819
URL: https://issues.apache.org/jira/browse/FLINK-13819
Project: Flink
Issue Type: Improvement
Andrey Zagrebin created FLINK-13820:
---
Summary: Breaking long function argument lists and chained method
calls
Key: FLINK-13820
URL: https://issues.apache.org/jira/browse/FLINK-13820
Project: Flink
Andrey Zagrebin created FLINK-13804:
---
Summary: Collections initial capacity
Key: FLINK-13804
URL: https://issues.apache.org/jira/browse/FLINK-13804
Project: Flink
Issue Type: Sub-task
Andrey Zagrebin created FLINK-13802:
---
Summary: Flink code style guide
Key: FLINK-13802
URL: https://issues.apache.org/jira/browse/FLINK-13802
Project: Flink
Issue Type: Task
Andrey Zagrebin created FLINK-13927:
---
Summary: Add note about hadoop dependencies for local debug
Key: FLINK-13927
URL: https://issues.apache.org/jira/browse/FLINK-13927
Project: Flink
Andrey Zagrebin created FLINK-13812:
---
Summary: Code style for the usage of Java Optional
Key: FLINK-13812
URL: https://issues.apache.org/jira/browse/FLINK-13812
Project: Flink
Issue Type:
Andrey Zagrebin created FLINK-13963:
---
Summary: Consolidate Hadoop file systems usage and Hadoop
integration docs
Key: FLINK-13963
URL: https://issues.apache.org/jira/browse/FLINK-13963
Project:
Andrey Zagrebin created FLINK-13581:
---
Summary: BatchFineGrainedRecoveryITCase failed on Travis
Key: FLINK-13581
URL: https://issues.apache.org/jira/browse/FLINK-13581
Project: Flink
Issue
Andrey Zagrebin created FLINK-13638:
---
Summary: Refactor
RemoteChannelStateChecker#isProducerConsumerReadyOrAbortConsumption to return
result action
Key: FLINK-13638
URL:
Andrey Zagrebin created FLINK-13640:
---
Summary: Consider TaskDeploymentDescriptorFactory to be Execution
specific
Key: FLINK-13640
URL: https://issues.apache.org/jira/browse/FLINK-13640
Project:
Andrey Zagrebin created FLINK-13639:
---
Summary: Consider refactoring of IntermediateResultPartitionID to
consist of IntermediateDataSetID and partitionIndex
Key: FLINK-13639
URL:
Andrey Zagrebin created FLINK-13641:
---
Summary: Consider removing UnknownInputChannel in
NettyShuffleEnvironment
Key: FLINK-13641
URL: https://issues.apache.org/jira/browse/FLINK-13641
Project:
Andrey Zagrebin created FLINK-13642:
---
Summary: Refactor ShuffleMaster to optionally provide preferred TM
location for produced partitions
Key: FLINK-13642
URL: https://issues.apache.org/jira/browse/FLINK-13642
Andrey Zagrebin created FLINK-13407:
---
Summary: Fix thread visibility of checked
SlotManager.failUnfulfillableRequest in StandaloneResourceManagerTest
Key: FLINK-13407
URL:
Andrey Zagrebin created FLINK-13408:
---
Summary: Schedule
StandaloneResourceManager.setFailUnfulfillableRequest whenever the leadership
is acquired
Key: FLINK-13408
URL:
Andrey Zagrebin created FLINK-13435:
---
Summary: Remove ShuffleDescriptor.ReleaseType and make release
semantics fixed per partition type
Key: FLINK-13435
URL: https://issues.apache.org/jira/browse/FLINK-13435
Andrey Zagrebin created FLINK-13371:
---
Summary: Release partitions in JM of producer gets restarted
Key: FLINK-13371
URL: https://issues.apache.org/jira/browse/FLINK-13371
Project: Flink
Andrey Zagrebin created FLINK-14631:
---
Summary: Account for netty direct allocations in direct memory
limit
Key: FLINK-14631
URL: https://issues.apache.org/jira/browse/FLINK-14631
Project: Flink
Andrey Zagrebin created FLINK-14633:
---
Summary: Account for netty direct allocations in direct memory
limit (Queryable state)
Key: FLINK-14633
URL: https://issues.apache.org/jira/browse/FLINK-14633
Andrey Zagrebin created FLINK-14637:
---
Summary: Introduce framework off heap memory config
Key: FLINK-14637
URL: https://issues.apache.org/jira/browse/FLINK-14637
Project: Flink
Issue Type:
Andrey Zagrebin created FLINK-14901:
---
Summary: Throw Error in MemoryUtils if there is problem with using
system classes over reflection
Key: FLINK-14901
URL: https://issues.apache.org/jira/browse/FLINK-14901
Andrey Zagrebin created FLINK-14898:
---
Summary: Enable background cleanup of state with TTL by default
Key: FLINK-14898
URL: https://issues.apache.org/jira/browse/FLINK-14898
Project: Flink
Andrey Zagrebin created FLINK-15300:
---
Summary: Shuffle memory fraction sanity check does not account for
its min/max limit
Key: FLINK-15300
URL: https://issues.apache.org/jira/browse/FLINK-15300
Andrey Zagrebin created FLINK-15198:
---
Summary: Remove deprecated mesos.resourcemanager.tasks.mem in 1.11
Key: FLINK-15198
URL: https://issues.apache.org/jira/browse/FLINK-15198
Project: Flink
Andrey Zagrebin created FLINK-15094:
---
Summary: Warning about using private constructor of
java.nio.DirectByteBuffer in Java 11
Key: FLINK-15094
URL: https://issues.apache.org/jira/browse/FLINK-15094
Andrey Zagrebin created FLINK-14399:
---
Summary: Add memory chunk reservation API to MemoryManager
Key: FLINK-14399
URL: https://issues.apache.org/jira/browse/FLINK-14399
Project: Flink
Andrey Zagrebin created FLINK-14400:
---
Summary: Shrink the scope of MemoryManager from TaskExecutor to
slot
Key: FLINK-14400
URL: https://issues.apache.org/jira/browse/FLINK-14400
Project: Flink
Andrey Zagrebin created FLINK-14522:
---
Summary: Adjust GC Cleaner for unsafe memory and Java 11
Key: FLINK-14522
URL: https://issues.apache.org/jira/browse/FLINK-14522
Project: Flink
Issue
Andrey Zagrebin created FLINK-16406:
---
Summary: Increase default value for JVM Metaspace to minimise its
OutOfMemoryError
Key: FLINK-16406
URL: https://issues.apache.org/jira/browse/FLINK-16406
Andrey Zagrebin created FLINK-15774:
---
Summary: Consider adding an explicit network memory size config
option
Key: FLINK-15774
URL: https://issues.apache.org/jira/browse/FLINK-15774
Project: Flink
Andrey Zagrebin created FLINK-15741:
---
Summary: Fix TTL docs after enabling RocksDB compaction filter by
default
Key: FLINK-15741
URL: https://issues.apache.org/jira/browse/FLINK-15741
Project:
Andrey Zagrebin created FLINK-15942:
---
Summary: Improve logging of infinite resource profile
Key: FLINK-15942
URL: https://issues.apache.org/jira/browse/FLINK-15942
Project: Flink
Issue
Andrey Zagrebin created FLINK-15946:
---
Summary: Task manager Kubernetes pods take long time to terminate
Key: FLINK-15946
URL: https://issues.apache.org/jira/browse/FLINK-15946
Project: Flink
Andrey Zagrebin created FLINK-15758:
---
Summary: Investigate potential out-of-memory problems due to
managed unsafe memory allocation
Key: FLINK-15758
URL: https://issues.apache.org/jira/browse/FLINK-15758
Andrey Zagrebin created FLINK-15763:
---
Summary: Set necessary resource configuration options to defaults
for local execution ignoring FLIP-49
Key: FLINK-15763
URL:
Andrey Zagrebin created FLINK-16198:
---
Summary: FileUtilsTest fails on Mac OS
Key: FLINK-16198
URL: https://issues.apache.org/jira/browse/FLINK-16198
Project: Flink
Issue Type: Bug
Andrey Zagrebin created FLINK-15991:
---
Summary: Create Chinese documentation for FLIP-49 TM memory model
Key: FLINK-15991
URL: https://issues.apache.org/jira/browse/FLINK-15991
Project: Flink
Andrey Zagrebin created FLINK-15989:
---
Summary: Rewrap OutOfMemoryError in allocateUnpooledOffHeap with
better message
Key: FLINK-15989
URL: https://issues.apache.org/jira/browse/FLINK-15989
Andrey Zagrebin created FLINK-15597:
---
Summary: Relax sanity check of JVM memory overhead to be within
its min/max
Key: FLINK-15597
URL: https://issues.apache.org/jira/browse/FLINK-15597
Project:
Andrey Zagrebin created FLINK-15606:
---
Summary: Deprecate enable default background cleanup of state with
TTL
Key: FLINK-15606
URL: https://issues.apache.org/jira/browse/FLINK-15606
Project: Flink
1 - 100 of 153 matches
Mail list logo
