Andrey Zagrebin created FLINK-20469:
---
Summary: Enable TaskManager start and terminate in MiniCluster
Key: FLINK-20469
URL: https://issues.apache.org/jira/browse/FLINK-20469
Project: Flink
Andrey Zagrebin created FLINK-20468:
---
Summary: Enable leadership control in MiniCluster to test JM
failover
Key: FLINK-20468
URL: https://issues.apache.org/jira/browse/FLINK-20468
Project: Flink
Andrey Zagrebin created FLINK-20290:
---
Summary: Duplicated output in FileSource continuous ITCase with TM
failover
Key: FLINK-20290
URL: https://issues.apache.org/jira/browse/FLINK-20290
Project:
Andrey Zagrebin created FLINK-20261:
---
Summary: Uncaught exception in ExecutorNotifier due to split
assignment broken by failed task
Key: FLINK-20261
URL: https://issues.apache.org/jira/browse/FLINK-20261
Andrey Zagrebin created FLINK-20171:
---
Summary: Improve error message for Flink process memory
configuration
Key: FLINK-20171
URL: https://issues.apache.org/jira/browse/FLINK-20171
Project: Flink
Andrey Zagrebin created FLINK-20078:
---
Summary: Factor out an ExecutionGraph factory method for
DefaultExecutionTopology
Key: FLINK-20078
URL: https://issues.apache.org/jira/browse/FLINK-20078
Andrey Zagrebin created FLINK-19954:
---
Summary: Move execution deployment tracking logic from legacy EG
code to SchedulerNG
Key: FLINK-19954
URL: https://issues.apache.org/jira/browse/FLINK-19954
Andrey Zagrebin created FLINK-19923:
---
Summary: Remove BulkSlotProvider, its implementation and tests
Key: FLINK-19923
URL: https://issues.apache.org/jira/browse/FLINK-19923
Project: Flink
Andrey Zagrebin created FLINK-19918:
---
Summary: RocksIncrementalCheckpointRescalingTest.testScalingDown
fails on Windows
Key: FLINK-19918
URL: https://issues.apache.org/jira/browse/FLINK-19918
Andrey Zagrebin created FLINK-19917:
---
Summary: RocksDBInitTest.testTempLibFolderDeletedOnFail fails on
Windows
Key: FLINK-19917
URL: https://issues.apache.org/jira/browse/FLINK-19917
Project:
Andrey Zagrebin created FLINK-19860:
---
Summary: Consider skipping restart and traverse regions which are
already being restarted in RestartPipelinedRegionFailoverStrategy
Key: FLINK-19860
URL:
Andrey Zagrebin created FLINK-19832:
---
Summary: Improve handling of immediately failed physical slot in
SlotSharingExecutionSlotAllocator
Key: FLINK-19832
URL: https://issues.apache.org/jira/browse/FLINK-19832
Andrey Zagrebin created FLINK-19142:
---
Summary: Investigate slot hijacking from preceding pipelined
regions after failover
Key: FLINK-19142
URL: https://issues.apache.org/jira/browse/FLINK-19142
Andrey Zagrebin created FLINK-18957:
---
Summary: Implement bulk fulfil-ability timeout tracking for shared
slots
Key: FLINK-18957
URL: https://issues.apache.org/jira/browse/FLINK-18957
Project: Flink
Andrey Zagrebin created FLINK-18751:
---
Summary: Implement SlotSharingExecutionSlotAllocator
Key: FLINK-18751
URL: https://issues.apache.org/jira/browse/FLINK-18751
Project: Flink
Issue
Andrey Zagrebin created FLINK-18739:
---
Summary: Implement MergingSharedSlotProfileRetriever
Key: FLINK-18739
URL: https://issues.apache.org/jira/browse/FLINK-18739
Project: Flink
Issue
Andrey Zagrebin created FLINK-18709:
---
Summary: Implement PhysicalSlotProvider
Key: FLINK-18709
URL: https://issues.apache.org/jira/browse/FLINK-18709
Project: Flink
Issue Type: Sub-task
Andrey Zagrebin created FLINK-18689:
---
Summary: Deterministic Slot Sharing
Key: FLINK-18689
URL: https://issues.apache.org/jira/browse/FLINK-18689
Project: Flink
Issue Type: New Feature
Andrey Zagrebin created FLINK-18690:
---
Summary: Implement LocalInputPreferredSlotSharingStrategy
Key: FLINK-18690
URL: https://issues.apache.org/jira/browse/FLINK-18690
Project: Flink
Issue
Andrey Zagrebin created FLINK-18646:
---
Summary: Managed memory released check can block RPC thread
Key: FLINK-18646
URL: https://issues.apache.org/jira/browse/FLINK-18646
Project: Flink
Andrey Zagrebin created FLINK-18467:
---
Summary: Document what can be reconfigured for state with TTL
between job restarts
Key: FLINK-18467
URL: https://issues.apache.org/jira/browse/FLINK-18467
Andrey Zagrebin created FLINK-18454:
---
Summary: Add a code contribution section about how to look for
what to contribute
Key: FLINK-18454
URL: https://issues.apache.org/jira/browse/FLINK-18454
Andrey Zagrebin created FLINK-18309:
---
Summary: Recommend avoiding uppercase to emphasise statements in
doc style
Key: FLINK-18309
URL: https://issues.apache.org/jira/browse/FLINK-18309
Project:
Andrey Zagrebin created FLINK-18308:
---
Summary: KafkaProducerTestBase->Kafka011ProducerExactlyOnceITCase.
testExactlyOnceCustomOperator hangs in Azure
Key: FLINK-18308
URL:
Andrey Zagrebin created FLINK-18250:
---
Summary: Enrich OOM error messages with more details in
ClusterEntrypoint
Key: FLINK-18250
URL: https://issues.apache.org/jira/browse/FLINK-18250
Project:
Andrey Zagrebin created FLINK-17811:
---
Summary: Update docker hub Flink page
Key: FLINK-17811
URL: https://issues.apache.org/jira/browse/FLINK-17811
Project: Flink
Issue Type: Task
Andrey Zagrebin created FLINK-17740:
---
Summary: Remove flink-container/kubernetes
Key: FLINK-17740
URL: https://issues.apache.org/jira/browse/FLINK-17740
Project: Flink
Issue Type: Sub-task
Andrey Zagrebin created FLINK-17652:
---
Summary: Legacy JM heap options should fallback to new
JVM_HEAP_MEMORY in standalone
Key: FLINK-17652
URL: https://issues.apache.org/jira/browse/FLINK-17652
Andrey Zagrebin created FLINK-17546:
---
Summary: Consider setting the number of TM CPU cores to the actual
number of cores
Key: FLINK-17546
URL: https://issues.apache.org/jira/browse/FLINK-17546
Andrey Zagrebin created FLINK-17465:
---
Summary: Update Chinese user documentation for job manager memory
model
Key: FLINK-17465
URL: https://issues.apache.org/jira/browse/FLINK-17465
Project: Flink
Andrey Zagrebin created FLINK-17344:
---
Summary: RecordWriterTest.testIdleTime possibly deadlocks on Travis
Key: FLINK-17344
URL: https://issues.apache.org/jira/browse/FLINK-17344
Project: Flink
Andrey Zagrebin created FLINK-17167:
---
Summary: Extend entry point script and docs with history server
mode
Key: FLINK-17167
URL: https://issues.apache.org/jira/browse/FLINK-17167
Project: Flink
Andrey Zagrebin created FLINK-17166:
---
Summary: Modify the log4j-console.properties to also output logs
into the files for WebUI
Key: FLINK-17166
URL: https://issues.apache.org/jira/browse/FLINK-17166
Andrey Zagrebin created FLINK-17165:
---
Summary: Remove flink-container/docker
Key: FLINK-17165
URL: https://issues.apache.org/jira/browse/FLINK-17165
Project: Flink
Issue Type: Sub-task
Andrey Zagrebin created FLINK-17164:
---
Summary: Extend entry point script and docs with job cluster mode
and user job artefacts
Key: FLINK-17164
URL: https://issues.apache.org/jira/browse/FLINK-17164
Andrey Zagrebin created FLINK-17163:
---
Summary: Remove flink-contrib/docker-flink
Key: FLINK-17163
URL: https://issues.apache.org/jira/browse/FLINK-17163
Project: Flink
Issue Type: Sub-task
Andrey Zagrebin created FLINK-17162:
---
Summary: Document examples of how to extend the official docker
hub image
Key: FLINK-17162
URL: https://issues.apache.org/jira/browse/FLINK-17162
Project:
Andrey Zagrebin created FLINK-17161:
---
Summary: Document the official docker hub image and examples of
how to run
Key: FLINK-17161
URL: https://issues.apache.org/jira/browse/FLINK-17161
Project:
Andrey Zagrebin created FLINK-17160:
---
Summary: FLIP-111: Docker image unification
Key: FLINK-17160
URL: https://issues.apache.org/jira/browse/FLINK-17160
Project: Flink
Issue Type:
Andrey Zagrebin created FLINK-17048:
---
Summary: Add memory related JVM args to Mesos JM startup scripts
Key: FLINK-17048
URL: https://issues.apache.org/jira/browse/FLINK-17048
Project: Flink
Andrey Zagrebin created FLINK-16946:
---
Summary: Update user documentation for job manager memory model
Key: FLINK-16946
URL: https://issues.apache.org/jira/browse/FLINK-16946
Project: Flink
Andrey Zagrebin created FLINK-16754:
---
Summary: Consider refactoring of ProcessMemoryUtilsTestBase to
avoid inheritance
Key: FLINK-16754
URL: https://issues.apache.org/jira/browse/FLINK-16754
Andrey Zagrebin created FLINK-16742:
---
Summary: Extend and use BashJavaUtils to start JM JVM process and
pass JVM memory args
Key: FLINK-16742
URL: https://issues.apache.org/jira/browse/FLINK-16742
Andrey Zagrebin created FLINK-16746:
---
Summary: Deprecate/remove legacy memory options for JM and expose
the new ones
Key: FLINK-16746
URL: https://issues.apache.org/jira/browse/FLINK-16746
Project:
Andrey Zagrebin created FLINK-16745:
---
Summary: Use JobManagerProcessUtils to start JM container and pass
JVM memory args
Key: FLINK-16745
URL: https://issues.apache.org/jira/browse/FLINK-16745
Andrey Zagrebin created FLINK-16686:
---
Summary: [State TTL] Make user class loader available in native
RocksDB compaction thread
Key: FLINK-16686
URL: https://issues.apache.org/jira/browse/FLINK-16686
Andrey Zagrebin created FLINK-16615:
---
Summary: Introduce data structures and utilities to calculate Job
Manager memory components
Key: FLINK-16615
URL: https://issues.apache.org/jira/browse/FLINK-16615
Andrey Zagrebin created FLINK-16614:
---
Summary: FLIP-116 Unified Memory Configuration for Job Manager
Key: FLINK-16614
URL: https://issues.apache.org/jira/browse/FLINK-16614
Project: Flink
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-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-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-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-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-15763:
---
Summary: Set necessary resource configuration options to defaults
for local execution ignoring FLIP-49
Key: FLINK-15763
URL:
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-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-15621:
---
Summary: State TTL: Remove deprecated option and method to disable
TTL compaction filter
Key: FLINK-15621
URL: https://issues.apache.org/jira/browse/FLINK-15621
Andrey Zagrebin created FLINK-15620:
---
Summary: State TTL: Remove deprecated enable default background
cleanup
Key: FLINK-15620
URL: https://issues.apache.org/jira/browse/FLINK-15620
Project: Flink
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
Andrey Zagrebin created FLINK-15605:
---
Summary: Remove deprecated in 1.9 StateTtlConfig.TimeCharacteristic
Key: FLINK-15605
URL: https://issues.apache.org/jira/browse/FLINK-15605
Project: Flink
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-15519:
---
Summary: Preserve logs from BashJavaUtils and make them part of TM
logs
Key: FLINK-15519
URL: https://issues.apache.org/jira/browse/FLINK-15519
Project: Flink
Andrey Zagrebin created FLINK-15517:
---
Summary: Use back 'network' in 'shuffle' memory config option names
Key: FLINK-15517
URL: https://issues.apache.org/jira/browse/FLINK-15517
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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-13641:
---
Summary: Consider removing UnknownInputChannel in
NettyShuffleEnvironment
Key: FLINK-13641
URL: https://issues.apache.org/jira/browse/FLINK-13641
Project:
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-13638:
---
Summary: Refactor
RemoteChannelStateChecker#isProducerConsumerReadyOrAbortConsumption to return
result action
Key: FLINK-13638
URL:
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-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-13408:
---
Summary: Schedule
StandaloneResourceManager.setFailUnfulfillableRequest whenever the leadership
is acquired
Key: FLINK-13408
URL:
Andrey Zagrebin created FLINK-13407:
---
Summary: Fix thread visibility of checked
SlotManager.failUnfulfillableRequest in StandaloneResourceManagerTest
Key: FLINK-13407
URL:
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-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-12960:
---
Summary: Move
ResultPartitionDeploymentDescriptor#releasedOnConsumption to
PartitionDescriptor#releasedOnConsumption
Key: FLINK-12960
URL:
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-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-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
1 - 100 of 153 matches
Mail list logo
