[jira] [Created] (FLINK-8382) sheduleRunAsync with a positive schedule delay does not work in JobMaster

2018-01-05 Thread Zhu Zhu (JIRA)
Zhu Zhu created FLINK-8382: -- Summary: sheduleRunAsync with a positive schedule delay does not work in JobMaster Key: FLINK-8382 URL: https://issues.apache.org/jira/browse/FLINK-8382 Project: Flink

[jira] [Created] (FLINK-10412) toString field in AbstractID should be transient to avoid been serialized

2018-09-24 Thread Zhu Zhu (JIRA)
Zhu Zhu created FLINK-10412: --- Summary: toString field in AbstractID should be transient to avoid been serialized Key: FLINK-10412 URL: https://issues.apache.org/jira/browse/FLINK-10412 Project: Flink

[jira] [Created] (FLINK-10413) requestPartitionState messages overwhelms JM RPC main thread

2018-09-24 Thread Zhu Zhu (JIRA)
Zhu Zhu created FLINK-10413: --- Summary: requestPartitionState messages overwhelms JM RPC main thread Key: FLINK-10413 URL: https://issues.apache.org/jira/browse/FLINK-10413 Project: Flink Issue

[jira] [Created] (FLINK-11165) Refine the deploying log for easier finding of task locations

2018-12-14 Thread Zhu Zhu (JIRA)
Zhu Zhu created FLINK-11165: --- Summary: Refine the deploying log for easier finding of task locations Key: FLINK-11165 URL: https://issues.apache.org/jira/browse/FLINK-11165 Project: Flink Issue

[jira] [Created] (FLINK-10945) Avoid resource deadlocks for finite stream jobs when resources are limited

2018-11-20 Thread Zhu Zhu (JIRA)
Zhu Zhu created FLINK-10945: --- Summary: Avoid resource deadlocks for finite stream jobs when resources are limited Key: FLINK-10945 URL: https://issues.apache.org/jira/browse/FLINK-10945 Project: Flink

[jira] [Created] (FLINK-12131) Resetting ExecutionVertex in region failover may cause inconsistency of IntermediateResult status

2019-04-08 Thread Zhu Zhu (JIRA)
Zhu Zhu created FLINK-12131: --- Summary: Resetting ExecutionVertex in region failover may cause inconsistency of IntermediateResult status Key: FLINK-12131 URL: https://issues.apache.org/jira/browse/FLINK-12131

[jira] [Created] (FLINK-12138) Limit input split count of each source task for better failover experience

2019-04-09 Thread Zhu Zhu (JIRA)
Zhu Zhu created FLINK-12138: --- Summary: Limit input split count of each source task for better failover experience Key: FLINK-12138 URL: https://issues.apache.org/jira/browse/FLINK-12138 Project: Flink

[jira] [Created] (FLINK-12643) Implement ExecutionGraph to FailoverTopology Adapter

2019-05-28 Thread Zhu Zhu (JIRA)
Zhu Zhu created FLINK-12643: --- Summary: Implement ExecutionGraph to FailoverTopology Adapter Key: FLINK-12643 URL: https://issues.apache.org/jira/browse/FLINK-12643 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-12709) Implement RestartBackoffTimeStrategyFactoryLoader

2019-06-03 Thread Zhu Zhu (JIRA)
Zhu Zhu created FLINK-12709: --- Summary: Implement RestartBackoffTimeStrategyFactoryLoader Key: FLINK-12709 URL: https://issues.apache.org/jira/browse/FLINK-12709 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-12876) Adapt region failover NG for legacy scheduler

2019-06-17 Thread Zhu Zhu (JIRA)
Zhu Zhu created FLINK-12876: --- Summary: Adapt region failover NG for legacy scheduler Key: FLINK-12876 URL: https://issues.apache.org/jira/browse/FLINK-12876 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-12926) Main thread checking in some tests fails

