This is an automated email from the ASF dual-hosted git repository.
azagrebin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from b96f085 [FLINK-20432] Add timeouts to SQLClientSchemaRegistryITCase
add cbdebd1 [FLINK-20078][coordination] Factor out an ExecutionGraph
factory method for DefaultExecutionTopology
No new revisions were added by this update.
Summary of changes:
.../failover/flip1/PipelinedRegionComputeUtil.java | 11 +-
.../jobgraph/topology/DefaultLogicalTopology.java | 3 +-
.../adapter/DefaultExecutionTopology.java | 160 +++++++++++++--------
.../flip1/PipelinedRegionComputeUtilTest.java | 3 +-
.../strategy/TestingSchedulingTopology.java | 2 +-
5 files changed, 112 insertions(+), 67 deletions(-)
