You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@wayang.apache.org by gl...@apache.org on 2023/06/19 21:14:44 UTC

[incubator-wayang] 01/01: Merge pull request #334 from apache/revert-311-MonitoringHackIT

This is an automated email from the ASF dual-hosted git repository.

glauesppen pushed a commit to branch rel/1.0
in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git

commit 1cca34877ed31fea7520ed51b4d6b74493867ba2
Merge: 983b5947 e85aa571
Author: Glaucia Esppenchutz <g....@gmail.com>
AuthorDate: Mon Jun 19 22:14:39 2023 +0100

    Merge pull request #334 from apache/revert-311-MonitoringHackIT
    
    Revert "Updates for monitoring the runtime metrics of underlying plat…

 .../main/java/org/apache/wayang/core/api/Job.java  |  22 +-
 .../org/apache/wayang/core/api/WayangContext.java  |  29 --
 .../spark/monitoring/interfaces/Application.java   |  99 ----
 .../spark/monitoring/interfaces/Executor.java      | 140 ------
 .../wayang/spark/monitoring/interfaces/Job.java    | 102 ----
 .../monitoring/interfaces/SerializableObject.java  |  39 --
 .../wayang/spark/monitoring/interfaces/Stage.java  | 177 -------
 .../wayang/spark/monitoring/interfaces/Task.java   | 253 ----------
 .../spark/monitoring/interfaces/TaskMetric.java    | 175 -------
 .../spark/monitoring/metrics/ApplicationEnd.java   | 103 ----
 .../spark/monitoring/metrics/ApplicationStart.java |  96 ----
 .../spark/monitoring/metrics/ExecutorAdded.java    | 131 ------
 .../spark/monitoring/metrics/ExecutorRemoved.java  | 128 -----
 .../spark/monitoring/metrics/ExecutorUpdated.java  | 138 ------
 .../wayang/spark/monitoring/metrics/JobEnd.java    |  89 ----
 .../wayang/spark/monitoring/metrics/JobStart.java  |  88 ----
 .../spark/monitoring/metrics/SparkListener.java    | 524 ---------------------
 .../spark/monitoring/metrics/StageCompleted.java   | 182 -------
 .../monitoring/metrics/StageExecutorMetrics.java   | 165 -------
 .../spark/monitoring/metrics/StageSubmitted.java   | 163 -------
 .../wayang/spark/monitoring/metrics/TaskEnd.java   | 220 ---------
 .../monitoring/metrics/TaskGettingResult.java      | 218 ---------
 .../spark/monitoring/metrics/TaskMetric.java       | 158 -------
 .../wayang/spark/monitoring/metrics/TaskStart.java | 217 ---------
 .../wayang/spark/platform/SparkPlatform.java       |  31 +-
 .../main/resources/wayang-spark-kafka.properties   |  42 --
 wayang-platforms/wayang-spark/pom.xml              |  47 +-
 27 files changed, 44 insertions(+), 3732 deletions(-)