2019-06-21 Thread Zhu Zhu (JIRA)
Zhu Zhu created FLINK-12926: --- Summary: Main thread checking in some tests fails Key: FLINK-12926 URL: https://issues.apache.org/jira/browse/FLINK-12926 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-12369) Introducing next version failover strategy interfaces and implement a region failover strategy with it

2019-04-29 Thread Zhu Zhu (JIRA)
Zhu Zhu created FLINK-12369: --- Summary: Introducing next version failover strategy interfaces and implement a region failover strategy with it Key: FLINK-12369 URL: https://issues.apache.org/jira/browse/FLINK-12369

[jira] [Created] (FLINK-13241) YarnResourceManager gives no response to second round slot allocations

2019-07-12 Thread Zhu Zhu (JIRA)
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

[jira] [Created] (FLINK-13254) Task launching blocked due to pending on #waitForChannel after failover

2019-07-14 Thread Zhu Zhu (JIRA)
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

[jira] [Created] (FLINK-13256) Periodical checkpointing is stopped after failovers

2019-07-15 Thread Zhu Zhu (JIRA)
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

[jira] [Created] (FLINK-13056) Optimize region failover performance on calculating vertices to restart

2019-07-02 Thread Zhu Zhu (JIRA)
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

[jira] [Created] (FLINK-13055) Leverage JM side partition state to improve region failover experience

2019-07-02 Thread Zhu Zhu (JIRA)
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

[jira] [Created] (FLINK-13887) ExecutionConfig#setDefaultInputDependencyConstraint should do NotNull check on params

2019-08-28 Thread Zhu Zhu (Jira)
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:

[jira] [Created] (FLINK-13962) Execution#taskRestore leaks if task fails before deploying

2019-09-04 Thread Zhu Zhu (Jira)
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:

[jira] [Created] (FLINK-14069) Enable TimeUtils to parse all time units labels supported by scala Duration

2019-09-12 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14070) Use TimeUtils to parse duration configs

2019-09-12 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14040) Enable a cron job to run MiniCluster tests for schedulerNG

2019-09-10 Thread Zhu Zhu (Jira)
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:

[jira] [Created] (FLINK-14000) Remove legacy ProcessShutDownThread

2019-09-07 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-13336) Remove the legacy batch fault tolerance page and redirect it to the new task failure recovery page

2019-07-19 Thread Zhu Zhu (JIRA)
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

[jira] [Created] (FLINK-13421) Unexpected ConcurrentModificationException when RM notify JM about allocation failure

2019-07-25 Thread Zhu Zhu (JIRA)
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:

[jira] [Created] (FLINK-14128) Remove the description of restart strategy customization

2019-09-19 Thread Zhu Zhu (Jira)
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:

[jira] [Created] (FLINK-14131) Support choosing new version failover strategy via configuration

2019-09-19 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14271) Deprecate legacy RestartPipelinedRegionStrategy

2019-09-29 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14236) Make LazyFromSourcesSchedulingStrategy do lazy scheduling only based on partition state

2019-09-26 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14233) All task state changes should be notified to SchedulingStrategy (SchedulerNG)

2019-09-26 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14232) Support full restarts for DefaultScheduler (SchedulerNG)

2019-09-26 Thread Zhu Zhu (Jira)
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:

[jira] [Created] (FLINK-14234) All partition consumable events should be notified to SchedulingStrategy (SchedulerNG)

2019-09-26 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14247) Use NoResourceAvailableException to wrap TimeoutException on slot allocation (Scheduler NG)

2019-09-27 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14246) Annotate all MiniCluster tests in flink-runtime with AlsoRunWithSchedulerNG

2019-09-27 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14183) Remove unnecessary scala Duration usages in flink-runtime

2019-09-24 Thread Zhu Zhu (Jira)
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:

[jira] [Created] (FLINK-14182) Make TimeUtils able to parse duration string with plural form labels

2019-09-24 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14168) Remove unused BootstrapTools#generateTaskManagerConfiguration

2019-09-23 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14162) Unify SchedulerOperations#allocateSlotsAndDeploy implementation for all scheduling strategies

