This is an automated email from the ASF dual-hosted git repository. zhijiang pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from f074d1f [FLINK-14758] Add Executor-related interfaces + wire their discovery to environments. add a9b1266 [FLINK-14472][runtime] Implement back-pressure monitor with non-blocking outputs No new revisions were added by this update. Summary of changes: docs/_includes/generated/web_configuration.html | 4 +- docs/fig/back_pressure_sampling.png | Bin 17635 -> 17525 bytes docs/monitoring/back_pressure.md | 18 +- docs/monitoring/back_pressure.zh.md | 22 +- .../flink/configuration/ConfigConstants.java | 4 +- .../org/apache/flink/configuration/WebOptions.java | 8 +- .../flink/runtime/executiongraph/Execution.java | 28 +- .../runtime/jobgraph/tasks/AbstractInvokable.java | 12 - .../jobmanager/slots/TaskManagerGateway.java | 26 +- .../jobmaster/JobManagerSharedServices.java | 31 +- .../runtime/jobmaster/RpcTaskManagerGateway.java | 17 +- ...Response.java => TaskBackPressureResponse.java} | 27 +- .../BackPressureRequestCoordinator.java | 369 ++++++++++++++++++ .../legacy/backpressure/BackPressureStats.java | 87 +++++ .../backpressure/BackPressureStatsTracker.java | 2 +- .../backpressure/BackPressureStatsTrackerImpl.java | 231 ++++------- .../backpressure/OperatorBackPressureStats.java | 68 +--- .../legacy/backpressure/StackTraceSample.java | 119 ------ .../backpressure/StackTraceSampleCoordinator.java | 392 ------------------- .../taskexecutor/BackPressureSampleService.java | 111 ++++++ ...leTask.java => BackPressureSampleableTask.java} | 10 +- .../taskexecutor/StackTraceSampleService.java | 128 ------- .../flink/runtime/taskexecutor/TaskExecutor.java | 38 +- .../runtime/taskexecutor/TaskExecutorGateway.java | 9 +- .../runtime/taskexecutor/TaskManagerRunner.java | 14 +- .../TaskStackTraceSampleableTaskAdapter.java | 58 --- .../org/apache/flink/runtime/taskmanager/Task.java | 26 +- .../executiongraph/ExecutionJobVertexTest.java | 26 +- .../utils/SimpleAckingTaskManagerGateway.java | 9 +- .../TestingJobManagerSharedServicesBuilder.java | 14 +- .../BackPressureRequestCoordinatorTest.java | 343 +++++++++++++++++ .../BackPressureStatsTrackerImplTest.java | 293 ++++++++------ .../StackTraceSampleCoordinatorTest.java | 421 --------------------- .../BackPressureSampleServiceTest.java | 123 ++++++ .../taskexecutor/StackTraceSampleServiceTest.java | 189 --------- .../TaskExecutorPartitionLifecycleTest.java | 8 +- .../taskexecutor/TaskExecutorSubmissionTest.java | 154 +++----- .../runtime/taskexecutor/TaskExecutorTest.java | 6 +- .../TaskSubmissionTestEnvironment.java | 4 +- .../runtime/taskexecutor/TestingTaskExecutor.java | 6 +- .../taskexecutor/TestingTaskExecutorGateway.java | 11 +- .../apache/flink/runtime/taskmanager/TaskTest.java | 5 +- ...pInvokable.java => OutputBlockedInvokable.java} | 23 +- .../streaming/runtime/tasks/SourceStreamTask.java | 6 - 44 files changed, 1526 insertions(+), 1974 deletions(-) rename flink-runtime/src/main/java/org/apache/flink/runtime/messages/{StackTraceSampleResponse.java => TaskBackPressureResponse.java} (72%) create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/backpressure/BackPressureRequestCoordinator.java create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/backpressure/BackPressureStats.java delete mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/backpressure/StackTraceSample.java delete mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/backpressure/StackTraceSampleCoordinator.java create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/BackPressureSampleService.java rename flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/{StackTraceSampleableTask.java => BackPressureSampleableTask.java} (76%) delete mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/StackTraceSampleService.java delete mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskStackTraceSampleableTaskAdapter.java create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/backpressure/BackPressureRequestCoordinatorTest.java delete mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/backpressure/StackTraceSampleCoordinatorTest.java create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/BackPressureSampleServiceTest.java delete mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/StackTraceSampleServiceTest.java copy flink-runtime/src/test/java/org/apache/flink/runtime/testtasks/{BlockingNoOpInvokable.java => OutputBlockedInvokable.java} (58%)