Zhu Zhu created FLINK-34105:
---
Summary: Akka timeout happens in TPC-DS benchmarks
Key: FLINK-34105
URL: https://issues.apache.org/jira/browse/FLINK-34105
Project: Flink
Issue Type: Bug
Zhu Zhu created FLINK-33677:
---
Summary: Remove flink-conf.yaml from flink dist
Key: FLINK-33677
URL: https://issues.apache.org/jira/browse/FLINK-33677
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-32654:
---
Summary: Deprecate ExecutionConfig#canEqual(obj)
Key: FLINK-32654
URL: https://issues.apache.org/jira/browse/FLINK-32654
Project: Flink
Issue Type: Technical Debt
Zhu Zhu created FLINK-32384:
---
Summary: Remove deprecated configuration keys which violate YAML
spec
Key: FLINK-32384
URL: https://issues.apache.org/jira/browse/FLINK-32384
Project: Flink
Issue
Zhu Zhu created FLINK-32383:
---
Summary: 2.0 Breaking configuration changes
Key: FLINK-32383
URL: https://issues.apache.org/jira/browse/FLINK-32383
Project: Flink
Issue Type: Technical Debt
Zhu Zhu created FLINK-31052:
---
Summary: Release Testing: Verify FLINK-30707 Improve slow task
detection
Key: FLINK-31052
URL: https://issues.apache.org/jira/browse/FLINK-31052
Project: Flink
Issue
Zhu Zhu created FLINK-31005:
---
Summary: Release Testing: Verify FLIP-281 Supports speculative
execution of sinks
Key: FLINK-31005
URL: https://issues.apache.org/jira/browse/FLINK-31005
Project: Flink
Zhu Zhu created FLINK-30904:
---
Summary: Update the documentation and configuration description of
slow task detector
Key: FLINK-30904
URL: https://issues.apache.org/jira/browse/FLINK-30904
Project: Flink
Zhu Zhu created FLINK-30834:
---
Summary: SortAggITCase.testLeadLag is unstable in
ALL_EXCHANGES_BLOCKING mode
Key: FLINK-30834
URL: https://issues.apache.org/jira/browse/FLINK-30834
Project: Flink
Zhu Zhu created FLINK-30815:
---
Summary: BatchTestBase/BatchAbstractTestBase are using Junit4
while some child tests are using JUnit5
Key: FLINK-30815
URL: https://issues.apache.org/jira/browse/FLINK-30815
Zhu Zhu created FLINK-30814:
---
Summary: The parallelism of sort after a global
partitioning is forced to be 1
Key: FLINK-30814
URL: https://issues.apache.org/jira/browse/FLINK-30814
Project: Flink
Zhu Zhu created FLINK-30480:
---
Summary: Add benchmarks for adaptive batch scheduler
Key: FLINK-30480
URL: https://issues.apache.org/jira/browse/FLINK-30480
Project: Flink
Issue Type: Improvement
Zhu Zhu created FLINK-29989:
---
Summary: Enable FlameGraph for arbitrary thread on TaskManager
Key: FLINK-29989
URL: https://issues.apache.org/jira/browse/FLINK-29989
Project: Flink
Issue Type:
Zhu Zhu created FLINK-28981:
---
Summary: Release Testing: Verify FLIP-245 sources speculative
execution
Key: FLINK-28981
URL: https://issues.apache.org/jira/browse/FLINK-28981
Project: Flink
Issue
Zhu Zhu created FLINK-28980:
---
Summary: Release Testing: Verify FLIP-168 speculative execution
Key: FLINK-28980
URL: https://issues.apache.org/jira/browse/FLINK-28980
Project: Flink
Issue Type:
Zhu Zhu created FLINK-28907:
---
Summary: Flink docs does not compile
Key: FLINK-28907
URL: https://issues.apache.org/jira/browse/FLINK-28907
Project: Flink
Issue Type: Bug
Components:
Zhu Zhu created FLINK-28771:
---
Summary: Assign speculative execution attempt with correct CREATED
timestamp
Key: FLINK-28771
URL: https://issues.apache.org/jira/browse/FLINK-28771
Project: Flink
Zhu Zhu created FLINK-28759:
---
Summary: Enable speculative execution for in
AdaptiveBatchScheduler TPC-DS e2e tests
Key: FLINK-28759
URL: https://issues.apache.org/jira/browse/FLINK-28759
Project: Flink
Zhu Zhu created FLINK-28612:
---
Summary: Cancel pending slot allocation after canceling executions
Key: FLINK-28612
URL: https://issues.apache.org/jira/browse/FLINK-28612
Project: Flink
Issue Type:
Zhu Zhu created FLINK-28610:
---
Summary: Enable speculative execution of sources
Key: FLINK-28610
URL: https://issues.apache.org/jira/browse/FLINK-28610
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-28586:
---
Summary: Speculative execution for new sources
Key: FLINK-28586
URL: https://issues.apache.org/jira/browse/FLINK-28586
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-28585:
---
Summary: Speculative execution for InputFormat sources
Key: FLINK-28585
URL: https://issues.apache.org/jira/browse/FLINK-28585
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-28402:
---
Summary: Create FailureHandlingResultSnapshot with the truly
failed execution
Key: FLINK-28402
URL: https://issues.apache.org/jira/browse/FLINK-28402
Project: Flink
Zhu Zhu created FLINK-28258:
---
Summary: Introduce ExecutionHistory to host historical executions
for each execution vertex
Key: FLINK-28258
URL: https://issues.apache.org/jira/browse/FLINK-28258
Project:
Zhu Zhu created FLINK-28193:
---
Summary: Enable to identify whether a job vertex contains
source/sink operators
Key: FLINK-28193
URL: https://issues.apache.org/jira/browse/FLINK-28193
Project: Flink
Zhu Zhu created FLINK-28139:
---
Summary: Add documentation for speculative execution
Key: FLINK-28139
URL: https://issues.apache.org/jira/browse/FLINK-28139
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-28138:
---
Summary: Add metrics for speculative execution
Key: FLINK-28138
URL: https://issues.apache.org/jira/browse/FLINK-28138
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-28137:
---
Summary: Introduce SpeculativeScheduler
Key: FLINK-28137
URL: https://issues.apache.org/jira/browse/FLINK-28137
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-28136:
---
Summary: Implement ExecutionTimeBasedSlowTaskDetector
Key: FLINK-28136
URL: https://issues.apache.org/jira/browse/FLINK-28136
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-28135:
---
Summary: Introduce SlowTaskDetector
Key: FLINK-28135
URL: https://issues.apache.org/jira/browse/FLINK-28135
Project: Flink
Issue Type: Sub-task
Reporter:
Zhu Zhu created FLINK-28134:
---
Summary: Introduce SpeculativeExecutionVertex
Key: FLINK-28134
URL: https://issues.apache.org/jira/browse/FLINK-28134
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-28133:
---
Summary: Rework DefaultScheduler to directly deploy executions
Key: FLINK-28133
URL: https://issues.apache.org/jira/browse/FLINK-28133
Project: Flink
Issue Type:
Zhu Zhu created FLINK-28131:
---
Summary: FLIP-168: Speculative Execution for Batch Job
Key: FLINK-28131
URL: https://issues.apache.org/jira/browse/FLINK-28131
Project: Flink
Issue Type: New Feature
Zhu Zhu created FLINK-27944:
---
Summary: IO metric collision happens when a task has union inputs
Key: FLINK-27944
URL: https://issues.apache.org/jira/browse/FLINK-27944
Project: Flink
Issue Type:
Zhu Zhu created FLINK-27710:
---
Summary: Improve logs to better display Execution
Key: FLINK-27710
URL: https://issues.apache.org/jira/browse/FLINK-27710
Project: Flink
Issue Type: Improvement
Zhu Zhu created FLINK-27460:
---
Summary: Remove unused notifyPartitionDataAvailable process
Key: FLINK-27460
URL: https://issues.apache.org/jira/browse/FLINK-27460
Project: Flink
Issue Type:
Zhu Zhu created FLINK-25996:
---
Summary: Introduce job property isDynamicGraph to ExecutionConfig
Key: FLINK-25996
URL: https://issues.apache.org/jira/browse/FLINK-25996
Project: Flink
Issue Type:
Zhu Zhu created FLINK-25995:
---
Summary: Make implicit assumption of SQL local keyBy/groupBy
explicit
Key: FLINK-25995
URL: https://issues.apache.org/jira/browse/FLINK-25995
Project: Flink
Issue
Zhu Zhu created FLINK-25226:
---
Summary: Add documentation about the AdaptiveBatchScheduler
Key: FLINK-25226
URL: https://issues.apache.org/jira/browse/FLINK-25226
Project: Flink
Issue Type:
Zhu Zhu created FLINK-25225:
---
Summary: Add e2e TPCDS tests to run against the
AdatpiveBatchScheduler
Key: FLINK-25225
URL: https://issues.apache.org/jira/browse/FLINK-25225
Project: Flink
Issue
Zhu Zhu created FLINK-24005:
---
Summary: Resource requirements declaration may be incorrect if
JobMaster disconnects with a TaskManager with available slots in the SlotPool
Key: FLINK-24005
URL:
Zhu Zhu created FLINK-23826:
---
Summary: Verify optimized scheduler performance for large-scale
jobs
Key: FLINK-23826
URL: https://issues.apache.org/jira/browse/FLINK-23826
Project: Flink
Issue
Zhu Zhu created FLINK-23806:
---
Summary: StackOverflowException can happen if a large scale job
failed to acquire enough slots in time
Key: FLINK-23806
URL: https://issues.apache.org/jira/browse/FLINK-23806
Zhu Zhu created FLINK-22945:
---
Summary: StackOverflowException can happen when a large scale job
is CANCELED/FAILED
Key: FLINK-22945
URL: https://issues.apache.org/jira/browse/FLINK-22945
Project: Flink
Zhu Zhu created FLINK-21735:
---
Summary: Harden JobMaster#updateTaskExecutionState()
Key: FLINK-21735
URL: https://issues.apache.org/jira/browse/FLINK-21735
Project: Flink
Issue Type: Improvement
Zhu Zhu created FLINK-21734:
---
Summary: Allow BLOCKING result partition to be individually
consumable
Key: FLINK-21734
URL: https://issues.apache.org/jira/browse/FLINK-21734
Project: Flink
Issue
Zhu Zhu created FLINK-21707:
---
Summary: Job is possible to hang when restarting a FINISHED task
with POINTWISE BLOCKING consumers
Key: FLINK-21707
URL: https://issues.apache.org/jira/browse/FLINK-21707
Zhu Zhu created FLINK-21576:
---
Summary: Remove ExecutionVertex#getPreferredLocations
Key: FLINK-21576
URL: https://issues.apache.org/jira/browse/FLINK-21576
Project: Flink
Issue Type: Improvement
Zhu Zhu created FLINK-20931:
---
Summary: Remove globalModVersion from ExecutionGraph
Key: FLINK-20931
URL: https://issues.apache.org/jira/browse/FLINK-20931
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-20930:
---
Summary: Remove AbstractExecutionSlotAllocator
Key: FLINK-20930
URL: https://issues.apache.org/jira/browse/FLINK-20930
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-20721:
---
Summary: Remove unknown input channels and process to update
partitions
Key: FLINK-20721
URL: https://issues.apache.org/jira/browse/FLINK-20721
Project: Flink
Issue
Zhu Zhu created FLINK-20626:
---
Summary: Canceling a job when it is failing will result in job
hanging in CANCELING state
Key: FLINK-20626
URL: https://issues.apache.org/jira/browse/FLINK-20626
Project:
Zhu Zhu created FLINK-20619:
---
Summary: Remove InputDependencyConstraint and
InputDependencyConstraintChecker
Key: FLINK-20619
URL: https://issues.apache.org/jira/browse/FLINK-20619
Project: Flink
Zhu Zhu created FLINK-20439:
---
Summary: Consider simplifying or removing mechanism to
scheduleOrUpdateConsumers
Key: FLINK-20439
URL: https://issues.apache.org/jira/browse/FLINK-20439
Project: Flink
Zhu Zhu created FLINK-20285:
---
Summary: LazyFromSourcesSchedulingStrategy is possible to schedule
non-CREATED vertices
Key: FLINK-20285
URL: https://issues.apache.org/jira/browse/FLINK-20285
Project: Flink
Zhu Zhu created FLINK-20284:
---
Summary: Error happens in TaskExecutor when closing JobMaster
connection if there was a python UDF
Key: FLINK-20284
URL: https://issues.apache.org/jira/browse/FLINK-20284
Zhu Zhu created FLINK-20283:
---
Summary: Make invalid managed memory fraction errors of python udf
more user friendly
Key: FLINK-20283
URL: https://issues.apache.org/jira/browse/FLINK-20283
Project: Flink
Zhu Zhu created FLINK-20282:
---
Summary: Make invalid managed memory fraction errors more advisory
in MemoryManager
Key: FLINK-20282
URL: https://issues.apache.org/jira/browse/FLINK-20282
Project: Flink
Zhu Zhu created FLINK-19994:
---
Summary: All vertices in an DataSet iteration job will be eagerly
scheduled
Key: FLINK-19994
URL: https://issues.apache.org/jira/browse/FLINK-19994
Project: Flink
Zhu Zhu created FLINK-19922:
---
Summary: Remove SlotProvider from SchedulerNG
Key: FLINK-19922
URL: https://issues.apache.org/jira/browse/FLINK-19922
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-19921:
---
Summary: Remove legacy RestartStrategy
Key: FLINK-19921
URL: https://issues.apache.org/jira/browse/FLINK-19921
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-19920:
---
Summary: Remove legacy FailoverStrategy
Key: FLINK-19920
URL: https://issues.apache.org/jira/browse/FLINK-19920
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-19919:
---
Summary: Remove legacy scheduling in ExecutionGraph components
Key: FLINK-19919
URL: https://issues.apache.org/jira/browse/FLINK-19919
Project: Flink
Issue Type:
Zhu Zhu created FLINK-19806:
---
Summary: Job may try to leave SUSPENDED state in
ExecutionGraph#failJob()
Key: FLINK-19806
URL: https://issues.apache.org/jira/browse/FLINK-19806
Project: Flink
Zhu Zhu created FLINK-19714:
---
Summary: Assign different logical pipelined regions of a DataSet
job to different slot sharing group
Key: FLINK-19714
URL: https://issues.apache.org/jira/browse/FLINK-19714
Zhu Zhu created FLINK-19712:
---
Summary: Pipelined region failover should skip restarting tasks in
CREATED
Key: FLINK-19712
URL: https://issues.apache.org/jira/browse/FLINK-19712
Project: Flink
Zhu Zhu created FLINK-19703:
---
Summary: A result partition is not untracked after its producer
task failed in TaskManager
Key: FLINK-19703
URL: https://issues.apache.org/jira/browse/FLINK-19703
Project:
Zhu Zhu created FLINK-19598:
---
Summary: E2E test Kerberized YARN application on Docker test
(default input) fails on CI
Key: FLINK-19598
URL: https://issues.apache.org/jira/browse/FLINK-19598
Project: Flink
Zhu Zhu created FLINK-19570:
---
Summary: Execution graph related tests are possibly broken due to
registering duplicated ExecutionAttemptID
Key: FLINK-19570
URL: https://issues.apache.org/jira/browse/FLINK-19570
Zhu Zhu created FLINK-19287:
---
Summary: Fix minor version in flink docs
Key: FLINK-19287
URL: https://issues.apache.org/jira/browse/FLINK-19287
Project: Flink
Issue Type: Bug
Components:
Zhu Zhu created FLINK-19286:
---
Summary: Improve pipelined region scheduling performance
Key: FLINK-19286
URL: https://issues.apache.org/jira/browse/FLINK-19286
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-19189:
---
Summary: Enable pipelined scheduling by default
Key: FLINK-19189
URL: https://issues.apache.org/jira/browse/FLINK-19189
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-18972:
---
Summary: Unfulfillable slot requests of Blink planner batch jobs
never timeout
Key: FLINK-18972
URL: https://issues.apache.org/jira/browse/FLINK-18972
Project: Flink
Zhu Zhu created FLINK-18496:
---
Summary: Anchors are not generated based on ZH characters
Key: FLINK-18496
URL: https://issues.apache.org/jira/browse/FLINK-18496
Project: Flink
Issue Type: Bug
Zhu Zhu created FLINK-18372:
---
Summary: NullPointerException can happen in
SlotPoolImpl#maybeRemapOrphanedAllocation
Key: FLINK-18372
URL: https://issues.apache.org/jira/browse/FLINK-18372
Project: Flink
Zhu Zhu created FLINK-18355:
---
Summary: Simplify tests of SlotPoolImpl
Key: FLINK-18355
URL: https://issues.apache.org/jira/browse/FLINK-18355
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-18295:
---
Summary: Remove the hack logics of result consumers
Key: FLINK-18295
URL: https://issues.apache.org/jira/browse/FLINK-18295
Project: Flink
Issue Type: Improvement
Zhu Zhu created FLINK-18114:
---
Summary: Expose more details in logs for debugging bulk slot
allocation failures
Key: FLINK-18114
URL: https://issues.apache.org/jira/browse/FLINK-18114
Project: Flink
Zhu Zhu created FLINK-18034:
---
Summary: Introduce PreferredLocationsRetriever
Key: FLINK-18034
URL: https://issues.apache.org/jira/browse/FLINK-18034
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-17821:
---
Summary:
Kafka010TableITCase>KafkaTableTestBase.testKafkaSourceSink failed on AZP
Key: FLINK-17821
URL: https://issues.apache.org/jira/browse/FLINK-17821
Project: Flink
Zhu Zhu created FLINK-17760:
---
Summary: Rework tests to not rely on legacy scheduling logics in
ExecutionGraph anymore
Key: FLINK-17760
URL: https://issues.apache.org/jira/browse/FLINK-17760
Project: Flink
Zhu Zhu created FLINK-17759:
---
Summary: Remove RestartIndividualStrategy
Key: FLINK-17759
URL: https://issues.apache.org/jira/browse/FLINK-17759
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-17758:
---
Summary: Remove AdaptedRestartPipelinedRegionStrategyNG
Key: FLINK-17758
URL: https://issues.apache.org/jira/browse/FLINK-17758
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-17726:
---
Summary: Scheduler should take care of tasks directly canceled by
TaskManager
Key: FLINK-17726
URL: https://issues.apache.org/jira/browse/FLINK-17726
Project: Flink
Zhu Zhu created FLINK-17714:
---
Summary: Support custom RestartBackoffTimeStrategy
Key: FLINK-17714
URL: https://issues.apache.org/jira/browse/FLINK-17714
Project: Flink
Issue Type: Wish
Zhu Zhu created FLINK-17542:
---
Summary: Unify slot request timeout handling for streaming and
batch tasks
Key: FLINK-17542
URL: https://issues.apache.org/jira/browse/FLINK-17542
Project: Flink
Zhu Zhu created FLINK-17410:
---
Summary: BlockingPartitionBenchmark compilation failed due to
changed StreamGraph interface
Key: FLINK-17410
URL: https://issues.apache.org/jira/browse/FLINK-17410
Project:
Zhu Zhu created FLINK-17330:
---
Summary: Avoid scheduling deadlocks caused by intra-logical-region
ALL-to-ALL blocking edges
Key: FLINK-17330
URL: https://issues.apache.org/jira/browse/FLINK-17330
Project:
Zhu Zhu created FLINK-17047:
---
Summary: Simplify SchedulingStrategy#onPartitionConsumable(...)
parameters
Key: FLINK-17047
URL: https://issues.apache.org/jira/browse/FLINK-17047
Project: Flink
Zhu Zhu created FLINK-17046:
---
Summary: SavepointWriterITCase failed on travis
Key: FLINK-17046
URL: https://issues.apache.org/jira/browse/FLINK-17046
Project: Flink
Issue Type: Bug
Zhu Zhu created FLINK-17021:
---
Summary: Blink Planner set GlobalDataExchangeMode
Key: FLINK-17021
URL: https://issues.apache.org/jira/browse/FLINK-17021
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-17020:
---
Summary: Introduce GlobalDataExchangeMode for JobGraph Generation
Key: FLINK-17020
URL: https://issues.apache.org/jira/browse/FLINK-17020
Project: Flink
Issue Type:
Zhu Zhu created FLINK-17019:
---
Summary: Implement FIFO Physical Slot Assignment in SlotPoolImpl
Key: FLINK-17019
URL: https://issues.apache.org/jira/browse/FLINK-17019
Project: Flink
Issue Type:
Zhu Zhu created FLINK-17018:
---
Summary: Use Bulk Slot Allocation in DefaultExecutionSlotAllocator
Key: FLINK-17018
URL: https://issues.apache.org/jira/browse/FLINK-17018
Project: Flink
Issue Type:
Zhu Zhu created FLINK-17017:
---
Summary: Implement Bulk Slot Allocation in SchedulerImpl
Key: FLINK-17017
URL: https://issues.apache.org/jira/browse/FLINK-17017
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-17014:
---
Summary: Implement PipelinedRegionSchedulingStrategy
Key: FLINK-17014
URL: https://issues.apache.org/jira/browse/FLINK-17014
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-16560:
---
Summary: StreamExecutionEnvironment configuration is empty when
building program via PackagedProgramUtils#createJobGraph
Key: FLINK-16560
URL:
Zhu Zhu created FLINK-16430:
---
Summary: Pipelined region scheduling
Key: FLINK-16430
URL: https://issues.apache.org/jira/browse/FLINK-16430
Project: Flink
Issue Type: Task
Components:
Zhu Zhu created FLINK-16300:
---
Summary: Reworks SchedulerTestUtils with testing classes to
replace mockito usages
Key: FLINK-16300
URL: https://issues.apache.org/jira/browse/FLINK-16300
Project: Flink
Zhu Zhu created FLINK-16276:
---
Summary: Introduce factory methods to create DefaultScheduler for
testing
Key: FLINK-16276
URL: https://issues.apache.org/jira/browse/FLINK-16276
Project: Flink
1 - 100 of 194 matches
Mail list logo
