This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 5e8d5a8 [hotfix] Rename JobClientImpl to ClusterClientJobClientAdapter
add 2eab3d8 [hotfix][runtime] Do state check before input check in
LAZY_FROM_SOURCES scheduling for better performance
add 88d9e7f [FLINK-14811][runtime] Replace Java Streams in input checking
with for-loops
No new revisions were added by this update.
Summary of changes:
.../runtime/executiongraph/ExecutionVertex.java | 46 +++++++++++++++++-----
.../strategy/InputDependencyConstraintChecker.java | 36 +++++++++++------
.../LazyFromSourcesSchedulingStrategy.java | 2 +-
3 files changed, 60 insertions(+), 24 deletions(-)
