Commits on Nov 8, 2020

1. [FLINK-19693][runtime] Downstream Failover for Approximate Local Reco… …

   …very
   
   Enables downstream failover for approximate local recovery. That says if a task fails,
   all its downstream tasks restart, including itself. This is achieved by reusing the existing
   RestartPipelinedRegionFailoverStrategy --- treat each individual task connected by
   ResultPartition.Pipelined_Approximate as a separate region.
   
   To achieve this, we introduced an attribute "reconnectable" in ResultPartitionType
   to indicate whether the partition is reconnectable. Notice that this is only a temporary
   solution for now. It will be removed after:
    - Approximate local recovery has its won failover strategy to restart the failed set of
      tasks instead of restarting downstream of failed tasks depending on
      {@code RestartPipelinedRegionFailoverStrategy}
    - FLINK-19895: Unify the life cycle of ResultPartitionType Pipelined Family.
      There is also a good discussion on this in FLINK-19632.

   

   curcur committed Nov 8, 2020
   Configuration menu

   • View commit details
   • Copy full SHA for c2d0a86
   • Browse repository at this point

   Copy the full SHA

   c2d0a86 View commit details

   Browse the repository at this point in the history

2. [FLINK-19693] Introduce a flag to enable approximate failover

   

   curcur committed Nov 8, 2020
   Configuration menu

   • View commit details
   • Copy full SHA for faa8ec8
   • Browse repository at this point

   Copy the full SHA

   faa8ec8 View commit details

   Browse the repository at this point in the history

3. [FLINK-19693] ITCases for Approximate Local Recovery

   

   curcur committed Nov 8, 2020
   Configuration menu

   • View commit details
   • Copy full SHA for 46b3d4b
   • Browse repository at this point

   Copy the full SHA

   46b3d4b View commit details

   Browse the repository at this point in the history