Zhu Zhu created FLINK-13055:
---
Summary: Leverage JM side partition state to improve region
failover experience
Key: FLINK-13055
URL: https://issues.apache.org/jira/browse/FLINK-13055
Project: Flink
Zhu Zhu created FLINK-13056:
---
Summary: Optimize region failover performance on calculating
vertices to restart
Key: FLINK-13056
URL: https://issues.apache.org/jira/browse/FLINK-13056
Project: Flink
Zhu Zhu created FLINK-13241:
---
Summary: YarnResourceManager gives no response to second round
slot allocations
Key: FLINK-13241
URL: https://issues.apache.org/jira/browse/FLINK-13241
Project: Flink
Zhu Zhu created FLINK-13254:
---
Summary: Task launching blocked due to pending on #waitForChannel
after failover
Key: FLINK-13254
URL: https://issues.apache.org/jira/browse/FLINK-13254
Project: Flink
Zhu Zhu created FLINK-13256:
---
Summary: Periodical checkpointing is stopped after failovers
Key: FLINK-13256
URL: https://issues.apache.org/jira/browse/FLINK-13256
Project: Flink
Issue Type: Bug
Zhu Zhu created FLINK-13336:
---
Summary: Remove the legacy batch fault tolerance page and redirect
it to the new task failure recovery page
Key: FLINK-13336
URL: https://issues.apache.org/jira/browse/FLINK-13336
Zhu Zhu created FLINK-13421:
---
Summary: Unexpected ConcurrentModificationException when RM notify
JM about allocation failure
Key: FLINK-13421
URL: https://issues.apache.org/jira/browse/FLINK-13421
Project:
Zhu Zhu created FLINK-13887:
---
Summary: ExecutionConfig#setDefaultInputDependencyConstraint
should do NotNull check on params
Key: FLINK-13887
URL: https://issues.apache.org/jira/browse/FLINK-13887
Project:
Zhu Zhu created FLINK-13962:
---
Summary: Execution#taskRestore leaks if task fails before deploying
Key: FLINK-13962
URL: https://issues.apache.org/jira/browse/FLINK-13962
Project: Flink
Issue Type:
Zhu Zhu created FLINK-14000:
---
Summary: Remove legacy ProcessShutDownThread
Key: FLINK-14000
URL: https://issues.apache.org/jira/browse/FLINK-14000
Project: Flink
Issue Type: Sub-task
Comp
Zhu Zhu created FLINK-14040:
---
Summary: Enable a cron job to run MiniCluster tests for schedulerNG
Key: FLINK-14040
URL: https://issues.apache.org/jira/browse/FLINK-14040
Project: Flink
Issue Type:
Zhu Zhu created FLINK-14069:
---
Summary: Enable TimeUtils to parse all time units labels supported
by scala Duration
Key: FLINK-14069
URL: https://issues.apache.org/jira/browse/FLINK-14069
Project: Flink
Zhu Zhu created FLINK-14070:
---
Summary: Use TimeUtils to parse duration configs
Key: FLINK-14070
URL: https://issues.apache.org/jira/browse/FLINK-14070
Project: Flink
Issue Type: Improvement
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-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 Typ
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-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
C
Zhu Zhu created FLINK-16139:
---
Summary: Co-location constraints are not reset on task recovery in
DefaultScheduler
Key: FLINK-16139
URL: https://issues.apache.org/jira/browse/FLINK-16139
Project: Flink
Zhu Zhu created FLINK-16180:
---
Summary: Replacing vertexExecution in ScheduledUnit with
executionVertexID
Key: FLINK-16180
URL: https://issues.apache.org/jira/browse/FLINK-16180
Project: Flink
Issu
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
Issue
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-16430:
---
Summary: Pipelined region scheduling
Key: FLINK-16430
URL: https://issues.apache.org/jira/browse/FLINK-16430
Project: Flink
Issue Type: Task
Components: Runt
Zhu Zhu created FLINK-16560:
---
Summary: StreamExecutionEnvironment configuration is empty when
building program via PackagedProgramUtils#createJobGraph
Key: FLINK-16560
URL: https://issues.apache.org/jira/browse/FLINK-16
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-17016:
---
Summary: Use PipelinedRegionSchedulingStrategy in DefaultScheduler
(for Blink Planner)
Key: FLINK-17016
URL: https://issues.apache.org/jira/browse/FLINK-17016
Project: Flink
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-17018:
---
Summary: Use Bulk Slot Allocation in DefaultExecutionSlotAllocator
Key: FLINK-17018
URL: https://issues.apache.org/jira/browse/FLINK-17018
Project: Flink
Issue Type: S
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: Sub
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: Su
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-17046:
---
Summary: SavepointWriterITCase failed on travis
Key: FLINK-17046
URL: https://issues.apache.org/jira/browse/FLINK-17046
Project: Flink
Issue Type: Bug
Compon
Zhu Zhu created FLINK-17047:
---
Summary: Simplify SchedulingStrategy#onPartitionConsumable(...)
parameters
Key: FLINK-17047
URL: https://issues.apache.org/jira/browse/FLINK-17047
Project: Flink
Issu
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: Fl
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: Fli
Zhu Zhu created FLINK-14128:
---
Summary: Remove the description of restart strategy customization
Key: FLINK-14128
URL: https://issues.apache.org/jira/browse/FLINK-14128
Project: Flink
Issue Type: Im
Zhu Zhu created FLINK-14131:
---
Summary: Support choosing new version failover strategy via
configuration
Key: FLINK-14131
URL: https://issues.apache.org/jira/browse/FLINK-14131
Project: Flink
Issue
Zhu Zhu created FLINK-14162:
---
Summary: Unify SchedulerOperations#allocateSlotsAndDeploy
implementation for all scheduling strategies
Key: FLINK-14162
URL: https://issues.apache.org/jira/browse/FLINK-14162
P
Zhu Zhu created FLINK-14163:
---
Summary: A Task should be deployed only after all its partitions
have completed the registration
Key: FLINK-14163
URL: https://issues.apache.org/jira/browse/FLINK-14163
Project
Zhu Zhu created FLINK-14164:
---
Summary: Add a metric to show failover count regarding fine
grained recovery
Key: FLINK-14164
URL: https://issues.apache.org/jira/browse/FLINK-14164
Project: Flink
Is
Zhu Zhu created FLINK-14168:
---
Summary: Remove unused
BootstrapTools#generateTaskManagerConfiguration
Key: FLINK-14168
URL: https://issues.apache.org/jira/browse/FLINK-14168
Project: Flink
Issue Ty
Zhu Zhu created FLINK-14182:
---
Summary: Make TimeUtils able to parse duration string with plural
form labels
Key: FLINK-14182
URL: https://issues.apache.org/jira/browse/FLINK-14182
Project: Flink
I
Zhu Zhu created FLINK-14183:
---
Summary: Remove unnecessary scala Duration usages in flink-runtime
Key: FLINK-14183
URL: https://issues.apache.org/jira/browse/FLINK-14183
Project: Flink
Issue Type: S
Zhu Zhu created FLINK-14206:
---
Summary: Make fullRestart metric to count fine grained restarts as
well
Key: FLINK-14206
URL: https://issues.apache.org/jira/browse/FLINK-14206
Project: Flink
Issue T
Zhu Zhu created FLINK-14232:
---
Summary: Support full restarts for DefaultScheduler (SchedulerNG)
Key: FLINK-14232
URL: https://issues.apache.org/jira/browse/FLINK-14232
Project: Flink
Issue Type: Su
Zhu Zhu created FLINK-14233:
---
Summary: All task state changes should be notified to
SchedulingStrategy (SchedulerNG)
Key: FLINK-14233
URL: https://issues.apache.org/jira/browse/FLINK-14233
Project: Flink
Zhu Zhu created FLINK-14234:
---
Summary: All partition consumable events should be notified to
SchedulingStrategy (SchedulerNG)
Key: FLINK-14234
URL: https://issues.apache.org/jira/browse/FLINK-14234
Project:
Zhu Zhu created FLINK-14236:
---
Summary: Make LazyFromSourcesSchedulingStrategy do lazy scheduling
only based on partition state
Key: FLINK-14236
URL: https://issues.apache.org/jira/browse/FLINK-14236
Project
Zhu Zhu created FLINK-14246:
---
Summary: Annotate all MiniCluster tests in flink-runtime with
AlsoRunWithSchedulerNG
Key: FLINK-14246
URL: https://issues.apache.org/jira/browse/FLINK-14246
Project: Flink
Zhu Zhu created FLINK-14247:
---
Summary: Use NoResourceAvailableException to wrap TimeoutException
on slot allocation (Scheduler NG)
Key: FLINK-14247
URL: https://issues.apache.org/jira/browse/FLINK-14247
Pr
Zhu Zhu created FLINK-14248:
---
Summary: LazyFromSourcesSchedulingStrategy should support to tasks
in terminal state
Key: FLINK-14248
URL: https://issues.apache.org/jira/browse/FLINK-14248
Project: Flink
Zhu Zhu created FLINK-14271:
---
Summary: Deprecate legacy RestartPipelinedRegionStrategy
Key: FLINK-14271
URL: https://issues.apache.org/jira/browse/FLINK-14271
Project: Flink
Issue Type: Bug
Zhu Zhu created FLINK-14310:
---
Summary: Get ExecutionVertexID from ExecutionVertex rather than
creating new instances
Key: FLINK-14310
URL: https://issues.apache.org/jira/browse/FLINK-14310
Project: Flink
Zhu Zhu created FLINK-14312:
---
Summary: Support logical pipelined region partitioning of JobGraph
Key: FLINK-14312
URL: https://issues.apache.org/jira/browse/FLINK-14312
Project: Flink
Issue Type: S
Zhu Zhu created FLINK-14314:
---
Summary: Allocate shared slot resources respecting the resources
of all vertices in the group
Key: FLINK-14314
URL: https://issues.apache.org/jira/browse/FLINK-14314
Project: F
Zhu Zhu created FLINK-14330:
---
Summary: Introduce a unified topology interface
Key: FLINK-14330
URL: https://issues.apache.org/jira/browse/FLINK-14330
Project: Flink
Issue Type: Sub-task
C
Zhu Zhu created FLINK-14331:
---
Summary: Reset vertices right after they transition to terminated
states
Key: FLINK-14331
URL: https://issues.apache.org/jira/browse/FLINK-14331
Project: Flink
Issue
Zhu Zhu created FLINK-14362:
---
Summary: Change DefaultSchedulingResultPartition to return correct
partition state
Key: FLINK-14362
URL: https://issues.apache.org/jira/browse/FLINK-14362
Project: Flink
Zhu Zhu created FLINK-14363:
---
Summary: No need to cancel vertex when its version is outdated in
scheduling (SchedulerNG)
Key: FLINK-14363
URL: https://issues.apache.org/jira/browse/FLINK-14363
Project: Flin
Zhu Zhu created FLINK-14365:
---
Summary: Annotate MiniCluster tests in core modules with
AlsoRunWithSchedulerNG
Key: FLINK-14365
URL: https://issues.apache.org/jira/browse/FLINK-14365
Project: Flink
Zhu Zhu created FLINK-14366:
---
Summary: Annotate MiniCluster tests in flink-tests with
AlsoRunWithSchedulerNG
Key: FLINK-14366
URL: https://issues.apache.org/jira/browse/FLINK-14366
Project: Flink
Zhu Zhu created FLINK-14371:
---
Summary: Enable ClassLoaderITCase to pass with scheduler NG
Key: FLINK-14371
URL: https://issues.apache.org/jira/browse/FLINK-14371
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-14372:
---
Summary: Enable KeyedStateCheckpointingITCase to pass with
scheduler NG
Key: FLINK-14372
URL: https://issues.apache.org/jira/browse/FLINK-14372
Project: Flink
Issue T
Zhu Zhu created FLINK-14373:
---
Summary: Enable ZooKeeperHighAvailabilityITCase to pass with
scheduler NG
Key: FLINK-14373
URL: https://issues.apache.org/jira/browse/FLINK-14373
Project: Flink
Issue
Zhu Zhu created FLINK-14374:
---
Summary: Enable RegionFailoverITCase to pass with scheduler NG
Key: FLINK-14374
URL: https://issues.apache.org/jira/browse/FLINK-14374
Project: Flink
Issue Type: Sub-t
Zhu Zhu created FLINK-14375:
---
Summary: Avoid to trigger failover on a non-effective task failure
notification
Key: FLINK-14375
URL: https://issues.apache.org/jira/browse/FLINK-14375
Project: Flink
Zhu Zhu created FLINK-14439:
---
Summary: RestartPipelinedRegionStrategy leverage tracked partition
availability for better failover experience in DefaultScheduler
Key: FLINK-14439
URL: https://issues.apache.org/jira/brow
Zhu Zhu created FLINK-14440:
---
Summary: Enable BatchFineGrainedRecoveryITCase to pass with
scheduler NG
Key: FLINK-14440
URL: https://issues.apache.org/jira/browse/FLINK-14440
Project: Flink
Issue
Zhu Zhu created FLINK-14450:
---
Summary: Change SchedulingTopology to extend base topology
Key: FLINK-14450
URL: https://issues.apache.org/jira/browse/FLINK-14450
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-14451:
---
Summary: Change FailoverTopology to extend base topology
Key: FLINK-14451
URL: https://issues.apache.org/jira/browse/FLINK-14451
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-14452:
---
Summary: Keep only one execution topology in scheduler
Key: FLINK-14452
URL: https://issues.apache.org/jira/browse/FLINK-14452
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-14453:
---
Summary: Support building pipelined regions from base topology
Key: FLINK-14453
URL: https://issues.apache.org/jira/browse/FLINK-14453
Project: Flink
Issue Type: Sub-t
Zhu Zhu created FLINK-14510:
---
Summary: Remove the lazy vertex attaching mechanism from
ExecutionGraph
Key: FLINK-14510
URL: https://issues.apache.org/jira/browse/FLINK-14510
Project: Flink
Issue T
Zhu Zhu created FLINK-14536:
---
Summary: Make clear the way to aggregate specified cpuCores
resources
Key: FLINK-14536
URL: https://issues.apache.org/jira/browse/FLINK-14536
Project: Flink
Issue Typ
Zhu Zhu created FLINK-14566:
---
Summary: Enable ResourceSpec to get/set whether managed memory is
used
Key: FLINK-14566
URL: https://issues.apache.org/jira/browse/FLINK-14566
Project: Flink
Issue Ty
Zhu Zhu created FLINK-14594:
---
Summary: Fix matching logics of
ResourceSpec/ResourceProfile/Resource considering double values
Key: FLINK-14594
URL: https://issues.apache.org/jira/browse/FLINK-14594
Project:
Zhu Zhu created FLINK-14606:
---
Summary: Simplify params of Execution#processFail
Key: FLINK-14606
URL: https://issues.apache.org/jira/browse/FLINK-14606
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-14607:
---
Summary: SharedSlot cannot fulfill pending slot requests before
it's totally released
Key: FLINK-14607
URL: https://issues.apache.org/jira/browse/FLINK-14607
Project: Flink
Zhu Zhu created FLINK-14611:
---
Summary: Move allVerticesInSameSlotSharingGroupByDefault from
ExecutionConfig to StreamGraph
Key: FLINK-14611
URL: https://issues.apache.org/jira/browse/FLINK-14611
Project: Fl
Zhu Zhu created FLINK-14641:
---
Summary: Fix description of metric `fullRestarts`
Key: FLINK-14641
URL: https://issues.apache.org/jira/browse/FLINK-14641
Project: Flink
Issue Type: Bug
Comp
Zhu Zhu created FLINK-14643:
---
Summary: Deprecate metric `fullRestarts`
Key: FLINK-14643
URL: https://issues.apache.org/jira/browse/FLINK-14643
Project: Flink
Issue Type: Bug
Components: R
Zhu Zhu created FLINK-14701:
---
Summary: Slot leaks if SharedSlotOversubscribedException happens
Key: FLINK-14701
URL: https://issues.apache.org/jira/browse/FLINK-14701
Project: Flink
Issue Type: Bug
Zhu Zhu created FLINK-14708:
---
Summary: Introduce full restarts failover strategy for NG scheduler
Key: FLINK-14708
URL: https://issues.apache.org/jira/browse/FLINK-14708
Project: Flink
Issue Type:
Zhu Zhu created FLINK-14733:
---
Summary: Introduce ResourceProfile builder to enable flexible
building
Key: FLINK-14733
URL: https://issues.apache.org/jira/browse/FLINK-14733
Project: Flink
Issue Ty
Zhu Zhu created FLINK-14734:
---
Summary: Add a ResourceSpec in SlotSharingGroup to describe its
overall resources
Key: FLINK-14734
URL: https://issues.apache.org/jira/browse/FLINK-14734
Project: Flink
Zhu Zhu created FLINK-14811:
---
Summary: Replace Java Streams with for-loops in vertex input
checking
Key: FLINK-14811
URL: https://issues.apache.org/jira/browse/FLINK-14811
Project: Flink
Issue Typ
Zhu Zhu created FLINK-14869:
---
Summary: Force an extended resource to be null if it's value is 0
Key: FLINK-14869
URL: https://issues.apache.org/jira/browse/FLINK-14869
Project: Flink
Issue Type: Im
Zhu Zhu created FLINK-14870:
---
Summary: Introducing non-nullable assumption for task slot sharing
group
Key: FLINK-14870
URL: https://issues.apache.org/jira/browse/FLINK-14870
Project: Flink
Issue
Zhu Zhu created FLINK-14909:
---
Summary: Let tasks in a batch get scheduled in topological order
and subtaskIndex ascending pattern
Key: FLINK-14909
URL: https://issues.apache.org/jira/browse/FLINK-14909
Proj
Zhu Zhu created FLINK-14936:
---
Summary: Introduce MemoryManager#computeMemorySize to calculate
managed memory of an operator from a fraction
Key: FLINK-14936
URL: https://issues.apache.org/jira/browse/FLINK-14936
Zhu Zhu created FLINK-14974:
---
Summary: Managed memory fractions should be rounded properly to
not summed up to be more than 1.0
Key: FLINK-14974
URL: https://issues.apache.org/jira/browse/FLINK-14974
Projec
Zhu Zhu created FLINK-15031:
---
Summary: Calculate required shuffle memory cases before allocating
slots in resources specified
Key: FLINK-15031
URL: https://issues.apache.org/jira/browse/FLINK-15031
Project:
Zhu Zhu created FLINK-15037:
---
Summary: Introduce LimittingMemoryManager as operator scope
MemoyManager
Key: FLINK-15037
URL: https://issues.apache.org/jira/browse/FLINK-15037
Project: Flink
Issue
Zhu Zhu created FLINK-15169:
---
Summary: Errors happen in the scheduling of DefaultScheduler is
not shown in WebUI
Key: FLINK-15169
URL: https://issues.apache.org/jira/browse/FLINK-15169
Project: Flink
Zhu Zhu created FLINK-15178:
---
Summary: Task crash due to mmap allocation failure for BLOCKING
shuffle
Key: FLINK-15178
URL: https://issues.apache.org/jira/browse/FLINK-15178
Project: Flink
Issue T
Zhu Zhu created FLINK-15224:
---
Summary: Resource requirements are not respected when fulfilling a
slot request with unresolvedRootSlots from a SlotSharingManager
Key: FLINK-15224
URL: https://issues.apache.org/jira/brows
Zhu Zhu created FLINK-15325:
---
Summary: Input location preference which affects task distribution
may make certain job performance worse
Key: FLINK-15325
URL: https://issues.apache.org/jira/browse/FLINK-15325
Zhu Zhu created FLINK-15456:
---
Summary: Job keeps failing on slot allocation timeout due to RM
not allocating new TMs for slot requests
Key: FLINK-15456
URL: https://issues.apache.org/jira/browse/FLINK-15456
Zhu Zhu created FLINK-15499:
---
Summary: No debug log describes the host of a TM before any task
is deployed to it in YARN mode
Key: FLINK-15499
URL: https://issues.apache.org/jira/browse/FLINK-15499
Projec
Zhu Zhu created FLINK-15582:
---
Summary: Enable batch scheduling tests in
LegacySchedulerBatchSchedulingTest for DefaultScheduler as well
Key: FLINK-15582
URL: https://issues.apache.org/jira/browse/FLINK-15582
Zhu Zhu created FLINK-15626:
---
Summary: Remove legacy scheduler
Key: FLINK-15626
URL: https://issues.apache.org/jira/browse/FLINK-15626
Project: Flink
Issue Type: New Feature
Components: R
1 - 100 of 199 matches
Mail list logo
