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%)