2019-09-22 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14310) Get ExecutionVertexID from ExecutionVertex rather than creating new instances

2019-10-02 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14312) Support logical pipelined region partitioning of JobGraph

2019-10-02 Thread Zhu Zhu (Jira)
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:

[jira] [Created] (FLINK-14314) Allocate shared slot resources respecting the resources of all vertices in the group

2019-10-02 Thread Zhu Zhu (Jira)
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:

[jira] [Created] (FLINK-14248) LazyFromSourcesSchedulingStrategy should support to tasks in terminal state

2019-09-27 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14163) A Task should be deployed only after all its partitions have completed the registration

2019-09-22 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14566) Enable ResourceSpec to get/set whether managed memory is used

2019-10-30 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14606) Simplify params of Execution#processFail

2019-11-04 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14607) SharedSlot cannot fulfill pending slot requests before it's totally released

2019-11-04 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14594) Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

2019-11-03 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14701) Slot leaks if SharedSlotOversubscribedException happens

2019-11-10 Thread Zhu Zhu (Jira)
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:

[jira] [Created] (FLINK-14708) Introduce full restarts failover strategy for NG scheduler

2019-11-11 Thread Zhu Zhu (Jira)
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:

[jira] [Created] (FLINK-14733) Introduce ResourceProfile builder to enable flexible building

2019-11-12 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14643) Deprecate metric `fullRestarts`

2019-11-06 Thread Zhu Zhu (Jira)
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:

[jira] [Created] (FLINK-14641) Fix description of metric `fullRestarts`

2019-11-06 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14611) Move allVerticesInSameSlotSharingGroupByDefault from ExecutionConfig to StreamGraph

2019-11-05 Thread Zhu Zhu (Jira)
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:

[jira] [Created] (FLINK-14909) Let tasks in a batch get scheduled in topological order and subtaskIndex ascending pattern

2019-11-21 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-15037) Introduce LimittingMemoryManager as operator scope MemoyManager

2019-12-03 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-15031) Calculate required shuffle memory cases before allocating slots in resources specified

2019-12-02 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-15178) Task crash due to mmap allocation failure for BLOCKING shuffle

2019-12-10 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-15224) Resource requirements are not respected when fulfilling a slot request with unresolvedRootSlots from a SlotSharingManager

2019-12-12 Thread Zhu Zhu (Jira)
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:

[jira] [Created] (FLINK-14451) Change FailoverTopology to extend base topology

2019-10-18 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14536) Make clear the way to aggregate specified cpuCores resources

2019-10-27 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14453) Support building pipelined regions from base topology

2019-10-18 Thread Zhu Zhu (Jira)
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:

[jira] [Created] (FLINK-14450) Change SchedulingTopology to extend base topology

2019-10-18 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14452) Keep only one execution topology in scheduler

2019-10-18 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14510) Remove the lazy vertex attaching mechanism from ExecutionGraph

2019-10-23 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14439) RestartPipelinedRegionStrategy leverage tracked partition availability for better failover experience in DefaultScheduler

2019-10-17 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-14439: --- Summary: RestartPipelinedRegionStrategy leverage tracked partition availability for better failover experience in DefaultScheduler Key: FLINK-14439 URL:

[jira] [Created] (FLINK-14440) Enable BatchFineGrainedRecoveryITCase to pass with scheduler NG

2019-10-17 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14869) Force an extended resource to be null if it's value is 0

2019-11-19 Thread Zhu Zhu (Jira)
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:

[jira] [Created] (FLINK-14870) Introducing non-nullable assumption for task slot sharing group

2019-11-19 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14936) Introduce MemoryManager#computeMemorySize to calculate managed memory of an operator from a fraction

2019-11-24 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14734) Add a ResourceSpec in SlotSharingGroup to describe its overall resources

2019-11-12 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14974) Managed memory fractions should be rounded properly to not summed up to be more than 1.0

2019-11-27 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14164) Add a metric to show failover count regarding fine grained recovery

2019-09-22 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14206) Make fullRestart metric to count fine grained restarts as well

2019-09-25 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14330) Introduce a unified topology interface

2019-10-06 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14331) Reset vertices right after they transition to terminated states

2019-10-06 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14362) Change DefaultSchedulingResultPartition to return correct partition state

2019-10-10 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14363) No need to cancel vertex when its version is outdated in scheduling (SchedulerNG)

2019-10-10 Thread Zhu Zhu (Jira)
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:

[jira] [Created] (FLINK-14366) Annotate MiniCluster tests in flink-tests with AlsoRunWithSchedulerNG

2019-10-11 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14365) Annotate MiniCluster tests in core modules with AlsoRunWithSchedulerNG

2019-10-11 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14371) Enable ClassLoaderITCase to pass with scheduler NG

2019-10-11 Thread Zhu Zhu (Jira)
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:

[jira] [Created] (FLINK-14372) Enable KeyedStateCheckpointingITCase to pass with scheduler NG

2019-10-11 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14373) Enable ZooKeeperHighAvailabilityITCase to pass with scheduler NG

2019-10-11 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14375) Avoid to trigger failover on a non-effective task failure notification

2019-10-11 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-14374) Enable RegionFailoverITCase to pass with scheduler NG

2019-10-11 Thread Zhu Zhu (Jira)
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:

[jira] [Created] (FLINK-15325) Input location preference which affects task distribution may make certain job performance worse

2019-12-19 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-15169) Errors happen in the scheduling of DefaultScheduler is not shown in WebUI

2019-12-09 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-16300) Reworks SchedulerTestUtils with testing classes to replace mockito usages

2020-02-26 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-16430) Pipelined region scheduling

2020-03-04 Thread Zhu Zhu (Jira)
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:

[jira] [Created] (FLINK-16276) Introduce factory methods to create DefaultScheduler for testing

2020-02-25 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-16139) Co-location constraints are not reset on task recovery in DefaultScheduler

2020-02-18 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-15668) Remove AlsoRunWithLegacyScheduler

2020-01-19 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-15668: --- Summary: Remove AlsoRunWithLegacyScheduler Key: FLINK-15668 URL: https://issues.apache.org/jira/browse/FLINK-15668 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-15651) JarHandlerTest.testRunJar fails on travis

2020-01-18 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-15651: --- Summary: JarHandlerTest.testRunJar fails on travis Key: FLINK-15651 URL: https://issues.apache.org/jira/browse/FLINK-15651 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-15626) Remove legacy scheduler

2020-01-16 Thread Zhu Zhu (Jira)
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:

[jira] [Created] (FLINK-15629) Remove LegacyScheduler class and the consequently unused codes after this removal

2020-01-17 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-15629: --- Summary: Remove LegacyScheduler class and the consequently unused codes after this removal Key: FLINK-15629 URL: https://issues.apache.org/jira/browse/FLINK-15629 Project:

[jira] [Created] (FLINK-15582) Enable batch scheduling tests in LegacySchedulerBatchSchedulingTest for DefaultScheduler as well

2020-01-14 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-15456) Job keeps failing on slot allocation timeout due to RM not allocating new TMs for slot requests

2020-01-02 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-15499) No debug log describes the host of a TM before any task is deployed to it in YARN mode

2020-01-07 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-16560) StreamExecutionEnvironment configuration is empty when building program via PackagedProgramUtils#createJobGraph

2020-03-11 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-16560: --- Summary: StreamExecutionEnvironment configuration is empty when building program via PackagedProgramUtils#createJobGraph Key: FLINK-16560 URL:

[jira] [Created] (FLINK-17046) SavepointWriterITCase failed on travis

2020-04-08 Thread Zhu Zhu (Jira)
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

[jira] [Created] (FLINK-17018) Use Bulk Slot Allocation in DefaultExecutionSlotAllocator

2020-04-07 Thread Zhu Zhu (Jira)
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:

  1   2   >